| | |
| | | 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
|
| | |
| | | * @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);
|
| | | }
|
| | |
|
| | |
| | | * @param key
|
| | | * @param value
|
| | | */
|
| | | public void zRemove(String key, String value) {
|
| | | public void zRemove(Object key, Object value) {
|
| | | redisTemplate.opsForZSet().remove(key, value);
|
| | | }
|
| | |
|
| | |
| | | *
|
| | | * @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);
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | * @param value
|
| | | * @return
|
| | | */
|
| | | public Double zScore(String key, String value) {
|
| | | public Double zScore(Object key, Object value) {
|
| | | return redisTemplate.opsForZSet().score(key, value);
|
| | | }
|
| | |
|
| | |
| | | * @param value
|
| | | * @return
|
| | | */
|
| | | public Long zRank(String key, String value) {
|
| | | public Long zRank(Object key, Object value) {
|
| | | return redisTemplate.opsForZSet().rank(key, value);
|
| | | }
|
| | |
|
| | |
| | | * @param key
|
| | | * @return
|
| | | */
|
| | | public Long zSize(String key) {
|
| | | public Long zSize(Object key) {
|
| | | return redisTemplate.opsForZSet().zCard(key);
|
| | | }
|
| | |
|
| | |
| | | * @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);
|
| | | }
|
| | | /**
|
| | |
| | | * @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);
|
| | | }
|
| | | /**
|
| | |
| | | * @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);
|
| | | }
|
| | | /**
|
| | |
| | | * @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);
|
| | | }
|
| | |
|
| | |
| | | }
|
| | |
|
| | | /**
|
| | | * 在键为 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
|
| | |
| | | return new ArrayList<>(keys);
|
| | | }
|
| | |
|
| | | // ============================== 消息发送与订阅 ==============================
|
| | | public void convertAndSend(String channel, JSONObject msg) {
|
| | | // redisTemplate.convertAndSend(channel, msg);
|
| | | redisTemplate.convertAndSend(channel, msg);
|
| | |
|
| | | }
|
| | |
|
| | | }
|