redis还原

server/src/main/java/edp/core/config/RedisConfig.java

@@ -47,17 +47,17 @@ public class RedisConfig {
             log.info("Init redisTemplate");
             redisTemplate = (RedisTemplate<String, Object>) beanFactory.getBean("redisTemplate");
 
-            redisTemplate.setKeySerializer(new StringRedisSerializer());
-            redisTemplate.setValueSerializer(new GenericFastJsonRedisSerializer());
-            redisTemplate.setHashKeySerializer(new GenericJackson2JsonRedisSerializer());
-            redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
-
-            // 旧
 //            redisTemplate.setKeySerializer(new StringRedisSerializer());
-//            redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
+//            redisTemplate.setValueSerializer(new GenericFastJsonRedisSerializer());
 //            redisTemplate.setHashKeySerializer(new GenericJackson2JsonRedisSerializer());
 //            redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
 
+            // 旧
+            redisTemplate.setKeySerializer(new StringRedisSerializer());
+            redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
+            redisTemplate.setHashKeySerializer(new GenericJackson2JsonRedisSerializer());
+            redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
+
             redisTemplate.afterPropertiesSet();
 
             //用于测试连接

server/src/main/java/edp/davinci/core/config/RedisMessageListener.java

@@ -19,6 +19,7 @@
 
 package edp.davinci.core.config;
 
+import com.alibaba.fastjson.support.spring.GenericFastJsonRedisSerializer;
 import edp.core.config.RedisEnableCondition;
 import edp.davinci.core.service.RedisMessageReceiver;
 import lombok.extern.slf4j.Slf4j;
@@ -67,6 +68,9 @@ public class RedisMessageListener {
 
     @Bean
     MessageListenerAdapter listenerAdapter2(MessageReceiver receiver) {
+        MessageListenerAdapter adapter = new MessageListenerAdapter(receiver, "receive");
+        adapter.setStringSerializer(new StringRedisSerializer());
+        adapter.setSerializer(new GenericFastJsonRedisSerializer());
         return new MessageListenerAdapter(receiver, "receiverMessage");
     }