import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
@Test
public void testCustomPayloadSerializer() throws Exception {
	RedisTemplate<String, Long> template = new RedisTemplate<>();
	template.setKeySerializer(new StringRedisSerializer());
	template.setValueSerializer(new GenericToStringSerializer<>(Long.class));
	template.setConnectionFactory(connectionFactory);
	template.afterPropertiesSet();

	adapter.setSerializer(new GenericToStringSerializer<Long>(Long.class));
	adapter.afterPropertiesSet();
	adapter.start();

	template.boundListOps(currentQueueName).rightPush(5l);
	@SuppressWarnings("unchecked")
	Message<Long> message = (Message<Long>) messages.poll((int)(1000 * timeoutMultiplier), TimeUnit.MILLISECONDS);
	assertEquals(5L, (long) message.getPayload());
}
 

import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
@Bean
public RedisTemplate<String, Object> redisTemplate() {
    final RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
    template.setConnectionFactory(jedisConnectionFactory());
    template.setValueSerializer(new GenericToStringSerializer<Object>(Object.class));
    return template;
}
 

import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
@Bean(name = "redisListTemplate")
RedisTemplate<String, Long> redisListTemplate() {
    RedisTemplate<String, Long> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(jedisConnectionFactory());
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setValueSerializer(new GenericToStringSerializer<>(Long.class));
    return redisTemplate;
}
 

import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
@Bean(name = "redisCountingTemplate")
RedisTemplate<String, Integer> redisCountingTemplate() {
    RedisTemplate<String, Integer> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(jedisConnectionFactory());
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setHashKeySerializer(new StringRedisSerializer());
    redisTemplate.setHashValueSerializer(new GenericToStringSerializer<>(Integer.class));
    return redisTemplate;
}
 

import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
@Bean
public RedisTemplate<Object, Object> redisTemplate() {
  RedisTemplate<Object, Object> template = new RedisTemplate<>();
  template.setConnectionFactory(connectionFactory());
  template.setHashKeySerializer(new GenericToStringSerializer<>(UUID.class));
  template.setKeySerializer(new GenericToStringSerializer<>(UUID.class));
  template.setHashValueSerializer(new GenericToStringSerializer<>(Object.class));
  template.setValueSerializer(new GenericToStringSerializer<>(Object.class));
  return template;
}
 

import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
@Test
public void testWithCustomSerializer() throws Exception {
	GenericToStringSerializer<Long> serializer = new GenericToStringSerializer<Long>(Long.class);
	setupListener(serializer);
	final RedisPublishingMessageHandler handler = new RedisPublishingMessageHandler(connectionFactory);
	handler.setBeanFactory(BinderTestUtils.MOCK_BF);
	handler.setTopic(TOPIC);
	handler.setSerializer(serializer);
	handler.afterPropertiesSet();
	for (long i = 0; i < NUM_MESSAGES; i++) {
		handler.handleMessage(MessageBuilder.withPayload(i).build());
	}
	latch.await(3, TimeUnit.SECONDS);
	assertEquals(0, latch.getCount());
	container.stop();
}
 

import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
@Test
public void testCustomPayloadSerializer() throws Exception {
	RedisTemplate<String, Long> template = new RedisTemplate<String, Long>();
	template.setKeySerializer(new StringRedisSerializer());
	template.setValueSerializer(new GenericToStringSerializer<Long>(Long.class));
	template.setConnectionFactory(connectionFactory);
	template.afterPropertiesSet();

	adapter.setSerializer(new GenericToStringSerializer<Long>(Long.class));
	adapter.afterPropertiesSet();

	adapter.handleMessage(new GenericMessage<Long>(5l));
	assertEquals(Long.valueOf(5), template.boundListOps(QUEUE_NAME).rightPop());
}
 

import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
public RedisAggregateCounterRepository(RedisConnectionFactory redisConnectionFactory, RetryOperations retryOperations) {
	redisTemplate = new RedisRetryTemplate<String, String>();
	redisTemplate.setConnectionFactory(redisConnectionFactory);
	redisTemplate.setKeySerializer(new StringRedisSerializer());
	redisTemplate.setValueSerializer(new StringRedisSerializer());
	redisTemplate.setHashKeySerializer(new StringRedisSerializer());
	redisTemplate.setHashValueSerializer(new GenericToStringSerializer<Long>(Long.class));
	redisTemplate.setRetryOperations(retryOperations);
	redisTemplate.afterPropertiesSet();
	hashOperations = redisTemplate.opsForHash();
	setOperations = redisTemplate.opsForSet();
}
 

import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
static <K, V> RedisTemplate<K, V> createRedisTemplate(
		RedisConnectionFactory connectionFactory, Class<V> valueClass) {
	RedisTemplate<K, V> redisTemplate = new RedisTemplate<K, V>();
	redisTemplate.setKeySerializer(new StringRedisSerializer());
	redisTemplate.setValueSerializer(new GenericToStringSerializer<V>(valueClass));

	// avoids proxy
	redisTemplate.setExposeConnection(true);

	redisTemplate.setConnectionFactory(connectionFactory);
	redisTemplate.afterPropertiesSet();
	return redisTemplate;
}
 

import org.springframework.data.redis.serializer.GenericToStringSerializer; //导入依赖的package包/类
@Bean(name = "redisTemplate")
public <String,V> RedisTemplate<String,V> getRedisTemplate(){
    RedisTemplate<String,V> redisTemplate =  new RedisTemplate<String, V>();
    redisTemplate.setConnectionFactory(getConnectionFactory());
    redisTemplate.setValueSerializer(new GenericToStringSerializer<Object>(Object.class));
    return redisTemplate;
}