648540858
2022-05-06 5d901b5e3f033e8b04e53420d68626cbd87431c8
src/main/java/com/genersoft/iot/vmp/utils/redis/RedisUtil.java
@@ -3,19 +3,19 @@
import java.util.*;
import java.util.concurrent.TimeUnit;
import com.alibaba.fastjson.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.*;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
/**    
 * @Description:Redis工具类
 * @description:Redis工具类
 * @author: swwheihei
 * @date:   2020年5月6日 下午8:27:29     
 */
@Component
@SuppressWarnings(value = {"rawtypes", "unchecked"})
public class RedisUtil {
   @Autowired
@@ -397,7 +397,7 @@
     * @param value
     * @param score
     */
    public void zAdd(String key, String value, double score) {
    public void zAdd(Object key, Object value, double score) {
        redisTemplate.opsForZSet().add(key, value, score);
    }
@@ -407,7 +407,7 @@
     * @param key
     * @param value
     */
    public void zRemove(String key, String value) {
    public void zRemove(Object key, Object value) {
        redisTemplate.opsForZSet().remove(key, value);
    }
@@ -416,10 +416,10 @@
     *
     * @param key
     * @param value
     * @param score
     * @param delta -1 表示减 1 表示加1
     */
    public Double zIncrScore(String key, String value, double score) {
        return redisTemplate.opsForZSet().incrementScore(key, value, score);
    public Double zIncrScore(Object key, Object value, double delta) {
        return redisTemplate.opsForZSet().incrementScore(key, value, delta);
    }
    /**
@@ -429,7 +429,7 @@
     * @param value
     * @return
     */
    public Double zScore(String key, String value) {
    public Double zScore(Object key, Object value) {
        return redisTemplate.opsForZSet().score(key, value);
    }
@@ -440,7 +440,7 @@
     * @param value
     * @return
     */
    public Long zRank(String key, String value) {
    public Long zRank(Object key, Object value) {
        return redisTemplate.opsForZSet().rank(key, value);
    }
@@ -450,7 +450,7 @@
     * @param key
     * @return
     */
    public Long zSize(String key) {
    public Long zSize(Object key) {
        return redisTemplate.opsForZSet().zCard(key);
    }
@@ -464,7 +464,7 @@
     * @param end
     * @return
     */
    public Set<String> ZRange(String key, int start, int end) {
    public Set<Object> ZRange(Object key, int start, int end) {
        return redisTemplate.opsForZSet().range(key, start, end);
    }
    /**
@@ -475,7 +475,7 @@
     * @param end
     * @return
     */
    public Set<ZSetOperations.TypedTuple<String>> zRangeWithScore(String key, int start, int end) {
    public Set<ZSetOperations.TypedTuple<String>> zRangeWithScore(Object key, int start, int end) {
        return redisTemplate.opsForZSet().rangeWithScores(key, start, end);
    }
    /**
@@ -488,7 +488,7 @@
     * @param end
     * @return
     */
    public Set<String> zRevRange(String key, int start, int end) {
    public Set<String> zRevRange(Object key, int start, int end) {
        return redisTemplate.opsForZSet().reverseRange(key, start, end);
    }
    /**
@@ -499,7 +499,7 @@
     * @param max
     * @return
     */
    public Set<String> zSortRange(String key, int min, int max) {
    public Set<String> zSortRange(Object key, int min, int max) {
        return redisTemplate.opsForZSet().rangeByScore(key, min, max);
    }
@@ -661,6 +661,24 @@
    }
    /**
     * 在键为 key 的 list中移除第一个元素
     * @param key 键
     * @return
     */
    public Object lLeftPop(String key) {
        return redisTemplate.opsForList().leftPop(key);
    }
    /**
     * 在键为 key 的 list中移除、最后一个元素
     * @param key 键
     * @return
     */
    public Object lrightPop(String key) {
        return redisTemplate.opsForList().rightPop(key);
    }
    /**
     * 模糊查询
     * @param key 键
     * @return true / false
@@ -730,4 +748,11 @@
        return new ArrayList<>(keys);
    }
    //    ============================== 消息发送与订阅 ==============================
    public void convertAndSend(String channel, JSONObject msg) {
//        redisTemplate.convertAndSend(channel, msg);
        redisTemplate.convertAndSend(channel, msg);
    }
}