|
@@ -1,9 +1,6 @@
|
|
|
package org.jeecg.common.util;
|
|
|
|
|
|
-import java.util.HashSet;
|
|
|
-import java.util.List;
|
|
|
-import java.util.Map;
|
|
|
-import java.util.Set;
|
|
|
+import java.util.*;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@@ -46,7 +43,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 根据key 获取过期时间
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键 不能为null
|
|
|
* @return 时间(秒) 返回0代表为永久有效
|
|
|
*/
|
|
@@ -56,7 +53,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 判断key是否存在
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @return true 存在 false不存在
|
|
|
*/
|
|
@@ -71,7 +68,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 删除缓存
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 可以传一个值 或多个
|
|
|
*/
|
|
|
@SuppressWarnings("unchecked")
|
|
@@ -80,7 +77,7 @@ public class RedisUtil {
|
|
|
if (key.length == 1) {
|
|
|
redisTemplate.delete(key[0]);
|
|
|
} else {
|
|
|
- redisTemplate.delete(CollectionUtils.arrayToList(key));
|
|
|
+ redisTemplate.delete(Arrays.asList(key));
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -88,7 +85,7 @@ public class RedisUtil {
|
|
|
// ============================String=============================
|
|
|
/**
|
|
|
* 普通缓存获取
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @return 值
|
|
|
*/
|
|
@@ -98,7 +95,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 普通缓存放入
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param value 值
|
|
|
* @return true成功 false失败
|
|
@@ -116,7 +113,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 普通缓存放入并设置时间
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param value 值
|
|
|
* @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
|
|
@@ -138,7 +135,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 递增
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param by 要增加几(大于0)
|
|
|
* @return
|
|
@@ -152,7 +149,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 递减
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param by 要减少几(小于0)
|
|
|
* @return
|
|
@@ -167,7 +164,7 @@ public class RedisUtil {
|
|
|
// ================================Map=================================
|
|
|
/**
|
|
|
* HashGet
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键 不能为null
|
|
|
* @param item 项 不能为null
|
|
|
* @return 值
|
|
@@ -178,7 +175,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 获取hashKey对应的所有键值
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @return 对应的多个键值
|
|
|
*/
|
|
@@ -188,7 +185,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* HashSet
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param map 对应多个键值
|
|
|
* @return true 成功 false 失败
|
|
@@ -205,7 +202,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* HashSet 并设置时间
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param map 对应多个键值
|
|
|
* @param time 时间(秒)
|
|
@@ -226,7 +223,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 向一张hash表中放入数据,如果不存在将创建
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param item 项
|
|
|
* @param value 值
|
|
@@ -244,7 +241,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 向一张hash表中放入数据,如果不存在将创建
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param item 项
|
|
|
* @param value 值
|
|
@@ -266,7 +263,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 删除hash表中的值
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键 不能为null
|
|
|
* @param item 项 可以使多个 不能为null
|
|
|
*/
|
|
@@ -276,7 +273,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 判断hash表中是否有该项的值
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键 不能为null
|
|
|
* @param item 项 不能为null
|
|
|
* @return true 存在 false不存在
|
|
@@ -287,7 +284,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* hash递增 如果不存在,就会创建一个 并把新增后的值返回
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param item 项
|
|
|
* @param by 要增加几(大于0)
|
|
@@ -299,7 +296,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* hash递减
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param item 项
|
|
|
* @param by 要减少记(小于0)
|
|
@@ -312,7 +309,7 @@ public class RedisUtil {
|
|
|
// ============================set=============================
|
|
|
/**
|
|
|
* 根据key获取Set中的所有值
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @return
|
|
|
*/
|
|
@@ -327,7 +324,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 根据value从一个set中查询,是否存在
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param value 值
|
|
|
* @return true 存在 false不存在
|
|
@@ -343,7 +340,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 将数据放入set缓存
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param values 值 可以是多个
|
|
|
* @return 成功个数
|
|
@@ -359,7 +356,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 将set数据放入缓存
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param time 时间(秒)
|
|
|
* @param values 值 可以是多个
|
|
@@ -380,7 +377,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 获取set缓存的长度
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @return
|
|
|
*/
|
|
@@ -395,7 +392,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 移除值为value的
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param values 值 可以是多个
|
|
|
* @return 移除的个数
|
|
@@ -413,7 +410,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 获取list缓存的内容
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param start 开始
|
|
|
* @param end 结束 0 到 -1代表所有值
|
|
@@ -432,7 +429,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 获取list缓存的长度
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @return
|
|
|
*/
|
|
@@ -447,7 +444,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 通过索引 获取list中的值
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param index 索引 index>=0时, 0 表头,1 第二个元素,依次类推;index<0时,-1,表尾,-2倒数第二个元素,依次类推
|
|
|
* @return
|
|
@@ -463,7 +460,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 将list放入缓存
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param value 值
|
|
|
* @param time 时间(秒)
|
|
@@ -481,7 +478,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 将list放入缓存
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param value 值
|
|
|
* @param time 时间(秒)
|
|
@@ -502,7 +499,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 将list放入缓存
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param value 值
|
|
|
* @param time 时间(秒)
|
|
@@ -520,7 +517,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 将list放入缓存
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param value 值
|
|
|
* @param time 时间(秒)
|
|
@@ -541,7 +538,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 根据索引修改list中的某条数据
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param index 索引
|
|
|
* @param value 值
|
|
@@ -559,7 +556,7 @@ public class RedisUtil {
|
|
|
|
|
|
/**
|
|
|
* 移除N个值为value
|
|
|
- *
|
|
|
+ *
|
|
|
* @param key 键
|
|
|
* @param count 移除多少个
|
|
|
* @param value 值
|
|
@@ -588,7 +585,7 @@ public class RedisUtil {
|
|
|
try {
|
|
|
return redisTemplate.execute((RedisCallback<Set<String>>) connection -> {
|
|
|
Set<String> binaryKeys = new HashSet<>();
|
|
|
- Cursor<byte[]> cursor = connection.scan(new ScanOptions.ScanOptionsBuilder().match(realKey).count(Integer.MAX_VALUE).build());
|
|
|
+ Cursor<byte[]> cursor = connection.scan(ScanOptions.scanOptions().match(realKey).count(Integer.MAX_VALUE).build());
|
|
|
while (cursor.hasNext()) {
|
|
|
binaryKeys.add(new String(cursor.next()));
|
|
|
}
|