Merge branch 'dt' of wangfan/adweb3-server into master

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/adweb/common/util/AdwebRedisUtil.java

@@ -6,9 +6,14 @@ import com.fasterxml.jackson.databind.MapperFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.json.JsonMapper;
 import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
+
+import jakarta.annotation.PostConstruct;
+
 import lombok.extern.slf4j.Slf4j;
+
 import org.jeecg.common.base.BaseMap;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.core.RedisCallback;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
@@ -21,30 +26,22 @@ import java.util.*;
 import java.util.concurrent.TimeUnit;
 
 /**
- * redis 工具类
+ * Redis 工具类
  *
- * @author Scott
+ * @author wfansh
  */
 @Component
 @Slf4j
 public class AdwebRedisUtil {
 
-    @Autowired
-    private RedisTemplate<String, Object> redisTemplate;
-
+    @Autowired private RedisConnectionFactory connectionFactory;
 
-    @Autowired(required = false)
-    public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) {
-        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = jacksonSerializer();
-        RedisSerializer<String> stringSerializer = new StringRedisSerializer();
-        redisTemplate.setKeySerializer(stringSerializer);
-        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
-        redisTemplate.setHashKeySerializer(stringSerializer);
-        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
-        this.redisTemplate = redisTemplate;
-    }
+    // 自定义serializer
+    // 不使用org.jeecg.common.modules.redis.config.RedisConfig
+    private RedisTemplate<String, Object> redisTemplate;
 
-    private Jackson2JsonRedisSerializer<Object> jacksonSerializer() {
+    @PostConstruct
+    public void initRedisTemplate() {
         JsonMapper jsonMapper =
                 JsonMapper.builder()
                         .visibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY)
@@ -53,21 +50,28 @@ public class AdwebRedisUtil {
                                 ObjectMapper.DefaultTyping.NON_FINAL)
                         .configure(MapperFeature.USE_ANNOTATIONS, false) // 忽略@JsonIgnore注解，缓存所有字段
                         .build();
+        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer =
+                new Jackson2JsonRedisSerializer<>(jsonMapper, Object.class);
+        RedisSerializer<String> stringSerializer = new StringRedisSerializer();
 
-
-        return new Jackson2JsonRedisSerializer<>(jsonMapper, Object.class);
+        this.redisTemplate = new RedisTemplate();
+        this.redisTemplate.setConnectionFactory(connectionFactory);
+        this.redisTemplate.setKeySerializer(stringSerializer);
+        this.redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
+        this.redisTemplate.setHashKeySerializer(stringSerializer);
+        this.redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
+        this.redisTemplate.afterPropertiesSet();
     }
 
     public void sendMessage(String handlerName, BaseMap params) {
         params.put("handlerName", handlerName);
-        this.setRedisTemplate(this.redisTemplate);
         this.redisTemplate.convertAndSend("jeecg_redis_topic", params);
     }
 
     /**
      * 指定缓存失效时间
      *
-     * @param key  键
+     * @param key 键
      * @param time 时间(秒)
      * @return
      */
