1212import org .springframework .data .redis .core .ReactiveRedisTemplate ;
1313import org .springframework .data .redis .core .RedisTemplate ;
1414import org .springframework .data .redis .listener .RedisMessageListenerContainer ;
15- import org .springframework .data .redis .serializer .GenericJackson2JsonRedisSerializer ;
16- import org .springframework .data .redis .serializer .RedisSerializationContext ;
17- import org .springframework .data .redis .serializer .StringRedisSerializer ;
15+ import org .springframework .data .redis .serializer .*;
1816
1917import java .time .Duration ;
2018import java .util .HashMap ;
@@ -54,12 +52,22 @@ public RedisTemplate<String, Object> redisTemplateForObject(RedisConnectionFacto
5452 RedisTemplate <String , Object > redisTemplate = new RedisTemplate <>();
5553 redisTemplate .setConnectionFactory (connectionFactory );
5654 redisTemplate .setKeySerializer (new StringRedisSerializer ());
57- redisTemplate .setValueSerializer (new GenericJackson2JsonRedisSerializer ( ));
55+ redisTemplate .setValueSerializer (new Jackson2JsonRedisSerializer <>( String . class ));
5856 return redisTemplate ;
5957 }
6058
6159 @ Bean
6260 public ReactiveRedisTemplate <String , String > reactiveRedisTemplate (ReactiveRedisConnectionFactory connectionFactory ) {
63- return new ReactiveRedisTemplate <>(connectionFactory , RedisSerializationContext .string ());
61+ RedisSerializer <String > serializer = new StringRedisSerializer ();
62+ Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer <>(String .class );
63+ RedisSerializationContext serializationContext = RedisSerializationContext
64+ .<String , String >newSerializationContext ()
65+ .key (serializer )
66+ .value (jackson2JsonRedisSerializer )
67+ .hashKey (serializer )
68+ .hashValue (jackson2JsonRedisSerializer )
69+ .build ();
70+ 71+ return new ReactiveRedisTemplate <>(connectionFactory , serializationContext );
6472 }
6573}
0 commit comments