redis同步

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

@@ -47,18 +47,18 @@ 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/core/utils/RedisUtils.java

@@ -89,11 +89,6 @@ public class RedisUtils {
         ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();
         Object value = valueOperations.get(key);
 
-        redisTemplate.setKeySerializer(new StringRedisSerializer());
-        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
-        redisTemplate.setHashKeySerializer(new GenericJackson2JsonRedisSerializer());
-        redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
-        redisTemplate.afterPropertiesSet();
 
         return value;
     }
@@ -107,6 +102,11 @@ public class RedisUtils {
         if (!isRedisEnable) {
             throw new RuntimeException("Redis is disabled");
         }
+        redisTemplate.setKeySerializer(new StringRedisSerializer());
+        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
+        redisTemplate.setHashKeySerializer(new GenericJackson2JsonRedisSerializer());
+        redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
+        redisTemplate.afterPropertiesSet();
 
         redisTemplate.convertAndSend(channel, message);
     }