@@ -143,7 +147,6 @@ public class AdwebRedisUtil {
      * @return 值
      */
     public Object get(String key) {
-        this.setRedisTemplate(this.redisTemplate);
         return key == null ? null : redisTemplate.opsForValue().get(key);
     }
 
@@ -154,7 +157,6 @@ public class AdwebRedisUtil {
      * @return 值
      */
     public String getString(String key) {
-        this.setRedisTemplate(this.redisTemplate);
         Object valueObj = get(key);
         return valueObj == null ? "" : valueObj.toString();
     }
@@ -162,7 +164,7 @@ public class AdwebRedisUtil {
     /**
      * 普通缓存放入
      *
-     * @param key   键
+     * @param key 键
      * @param value 值
      * @return true成功 false失败
      */
@@ -179,9 +181,9 @@ public class AdwebRedisUtil {
     /**
      * 普通缓存放入并设置时间
      *
-     * @param key   键
+     * @param key 键
      * @param value 值
-     * @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期
+     * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
      * @return true成功 false 失败
      */
     public boolean set(String key, Object value, long time) {
@@ -201,7 +203,7 @@ public class AdwebRedisUtil {
     /**
      * 递增
      *
-     * @param key   键
+     * @param key 键
      * @param delta 要增加几(大于0)
      * @return
      */
@@ -215,7 +217,7 @@ public class AdwebRedisUtil {
     /**
      * 递减
      *
-     * @param key   键
+     * @param key 键
      * @param delta 要减少几(小于0)
      * @return
      */
@@ -231,7 +233,7 @@ public class AdwebRedisUtil {
     /**
      * HashGet
      *
-     * @param key  键 不能为null
+     * @param key 键 不能为null
      * @param item 项 不能为null
      * @return 值
      */
@@ -269,8 +271,8 @@ public class AdwebRedisUtil {
     /**
      * HashSet 并设置时间
      *
-     * @param key  键
-     * @param map  对应多个键值
+     * @param key 键
+     * @param map 对应多个键值
      * @param time 时间(秒)
      * @return true成功 false失败
      */
@@ -290,8 +292,8 @@ public class AdwebRedisUtil {
     /**
      * 向一张hash表中放入数据,如果不存在将创建
      *
-     * @param key   键
-     * @param item  项
+     * @param key 键
+     * @param item 项
      * @param value 值
      * @return true 成功 false失败
      */
@@ -308,10 +310,10 @@ public class AdwebRedisUtil {
     /**
      * 向一张hash表中放入数据,如果不存在将创建
      *
-     * @param key   键
-     * @param item  项
+     * @param key 键
+     * @param item 项
      * @param value 值
-     * @param time  时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
+     * @param time 时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
      * @return true 成功 false失败
      */
     public boolean hset(String key, String item, Object value, long time) {
@@ -330,7 +332,7 @@ public class AdwebRedisUtil {
     /**
      * 删除hash表中的值
      *
-     * @param key  键 不能为null
+     * @param key 键 不能为null
      * @param item 项 可以使多个 不能为null
      */
     public void hdel(String key, Object... item) {
@@ -340,7 +342,7 @@ public class AdwebRedisUtil {
     /**
      * 判断hash表中是否有该项的值
      *
-     * @param key  键 不能为null
+     * @param key 键 不能为null
      * @param item 项 不能为null
      * @return true 存在 false不存在
      */
@@ -351,9 +353,9 @@ public class AdwebRedisUtil {
     /**
      * hash递增 如果不存在,就会创建一个 并把新增后的值返回
      *
-     * @param key  键
+     * @param key 键
      * @param item 项
-     * @param by   要增加几(大于0)
+     * @param by 要增加几(大于0)
      * @return
      */
     public double hincr(String key, String item, double by) {
@@ -363,9 +365,9 @@ public class AdwebRedisUtil {
     /**
      * hash递减
      *
-     * @param key  键
+     * @param key 键
      * @param item 项
-     * @param by   要减少记(小于0)
+     * @param by 要减少记(小于0)
      * @return
      */
     public double hdecr(String key, String item, double by) {
@@ -392,7 +394,7 @@ public class AdwebRedisUtil {
     /**
      * 根据value从一个set中查询,是否存在
      *
-     * @param key   键
+     * @param key 键
      * @param value 值
      * @return true 存在 false不存在
      */
@@ -408,7 +410,7 @@ public class AdwebRedisUtil {
     /**
      * 将数据放入set缓存
      *
-     * @param key    键
+     * @param key 键
      * @param values 值 可以是多个
      * @return 成功个数
      */
@@ -424,8 +426,8 @@ public class AdwebRedisUtil {
     /**
      * 将set数据放入缓存
      *
-     * @param key    键
-     * @param time   时间(秒)
+     * @param key 键
+     * @param time 时间(秒)
      * @param values 值 可以是多个
      * @return 成功个数
      */
@@ -460,7 +462,7 @@ public class AdwebRedisUtil {
     /**
      * 移除值为value的
      *
-     * @param key    键
+     * @param key 键
      * @param values 值 可以是多个
      * @return 移除的个数
      */
@@ -479,9 +481,9 @@ public class AdwebRedisUtil {
     /**
      * 获取list缓存的内容
      *
-     * @param key   键
+     * @param key 键
      * @param start 开始
-     * @param end   结束 0 到 -1代表所有值
+     * @param end 结束 0 到 -1代表所有值
      * @return
      */
     public List<Object> lGet(String key, long start, long end) {
@@ -511,7 +513,7 @@ public class AdwebRedisUtil {
     /**
      * 通过索引 获取list中的值
      *
-     * @param key   键
+     * @param key 键
      * @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
      * @return
      */
@@ -527,7 +529,7 @@ public class AdwebRedisUtil {
     /**
      * 将list放入缓存
      *
-     * @param key   键
+     * @param key 键
      * @param value 值
      * @return
      */
@@ -544,9 +546,9 @@ public class AdwebRedisUtil {
     /**
      * 将list放入缓存
      *
-     * @param key   键
+     * @param key 键
      * @param value 值
-     * @param time  时间(秒)
+     * @param time 时间(秒)
      * @return
      */
     public boolean lSet(String key, Object value, long time) {
@@ -565,7 +567,7 @@ public class AdwebRedisUtil {
     /**
      * 将list放入缓存
      *
-     * @param key   键
+     * @param key 键
      * @param value 值
      * @return
      */
@@ -582,9 +584,9 @@ public class AdwebRedisUtil {
     /**
      * 将list放入缓存
      *
-     * @param key   键
+     * @param key 键
      * @param value 值
-     * @param time  时间(秒)
+     * @param time 时间(秒)
      * @return
      */
     public boolean lSet(String key, List<Object> value, long time) {
@@ -603,7 +605,7 @@ public class AdwebRedisUtil {
     /**
      * 根据索引修改list中的某条数据
      *
-     * @param key   键
+     * @param key 键
      * @param index 索引
      * @param value 值
      * @return
@@ -621,7 +623,7 @@ public class AdwebRedisUtil {
     /**
      * 移除N个值为value
      *
-     * @param key   键
+     * @param key 键
      * @param count 移除多少个
      * @param value 值
      * @return 移除的个数
@@ -639,7 +641,7 @@ public class AdwebRedisUtil {
     /**
      * 获取锁
      *
-     * @param lockKey        锁的键
+     * @param lockKey 锁的键
      * @param lockExpireMils 获取锁的时间
      * @return 是否获取到锁
      */
@@ -674,7 +676,7 @@ public class AdwebRedisUtil {
                                                 return oldValue == null
                                                         ? false
                                                         : Long.parseLong(new String(oldValue))
-                                                        < nowTime;
+                                                                < nowTime;
                                             }
                                         }
                                     }