|
|
@@ -1,6 +1,5 @@
|
|
|
package com.jiayue.ipfcst.console.util;
|
|
|
|
|
|
-import com.jiayue.ipfcst.common.data.abst.equipmentstatus.AbstractEquipmentStatusData;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
import redis.clients.jedis.Jedis;
|
|
|
@@ -8,8 +7,6 @@ import redis.clients.jedis.JedisPool;
|
|
|
import redis.clients.jedis.Pipeline;
|
|
|
import redis.clients.jedis.Tuple;
|
|
|
|
|
|
-import java.lang.reflect.Field;
|
|
|
-import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
import java.util.Set;
|
|
|
@@ -26,1479 +23,1518 @@ public class RedisUtils {
|
|
|
除了该工具类提供的方法外，还可以在外面调用getJedis()方法，获取到jedis实例后，调用它原生的api来操作
|
|
|
*/
|
|
|
|
|
|
- /**
|
|
|
- * 获取jedis对象，并选择redis库。jedis默认是0号库，可传入1-16之间的数选择库存放数据
|
|
|
- * 原则上使用一个redis库存放数据，通过特定的key的命令规则来区分不同的数据就行了。
|
|
|
- *
|
|
|
- * @param index redis库号。使用可变参数的目的就是该参数可传可不传。
|
|
|
- * @return 返回jedis对象
|
|
|
- */
|
|
|
- public Jedis getJedis(int... index) {
|
|
|
- Jedis jedis = jedisPool.getResource();
|
|
|
- if (index != null && index.length > 0) {
|
|
|
- if (index[0] > 0 && index[0] <= 16){
|
|
|
- jedis.select(index[0]);
|
|
|
- }
|
|
|
- }
|
|
|
- return jedis;
|
|
|
- }
|
|
|
-
|
|
|
- /*######################## key的操作 ################################*/
|
|
|
-
|
|
|
- /**
|
|
|
- * 根据pattern返回当前库中的key
|
|
|
- *
|
|
|
- * @param pattern
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Set<String> keys(String pattern) {
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> keys = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- keys = jedis.keys(pattern);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return keys;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 删除一个或多个key
|
|
|
- *
|
|
|
- * @param key 一个或多个key
|
|
|
- */
|
|
|
- public Long del(String... key) {
|
|
|
- Jedis jedis = null;
|
|
|
- Long delNum = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- delNum =jedis.del(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return delNum;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 批量删除
|
|
|
- * @param keyList 要删除的key的集合
|
|
|
- */
|
|
|
- public void mdel(List<String> keyList){
|
|
|
- Jedis jedis = getJedis();
|
|
|
- //获取pipeline
|
|
|
- Pipeline pipeline = jedis.pipelined();
|
|
|
- for (String key : keyList) {
|
|
|
- pipeline.del(key);
|
|
|
- }
|
|
|
- //执行结果同步，这样才能保证结果的正确性。实际上不执行该方法也执行了上面的命令，但是结果确不一定完全正确。
|
|
|
- //注意
|
|
|
- pipeline.sync();
|
|
|
- //关闭连接
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 判断某个key是否还存在
|
|
|
- *
|
|
|
- * @param key key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Boolean exists(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- Boolean flag = false;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- flag = jedis.exists(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 设置某个key的过期时间，单位秒
|
|
|
- *
|
|
|
- * @param key key
|
|
|
- * @param seconds 过期时间秒
|
|
|
- */
|
|
|
- public void expire(String key, int seconds) {
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.expire(key, seconds);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 查看某个key还有几秒过期，-1表示永不过期 ，-2表示已过期
|
|
|
- *
|
|
|
- * @param key key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Long timeToLive(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- Long ttl;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- ttl = jedis.ttl(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return ttl;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 查看某个key对应的value的类型
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public String type(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- String type = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- type = jedis.type(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return type;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /*######################## string(字符串)的操作 ####################*/
|
|
|
-
|
|
|
- /**
|
|
|
- * 获取某个key的value，类型要对，只能value是string的才能获取
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public String get(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- String value = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- value = jedis.get(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return value;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 设置某个key的value
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @param value
|
|
|
- */
|
|
|
- public void set(String key, String value) {
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.set(key, value);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 字符串后追加内容
|
|
|
- *
|
|
|
- * @param key key
|
|
|
- * @param appendContent 要追加的内容
|
|
|
- */
|
|
|
- public void append(String key, String appendContent) {
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.append(key, appendContent);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回key的value的长度
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Long strlen(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- Long strLen = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- strLen = jedis.strlen(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return strLen;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * value 加1 必
|
|
|
- * 须是字符型数字
|
|
|
- * @param key
|
|
|
- * @return 增加后的值
|
|
|
- */
|
|
|
- public Long incr(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- Long incrResult = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- incrResult = jedis.incr(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return incrResult;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * value 减1 必须是字符型数字
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Long decr(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- Long decrResult = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- decrResult = jedis.decr(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return decrResult;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * value 加increment
|
|
|
- *
|
|
|
- * @param key key
|
|
|
- * @param increment 加几
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Long incrby(String key, int increment) {
|
|
|
- Jedis jedis = null;
|
|
|
- Long incrByResult = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- incrByResult = jedis.incrBy(key, increment);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return incrByResult;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * value 减increment
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @param increment
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Long decrby(String key, int increment) {
|
|
|
- Jedis jedis = null;
|
|
|
- Long decrByResult = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- decrByResult = jedis.decrBy(key, increment);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return decrByResult;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 给某个key设置过期时间和value，成功返回OK
|
|
|
- *
|
|
|
- * @param key key
|
|
|
- * @param seconds 过期时间秒
|
|
|
- * @param value 设置的值
|
|
|
- * @return
|
|
|
- */
|
|
|
- public String setex(String key, int seconds, String value) {
|
|
|
- Jedis jedis = null;
|
|
|
- String result = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- result = jedis.setex(key, seconds, value);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return result;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /*######################## list(列表)的操作 #######################*/
|
|
|
- //lpush rpush lpop rpop lrange lindex llen lset
|
|
|
-
|
|
|
- /**
|
|
|
- * 从左边向列表中添加值
|
|
|
- *
|
|
|
- * @param key key
|
|
|
- * @param str 要添加的值
|
|
|
- */
|
|
|
- public void lpush(String key, String str) {
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.lpush(key, str);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 从右边向列表中添加值
|
|
|
- *
|
|
|
- * @param key key
|
|
|
- * @param str 要添加的值
|
|
|
- */
|
|
|
- public void rpush(String key, String str) {
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.rpush(key, str);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 从左边取出一个列表中的值
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public String lpop(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- String lpop = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- lpop = jedis.lpop(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return lpop;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 从右边取出一个列表中的值
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public String rpop(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- String rpop = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- rpop = jedis.rpop(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return rpop;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 取出列表中指定范围内的值，0 到 -1 表示全部
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @param startIndex
|
|
|
- * @param endIndex
|
|
|
- * @return
|
|
|
- */
|
|
|
- public List<String> lrange(String key, int startIndex, int endIndex) {
|
|
|
- Jedis jedis = null;
|
|
|
- List<String> result = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- result = jedis.lrange(key, startIndex, endIndex);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return result;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回某列表指定索引位置的值
|
|
|
- *
|
|
|
- * @param key 列表key
|
|
|
- * @param index 索引位置
|
|
|
- * @return
|
|
|
- */
|
|
|
- public String lindex(String key, int index) {
|
|
|
- Jedis jedis = null;
|
|
|
- String lindex = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- lindex = jedis.lindex(key, index);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return lindex;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回某列表的长度
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Long llen(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- Long llen = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- llen = jedis.llen(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return llen;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 给某列表指定位置设置为指定的值
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @param index
|
|
|
- * @param str
|
|
|
- */
|
|
|
- public void lset(String key, Long index, String str) {
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.lset(key, index, str);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 对列表进行剪裁，保留指定闭区间的元素(索引位置也会重排)
|
|
|
- * @param key 列表key
|
|
|
- * @param startIndex 开始索引位置
|
|
|
- * @param endIndex 结束索引位置
|
|
|
- */
|
|
|
- public void ltrim(String key,Integer startIndex,Integer endIndex){
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.ltrim(key, startIndex, endIndex);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 从列表的左边阻塞弹出一个元素
|
|
|
- * @param key 列表的key
|
|
|
- * @param timeout 阻塞超时时间，0表示若没有元素就永久阻塞
|
|
|
- * @return
|
|
|
- */
|
|
|
- public List<String> blpop(String key,Integer timeout){
|
|
|
- Jedis jedis = null;
|
|
|
- List<String> valueList = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- valueList = jedis.blpop(timeout, key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return valueList;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 从列表的右边阻塞弹出一个元素
|
|
|
- * @param key 列表的key
|
|
|
- * @param timeout 阻塞超时时间，0表示若没有元素就永久阻塞
|
|
|
- * @return
|
|
|
- */
|
|
|
- public List<String> brpop(String key,Integer timeout){
|
|
|
- Jedis jedis = null;
|
|
|
- List<String> valueList = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- valueList = jedis.brpop(timeout, key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return valueList;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /*######################## hash(哈希表)的操作 #######################*/
|
|
|
- //hset hget hmset hmget hgetall hdel hkeys hvals hexists hincrby
|
|
|
-
|
|
|
- /**
|
|
|
- * 给某个hash表设置一个键值对
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @param field
|
|
|
- * @param value
|
|
|
- */
|
|
|
- public void hset(String key, String field, String value) {
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.hset(key, field, value);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 取出某个hash表中某个field对应的value
|
|
|
- *
|
|
|
- * @param key key
|
|
|
- * @param field field
|
|
|
- * @return
|
|
|
- */
|
|
|
- public String hget(String key, String field) {
|
|
|
- Jedis jedis = null;
|
|
|
- String hget = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- hget = jedis.hget(key, field);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return hget;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 某个hash表设置一个或多个键值对
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @param kvMap
|
|
|
- */
|
|
|
- public void hmset(String key, Map<String, String> kvMap) {
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.hmset(key, kvMap);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /**
|
|
|
- * 取出某个hash表中任意多个key对应的value的集合
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @param fields
|
|
|
- * @return
|
|
|
- */
|
|
|
- public List<String> hmget(String key, String... fields) {
|
|
|
- Jedis jedis = null;
|
|
|
- List<String> hmget = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- hmget = jedis.hmget(key, fields);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return hmget;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 取出某个hash表中所有的键值对
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Map<String, String> hgetall(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- Map<String, String> kvMap = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- kvMap = jedis.hgetAll(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return kvMap;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 判断某个hash表中的某个key是否存在
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @param field
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Boolean hexists(String key, String field) {
|
|
|
- Jedis jedis = null;
|
|
|
- Boolean exists = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- exists = jedis.hexists(key, field);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return exists;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回某个hash表中所有的key
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Set<String> hkeys(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> keys = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- keys = jedis.hkeys(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return keys;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回某个hash表中所有的value
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public List<String> hvals(String key) {
|
|
|
- Jedis jedis = null;
|
|
|
- List<String> hvals = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- hvals = jedis.hvals(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return hvals;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 删除某个hash表中的一个或多个键值对
|
|
|
- *
|
|
|
- * @param key
|
|
|
- * @param fields
|
|
|
- */
|
|
|
- public void hdel(String key, String... fields) {
|
|
|
- Jedis jedis = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- jedis.hdel(key, fields);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 给某个hash表中的某个field的value增加多少
|
|
|
- *
|
|
|
- * @param key hash表的key
|
|
|
- * @param field 表中的某个field
|
|
|
- * @param increment 增加多少
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Long hincrby(String key, String field, Long increment) {
|
|
|
- Jedis jedis = null;
|
|
|
- Long result = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- result = jedis.hincrBy(key, field, increment);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return result;
|
|
|
- }
|
|
|
-
|
|
|
- /*######################## set(集合)的操作 ###########################*/
|
|
|
-
|
|
|
- /**
|
|
|
- * 往set集合中添加一个或多个元素
|
|
|
- * @param key key
|
|
|
- * @param members 要添加的元素
|
|
|
- * @return 添加成功的元素个数
|
|
|
- */
|
|
|
- public Long sadd(String key,String... members){
|
|
|
- Jedis jedis = null;
|
|
|
- Long num = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- num = jedis.sadd(key, members);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return num;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回set集合中的所有元素，顺序与加入时的顺序一致
|
|
|
- * @param key key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Set<String> smembers(String key){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.smembers(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 判断集合中是否存在某个元素
|
|
|
- * @param key key
|
|
|
- * @param member 某个元素
|
|
|
- * @return true存在，false不存在
|
|
|
- */
|
|
|
- public Boolean sismember(String key,String member){
|
|
|
- Jedis jedis = null;
|
|
|
- Boolean isMember = false;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- isMember = jedis.sismember(key, member);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return isMember;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回set集合的长度
|
|
|
- * @param key key
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Long scard(String key){
|
|
|
- Jedis jedis = null;
|
|
|
- Long len = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- len = jedis.scard(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return len;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 删除set集合中指定的一个或多个元素
|
|
|
- * @param key
|
|
|
- * @param members 要删除的元素
|
|
|
- * @return 删除成功的元素个数
|
|
|
- */
|
|
|
- public Long srem(String key,String... members){
|
|
|
- Jedis jedis = null;
|
|
|
- Long num = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- num = jedis.srem(key,members);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return num;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 将key1中的元素key1Member移动到key2中
|
|
|
- * @param key1 来源集合key
|
|
|
- * @param key2 目的地集合key
|
|
|
- * @param key1Member key1中的元素
|
|
|
- * @return 1成功，0失败
|
|
|
- */
|
|
|
- public Long smove(String key1,String key2,String key1Member){
|
|
|
- Jedis jedis = null;
|
|
|
- Long num = 0L;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- num = jedis.smove(key1,key2,key1Member);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return num;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 随机查询返回集合中的指定个数的元素（若count为负数，返回的元素可能会重复）
|
|
|
- * @param key key
|
|
|
- * @param count 要查询返回的元素个数
|
|
|
- * @return 元素list集合
|
|
|
- */
|
|
|
- public List<String> srandmember(String key,int count){
|
|
|
- Jedis jedis = null;
|
|
|
- List<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.srandmember(key,count);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 从set集合中随机弹出指定个数个元素
|
|
|
- * @param key key
|
|
|
- * @param count 要弹出的个数
|
|
|
- * @return 随机弹出的元素
|
|
|
- */
|
|
|
- public Set<String> spop(String key,int count){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.spop(key,count);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 求交集，返回多个set集合相交的部分
|
|
|
- * @param setKeys 多个set集合的key
|
|
|
- * @return 相交的元素集合
|
|
|
- */
|
|
|
- public Set<String> sinter(String... setKeys){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.sinter(setKeys);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 求并集，求几个set集合的并集（因为set中不会有重复的元素，合并后的集合也不会有重复的元素）
|
|
|
- * @param setKeys 多个set的key
|
|
|
- * @return 合并后的集合
|
|
|
- */
|
|
|
- public Set<String> sunion(String... setKeys){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.sunion(setKeys);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 求差集，求几个集合之间的差集
|
|
|
- * @param setKeys 多个set的key
|
|
|
- * @return 差集
|
|
|
- */
|
|
|
- public Set<String> sdiff(String... setKeys){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.sdiff(setKeys);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /*######################## zset(有序集合)的操作 #######################*/
|
|
|
-
|
|
|
- /**
|
|
|
- * 添加一个元素到zset
|
|
|
- * @param key key
|
|
|
- * @param score 元素的分数
|
|
|
- * @param member 元素
|
|
|
- * @return 成功添加的元素个数
|
|
|
- */
|
|
|
- public Long zadd(String key,double score, String member){
|
|
|
- Jedis jedis = null;
|
|
|
- Long num = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- num = jedis.zadd(key,score,member);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return num;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 添加一个或多个元素到zset
|
|
|
- * @param key key
|
|
|
- * @param memberScores 元素和分数的map集合，map的k是元素，v是分数
|
|
|
- * @return 成功添加的元素个数
|
|
|
- */
|
|
|
- public Long zadd(String key,Map<String,Double> memberScores){
|
|
|
- Jedis jedis = null;
|
|
|
- Long num = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- num = jedis.zadd(key,memberScores);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return num;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 查询指定闭区间的元素（根据分数升序）
|
|
|
- * （0,-1表示全部）
|
|
|
- * @param key zset的key
|
|
|
- * @param start 开始区间
|
|
|
- * @param end 结束区间
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<String> zrange(String key, long start, long end){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> ascResult = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- ascResult = jedis.zrange(key,start,end);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return ascResult;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 查询指定闭区间的元素，带着分数
|
|
|
- * （0,-1表示全部）
|
|
|
- * @param key zset的key
|
|
|
- * @param start 开始区间
|
|
|
- * @param end 结束区间
|
|
|
- * @return 元素集合 格式为：
|
|
|
- * [{"element":"a","score":10.0,"binaryElement":"YQ=="},{"element":"b","score":20.0,"binaryElement":"Yg=="}]
|
|
|
- */
|
|
|
- public Set<Tuple> zrangeWithScores(String key, long start, long end){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<Tuple> ascResult = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- ascResult = jedis.zrangeWithScores(key,start,end);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return ascResult;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 查询指定索引闭区间的元素（根据分数降序）
|
|
|
- * （0,-1表示全部）
|
|
|
- * @param key zset的key
|
|
|
- * @param start 开始区间
|
|
|
- * @param end 结束区间
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<String> zrevrange(String key, long start, long end){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> descResult = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- descResult = jedis.zrevrange(key,start,end);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return descResult;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 查询指定索引闭区间的元素，带着分数（根据分数降序）
|
|
|
- * （0,-1表示全部）
|
|
|
- * @param key zset的key
|
|
|
- * @param start 开始区间
|
|
|
- * @param end 结束区间
|
|
|
- * @return 元素集合 格式为：
|
|
|
- * [{"element":"b","score":20.0,"binaryElement":"Yg=="},{"element":"a","score":10.0,"binaryElement":"YQ=="}]
|
|
|
- */
|
|
|
- public Set<Tuple> zrevrangeWithScores(String key, long start, long end){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<Tuple> descResult = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- descResult = jedis.zrevrangeWithScores(key,start,end);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return descResult;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回有序集合(zset)中的元素个数
|
|
|
- * @param key key
|
|
|
- * @return 个数
|
|
|
- */
|
|
|
- public Long zcard(String key){
|
|
|
- Jedis jedis = null;
|
|
|
- Long count = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- count = jedis.zcard(key);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return count;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回指定分数区间的元素个数（闭区间）
|
|
|
- * @param key key
|
|
|
- * @param startScore 开始分数
|
|
|
- * @param endScore 结束分数
|
|
|
- * @return 个数
|
|
|
- */
|
|
|
- public Long zcount(String key,Long startScore,Long endScore){
|
|
|
- Jedis jedis = null;
|
|
|
- Long count = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- count = jedis.zcount(key,startScore,endScore);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return count;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回某元素在集合中的排名（根据分数降序排列时）
|
|
|
- * @param key key
|
|
|
- * @param member 集合中的元素
|
|
|
- * @return 排名，从0开始
|
|
|
- */
|
|
|
- public Long zrevrank(String key, String member){
|
|
|
- Jedis jedis = null;
|
|
|
- Long count = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- count = jedis.zrevrank(key,member);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return count;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 返回某元素在集合中的排名（根据分数升序排列时）
|
|
|
- * @param key key
|
|
|
- * @param member 集合中的元素
|
|
|
- * @return 排名，从0开始
|
|
|
- */
|
|
|
- public Long zrank(String key, String member){
|
|
|
- Jedis jedis = null;
|
|
|
- Long count = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- count = jedis.zrank(key,member);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return count;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 升序查询指定分数闭区间的元素
|
|
|
- * @param key key
|
|
|
- * @param min 最小分数
|
|
|
- * @param max 最大分数
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<String> zrangeByScore(String key,double min, double max){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.zrangeByScore(key, min, max);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 升序查询指定分数闭区间的元素，并指定偏移量
|
|
|
- * @param key key
|
|
|
- * @param min 最小分数
|
|
|
- * @param max 最大分数
|
|
|
- * @param offset 偏移量
|
|
|
- * @param size 数量
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<String> zrangeByScore(String key,double min, double max,int offset,int size){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.zrangeByScore(key, min, max,offset,size);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 升序查询指定分数闭区间的元素，带着分数
|
|
|
- * @param key key
|
|
|
- * @param min 最小分数
|
|
|
- * @param max 最大分数
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<Tuple> zrangeByScoreWithScores(String key,double min, double max){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<Tuple> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.zrangeByScoreWithScores(key, min, max);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 升序查询指定分数闭区间的元素，并指定偏移量，带着分数
|
|
|
- * @param key key
|
|
|
- * @param min 最小分数
|
|
|
- * @param max 最大分数
|
|
|
- * @param offset 偏移量
|
|
|
- * @param size 数量
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<Tuple> zrangeByScoreWithScores(String key,double min, double max,int offset,int size){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<Tuple> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.zrangeByScoreWithScores(key, min, max,offset,size);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 降序查询指定分数闭区间的元素
|
|
|
- * @param key key
|
|
|
- * @param max 最大分数
|
|
|
- * @param min 最小分数
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<String> zrevrangebyscore(String key,double max,double min){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.zrevrangeByScore(key, max,min);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 降序查询指定分数闭区间的元素，并指定偏移量
|
|
|
- * @param key key
|
|
|
- * @param max 最大分数
|
|
|
- * @param min 最小分数
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<String> zrevrangebyscore(String key,double max,double min,int offset,int size){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<String> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.zrevrangeByScore(key, max,min,offset,size);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 降序查询指定分数闭区间的元素，并带着分数
|
|
|
- * @param key key
|
|
|
- * @param min 最小分数
|
|
|
- * @param max 最大分数
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<Tuple> zrevrangeByScoreWithScores(String key,double max,double min){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<Tuple> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.zrevrangeByScoreWithScores(key,max,min);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 降序查询指定分数闭区间的元素，并指定偏移量，带着分数
|
|
|
- * @param key key
|
|
|
- * @param min 最小分数
|
|
|
- * @param max 最大分数
|
|
|
- * @param offset 偏移量
|
|
|
- * @param size 数量
|
|
|
- * @return 元素集合
|
|
|
- */
|
|
|
- public Set<Tuple> zrevrangeByScoreWithScores(String key,double max,double min,int offset,int size){
|
|
|
- Jedis jedis = null;
|
|
|
- Set<Tuple> members = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- members = jedis.zrevrangeByScoreWithScores(key, min, max,offset,size);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return members;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 有序集合中指定删除一或多个元素
|
|
|
- * @param key
|
|
|
- * @param member 元素
|
|
|
- * @return 删除成功的个数
|
|
|
- */
|
|
|
- public Long zrem(String key, String... member){
|
|
|
- Jedis jedis = null;
|
|
|
- Long num = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- num = jedis.zrem(key,member);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return num;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 分数升序排名时，删除指定索引区间的元素
|
|
|
- * @param key key
|
|
|
- * @param start 开始索引
|
|
|
- * @param end 结束索引
|
|
|
- * @return 删除成功的个数
|
|
|
- */
|
|
|
- public Long zremrangebyrank(String key,long start,long end){
|
|
|
- Jedis jedis = null;
|
|
|
- Long num = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- num = jedis.zremrangeByRank(key,start,end);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return num;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 分数升序排名时，删除指定分数区间的元素
|
|
|
- * @param key key
|
|
|
- * @param min 最小分数
|
|
|
- * @param max 最大分数
|
|
|
- * @return 删除成功的个数
|
|
|
- */
|
|
|
- public Long zremrangeByScore(String key,long min,long max){
|
|
|
- Jedis jedis = null;
|
|
|
- Long num = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- num = jedis.zremrangeByScore(key,min,max);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return num;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 查询有序集合中某元素的分数
|
|
|
- * @param key key
|
|
|
- * @param member 元素
|
|
|
- * @return 删除成功的个数
|
|
|
- */
|
|
|
- public Double zscore(String key,String member){
|
|
|
- Jedis jedis = null;
|
|
|
- Double score = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- score = jedis.zscore(key,member);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return score;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 给有序集合中某元素的分数增加(正数)或减少(负数)
|
|
|
- * @param key key
|
|
|
- * @param score 分数
|
|
|
- * @param member 元素
|
|
|
- * @return 新的分数
|
|
|
- */
|
|
|
- public Double zincrby(String key,double score,String member){
|
|
|
- Jedis jedis = null;
|
|
|
- Double newScore = null;
|
|
|
- try {
|
|
|
- jedis = getJedis();
|
|
|
- newScore = jedis.zincrby(key,score,member);
|
|
|
- }finally {
|
|
|
- if (jedis != null){
|
|
|
- jedis.close();
|
|
|
- }
|
|
|
- }
|
|
|
- return newScore;
|
|
|
- }
|
|
|
- /**
|
|
|
- * 私有化构造器，不让实例化对象
|
|
|
- */
|
|
|
- private RedisUtils() {
|
|
|
+ /**
|
|
|
+ * 私有化构造器，不让实例化对象
|
|
|
+ */
|
|
|
+ private RedisUtils() {
|
|
|
+ }
|
|
|
+
|
|
|
+ /*######################## key的操作 ################################*/
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取jedis对象，并选择redis库。jedis默认是0号库，可传入1-16之间的数选择库存放数据
|
|
|
+ * 原则上使用一个redis库存放数据，通过特定的key的命令规则来区分不同的数据就行了。
|
|
|
+ *
|
|
|
+ * @param index redis库号。使用可变参数的目的就是该参数可传可不传。
|
|
|
+ * @return 返回jedis对象
|
|
|
+ */
|
|
|
+ public Jedis getJedis(int... index) {
|
|
|
+ Jedis jedis = jedisPool.getResource();
|
|
|
+ if (index != null && index.length > 0) {
|
|
|
+ if (index[0] > 0 && index[0] <= 16) {
|
|
|
+ jedis.select(index[0]);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return jedis;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据pattern返回当前库中的key
|
|
|
+ *
|
|
|
+ * @param pattern
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Set<String> keys(String pattern) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> keys;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ keys = jedis.keys(pattern);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return keys;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 删除一个或多个key
|
|
|
+ *
|
|
|
+ * @param key 一个或多个key
|
|
|
+ */
|
|
|
+ public Long del(String... key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long delNum;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ delNum = jedis.del(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return delNum;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 批量删除
|
|
|
+ *
|
|
|
+ * @param keyList 要删除的key的集合
|
|
|
+ */
|
|
|
+ public void mdel(List<String> keyList) {
|
|
|
+ Jedis jedis = getJedis();
|
|
|
+ //获取pipeline
|
|
|
+ Pipeline pipeline = jedis.pipelined();
|
|
|
+ for (String key : keyList) {
|
|
|
+ pipeline.del(key);
|
|
|
+ }
|
|
|
+ //执行结果同步，这样才能保证结果的正确性。实际上不执行该方法也执行了上面的命令，但是结果确不一定完全正确。
|
|
|
+ //注意
|
|
|
+ pipeline.sync();
|
|
|
+ //关闭连接
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 判断某个key是否还存在
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Boolean exists(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Boolean flag;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ flag = jedis.exists(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 设置某个key的过期时间，单位秒
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param seconds 过期时间秒
|
|
|
+ */
|
|
|
+ public void expire(String key, int seconds) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.expire(key, seconds);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查看某个key还有几秒过期，-1表示永不过期 ，-2表示已过期
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Long timeToLive(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long ttl;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ ttl = jedis.ttl(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return ttl;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /*######################## string(字符串)的操作 ####################*/
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查看某个key对应的value的类型
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public String type(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ String type;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ type = jedis.type(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return type;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取某个key的value，类型要对，只能value是string的才能获取
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public String get(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ String value;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ value = jedis.get(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return value;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 设置某个key的value
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param value
|
|
|
+ */
|
|
|
+ public void set(String key, String value) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.set(key, value);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 字符串后追加内容
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param appendContent 要追加的内容
|
|
|
+ */
|
|
|
+ public void append(String key, String appendContent) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.append(key, appendContent);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回key的value的长度
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Long strlen(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long strLen = 0L;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ strLen = jedis.strlen(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return strLen;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * value 加1 必
|
|
|
+ * 须是字符型数字
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return 增加后的值
|
|
|
+ */
|
|
|
+ public Long incr(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long incrResult = 0L;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ incrResult = jedis.incr(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return incrResult;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * value 减1 必须是字符型数字
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Long decr(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long decrResult = 0L;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ decrResult = jedis.decr(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return decrResult;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * value 加increment
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param increment 加几
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Long incrby(String key, int increment) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long incrByResult = 0L;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ incrByResult = jedis.incrBy(key, increment);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return incrByResult;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * value 减increment
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param increment
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Long decrby(String key, int increment) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long decrByResult = 0L;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ decrByResult = jedis.decrBy(key, increment);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return decrByResult;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /*######################## list(列表)的操作 #######################*/
|
|
|
+ //lpush rpush lpop rpop lrange lindex llen lset
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 给某个key设置过期时间和value，成功返回OK
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param seconds 过期时间秒
|
|
|
+ * @param value 设置的值
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public String setex(String key, int seconds, String value) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ String result = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ result = jedis.setex(key, seconds, value);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 从左边向列表中添加值
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param str 要添加的值
|
|
|
+ */
|
|
|
+ public void lpush(String key, String str) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.lpush(key, str);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 从右边向列表中添加值
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param str 要添加的值
|
|
|
+ */
|
|
|
+ public void rpush(String key, String str) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.rpush(key, str);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 从左边取出一个列表中的值
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public String lpop(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ String lpop;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ lpop = jedis.lpop(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return lpop;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 从右边取出一个列表中的值
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public String rpop(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ String rpop;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ rpop = jedis.rpop(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return rpop;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 取出列表中指定范围内的值，0 到 -1 表示全部
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param startIndex
|
|
|
+ * @param endIndex
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public List<String> lrange(String key, int startIndex, int endIndex) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ List<String> result;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ result = jedis.lrange(key, startIndex, endIndex);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回某列表指定索引位置的值
|
|
|
+ *
|
|
|
+ * @param key 列表key
|
|
|
+ * @param index 索引位置
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public String lindex(String key, int index) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ String lindex;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ lindex = jedis.lindex(key, index);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return lindex;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回某列表的长度
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Long llen(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long llen;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ llen = jedis.llen(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return llen;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 给某列表指定位置设置为指定的值
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param index
|
|
|
+ * @param str
|
|
|
+ */
|
|
|
+ public void lset(String key, Long index, String str) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.lset(key, index, str);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 对列表进行剪裁，保留指定闭区间的元素(索引位置也会重排)
|
|
|
+ *
|
|
|
+ * @param key 列表key
|
|
|
+ * @param startIndex 开始索引位置
|
|
|
+ * @param endIndex 结束索引位置
|
|
|
+ */
|
|
|
+ public void ltrim(String key, Integer startIndex, Integer endIndex) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.ltrim(key, startIndex, endIndex);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 从列表的左边阻塞弹出一个元素
|
|
|
+ *
|
|
|
+ * @param key 列表的key
|
|
|
+ * @param timeout 阻塞超时时间，0表示若没有元素就永久阻塞
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public List<String> blpop(String key, Integer timeout) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ List<String> valueList;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ valueList = jedis.blpop(timeout, key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return valueList;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /*######################## hash(哈希表)的操作 #######################*/
|
|
|
+ //hset hget hmset hmget hgetall hdel hkeys hvals hexists hincrby
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 从列表的右边阻塞弹出一个元素
|
|
|
+ *
|
|
|
+ * @param key 列表的key
|
|
|
+ * @param timeout 阻塞超时时间，0表示若没有元素就永久阻塞
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public List<String> brpop(String key, Integer timeout) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ List<String> valueList;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ valueList = jedis.brpop(timeout, key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return valueList;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 给某个hash表设置一个键值对
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param field
|
|
|
+ * @param value
|
|
|
+ */
|
|
|
+ public void hset(String key, String field, String value) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.hset(key, field, value);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 取出某个hash表中某个field对应的value
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param field field
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public String hget(String key, String field) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ String hget;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ hget = jedis.hget(key, field);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return hget;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 某个hash表设置一个或多个键值对
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param kvMap
|
|
|
+ */
|
|
|
+ public void hmset(String key, Map<String, String> kvMap) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.hmset(key, kvMap);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 取出某个hash表中任意多个key对应的value的集合
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param fields
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public List<String> hmget(String key, String... fields) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ List<String> hmget;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ hmget = jedis.hmget(key, fields);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return hmget;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 取出某个hash表中所有的键值对
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Map<String, String> hgetall(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Map<String, String> kvMap;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ kvMap = jedis.hgetAll(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return kvMap;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 判断某个hash表中的某个key是否存在
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param field
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Boolean hexists(String key, String field) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Boolean exists;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ exists = jedis.hexists(key, field);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return exists;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回某个hash表中所有的key
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Set<String> hkeys(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> keys;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ keys = jedis.hkeys(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return keys;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回某个hash表中所有的value
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public List<String> hvals(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ List<String> hvals;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ hvals = jedis.hvals(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return hvals;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 删除某个hash表中的一个或多个键值对
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param fields
|
|
|
+ */
|
|
|
+ public void hdel(String key, String... fields) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ jedis.hdel(key, fields);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /*######################## set(集合)的操作 ###########################*/
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 给某个hash表中的某个field的value增加多少
|
|
|
+ *
|
|
|
+ * @param key hash表的key
|
|
|
+ * @param field 表中的某个field
|
|
|
+ * @param increment 增加多少
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Long hincrby(String key, String field, Long increment) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long result;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ result = jedis.hincrBy(key, field, increment);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 往set集合中添加一个或多个元素
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param members 要添加的元素
|
|
|
+ * @return 添加成功的元素个数
|
|
|
+ */
|
|
|
+ public Long sadd(String key, String... members) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long num;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ num = jedis.sadd(key, members);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return num;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回set集合中的所有元素，顺序与加入时的顺序一致
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Set<String> smembers(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.smembers(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 判断集合中是否存在某个元素
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param member 某个元素
|
|
|
+ * @return true存在，false不存在
|
|
|
+ */
|
|
|
+ public Boolean sismember(String key, String member) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Boolean isMember;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ isMember = jedis.sismember(key, member);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return isMember;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回set集合的长度
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public Long scard(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long len;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ len = jedis.scard(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return len;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 删除set集合中指定的一个或多个元素
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param members 要删除的元素
|
|
|
+ * @return 删除成功的元素个数
|
|
|
+ */
|
|
|
+ public Long srem(String key, String... members) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long num;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ num = jedis.srem(key, members);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return num;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 将key1中的元素key1Member移动到key2中
|
|
|
+ *
|
|
|
+ * @param key1 来源集合key
|
|
|
+ * @param key2 目的地集合key
|
|
|
+ * @param key1Member key1中的元素
|
|
|
+ * @return 1成功，0失败
|
|
|
+ */
|
|
|
+ public Long smove(String key1, String key2, String key1Member) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long num;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ num = jedis.smove(key1, key2, key1Member);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return num;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 随机查询返回集合中的指定个数的元素（若count为负数，返回的元素可能会重复）
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param count 要查询返回的元素个数
|
|
|
+ * @return 元素list集合
|
|
|
+ */
|
|
|
+ public List<String> srandmember(String key, int count) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ List<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.srandmember(key, count);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 从set集合中随机弹出指定个数个元素
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param count 要弹出的个数
|
|
|
+ * @return 随机弹出的元素
|
|
|
+ */
|
|
|
+ public Set<String> spop(String key, int count) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.spop(key, count);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 求交集，返回多个set集合相交的部分
|
|
|
+ *
|
|
|
+ * @param setKeys 多个set集合的key
|
|
|
+ * @return 相交的元素集合
|
|
|
+ */
|
|
|
+ public Set<String> sinter(String... setKeys) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.sinter(setKeys);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 求并集，求几个set集合的并集（因为set中不会有重复的元素，合并后的集合也不会有重复的元素）
|
|
|
+ *
|
|
|
+ * @param setKeys 多个set的key
|
|
|
+ * @return 合并后的集合
|
|
|
+ */
|
|
|
+ public Set<String> sunion(String... setKeys) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.sunion(setKeys);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /*######################## zset(有序集合)的操作 #######################*/
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 求差集，求几个集合之间的差集
|
|
|
+ *
|
|
|
+ * @param setKeys 多个set的key
|
|
|
+ * @return 差集
|
|
|
+ */
|
|
|
+ public Set<String> sdiff(String... setKeys) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.sdiff(setKeys);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 添加一个元素到zset
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param score 元素的分数
|
|
|
+ * @param member 元素
|
|
|
+ * @return 成功添加的元素个数
|
|
|
+ */
|
|
|
+ public Long zadd(String key, double score, String member) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long num;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ num = jedis.zadd(key, score, member);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return num;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 添加一个或多个元素到zset
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param memberScores 元素和分数的map集合，map的k是元素，v是分数
|
|
|
+ * @return 成功添加的元素个数
|
|
|
+ */
|
|
|
+ public Long zadd(String key, Map<String, Double> memberScores) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long num;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ num = jedis.zadd(key, memberScores);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return num;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询指定闭区间的元素（根据分数升序）
|
|
|
+ * （0,-1表示全部）
|
|
|
+ *
|
|
|
+ * @param key zset的key
|
|
|
+ * @param start 开始区间
|
|
|
+ * @param end 结束区间
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<String> zrange(String key, long start, long end) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> ascResult;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ ascResult = jedis.zrange(key, start, end);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return ascResult;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询指定闭区间的元素，带着分数
|
|
|
+ * （0,-1表示全部）
|
|
|
+ *
|
|
|
+ * @param key zset的key
|
|
|
+ * @param start 开始区间
|
|
|
+ * @param end 结束区间
|
|
|
+ * @return 元素集合 格式为：
|
|
|
+ * [{"element":"a","score":10.0,"binaryElement":"YQ=="},{"element":"b","score":20.0,"binaryElement":"Yg=="}]
|
|
|
+ */
|
|
|
+ public Set<Tuple> zrangeWithScores(String key, long start, long end) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<Tuple> ascResult;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ ascResult = jedis.zrangeWithScores(key, start, end);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return ascResult;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询指定索引闭区间的元素（根据分数降序）
|
|
|
+ * （0,-1表示全部）
|
|
|
+ *
|
|
|
+ * @param key zset的key
|
|
|
+ * @param start 开始区间
|
|
|
+ * @param end 结束区间
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<String> zrevrange(String key, long start, long end) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> descResult;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ descResult = jedis.zrevrange(key, start, end);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return descResult;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询指定索引闭区间的元素，带着分数（根据分数降序）
|
|
|
+ * （0,-1表示全部）
|
|
|
+ *
|
|
|
+ * @param key zset的key
|
|
|
+ * @param start 开始区间
|
|
|
+ * @param end 结束区间
|
|
|
+ * @return 元素集合 格式为：
|
|
|
+ * [{"element":"b","score":20.0,"binaryElement":"Yg=="},{"element":"a","score":10.0,"binaryElement":"YQ=="}]
|
|
|
+ */
|
|
|
+ public Set<Tuple> zrevrangeWithScores(String key, long start, long end) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<Tuple> descResult;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ descResult = jedis.zrevrangeWithScores(key, start, end);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return descResult;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回有序集合(zset)中的元素个数
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @return 个数
|
|
|
+ */
|
|
|
+ public Long zcard(String key) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long count;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ count = jedis.zcard(key);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return count;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回指定分数区间的元素个数（闭区间）
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param startScore 开始分数
|
|
|
+ * @param endScore 结束分数
|
|
|
+ * @return 个数
|
|
|
+ */
|
|
|
+ public Long zcount(String key, Long startScore, Long endScore) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long count;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ count = jedis.zcount(key, startScore, endScore);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return count;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回某元素在集合中的排名（根据分数降序排列时）
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param member 集合中的元素
|
|
|
+ * @return 排名，从0开始
|
|
|
+ */
|
|
|
+ public Long zrevrank(String key, String member) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long count;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ count = jedis.zrevrank(key, member);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return count;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 返回某元素在集合中的排名（根据分数升序排列时）
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param member 集合中的元素
|
|
|
+ * @return 排名，从0开始
|
|
|
+ */
|
|
|
+ public Long zrank(String key, String member) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long count;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ count = jedis.zrank(key, member);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return count;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 升序查询指定分数闭区间的元素
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param min 最小分数
|
|
|
+ * @param max 最大分数
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<String> zrangeByScore(String key, double min, double max) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.zrangeByScore(key, min, max);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 升序查询指定分数闭区间的元素，并指定偏移量
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param min 最小分数
|
|
|
+ * @param max 最大分数
|
|
|
+ * @param offset 偏移量
|
|
|
+ * @param size 数量
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<String> zrangeByScore(String key, double min, double max, int offset, int size) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.zrangeByScore(key, min, max, offset, size);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 升序查询指定分数闭区间的元素，带着分数
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param min 最小分数
|
|
|
+ * @param max 最大分数
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<Tuple> zrangeByScoreWithScores(String key, double min, double max) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<Tuple> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.zrangeByScoreWithScores(key, min, max);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 升序查询指定分数闭区间的元素，并指定偏移量，带着分数
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param min 最小分数
|
|
|
+ * @param max 最大分数
|
|
|
+ * @param offset 偏移量
|
|
|
+ * @param size 数量
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<Tuple> zrangeByScoreWithScores(String key, double min, double max, int offset, int size) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<Tuple> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.zrangeByScoreWithScores(key, min, max, offset, size);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 降序查询指定分数闭区间的元素
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param max 最大分数
|
|
|
+ * @param min 最小分数
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<String> zrevrangebyscore(String key, double max, double min) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.zrevrangeByScore(key, max, min);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 降序查询指定分数闭区间的元素，并指定偏移量
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param max 最大分数
|
|
|
+ * @param min 最小分数
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<String> zrevrangebyscore(String key, double max, double min, int offset, int size) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<String> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.zrevrangeByScore(key, max, min, offset, size);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 降序查询指定分数闭区间的元素，并带着分数
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param min 最小分数
|
|
|
+ * @param max 最大分数
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<Tuple> zrevrangeByScoreWithScores(String key, double max, double min) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<Tuple> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.zrevrangeByScoreWithScores(key, max, min);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 降序查询指定分数闭区间的元素，并指定偏移量，带着分数
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param min 最小分数
|
|
|
+ * @param max 最大分数
|
|
|
+ * @param offset 偏移量
|
|
|
+ * @param size 数量
|
|
|
+ * @return 元素集合
|
|
|
+ */
|
|
|
+ public Set<Tuple> zrevrangeByScoreWithScores(String key, double max, double min, int offset, int size) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Set<Tuple> members;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ members = jedis.zrevrangeByScoreWithScores(key, min, max, offset, size);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return members;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 有序集合中指定删除一或多个元素
|
|
|
+ *
|
|
|
+ * @param key
|
|
|
+ * @param member 元素
|
|
|
+ * @return 删除成功的个数
|
|
|
+ */
|
|
|
+ public Long zrem(String key, String... member) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long num;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ num = jedis.zrem(key, member);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return num;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 分数升序排名时，删除指定索引区间的元素
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param start 开始索引
|
|
|
+ * @param end 结束索引
|
|
|
+ * @return 删除成功的个数
|
|
|
+ */
|
|
|
+ public Long zremrangebyrank(String key, long start, long end) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long num;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ num = jedis.zremrangeByRank(key, start, end);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return num;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 分数升序排名时，删除指定分数区间的元素
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param min 最小分数
|
|
|
+ * @param max 最大分数
|
|
|
+ * @return 删除成功的个数
|
|
|
+ */
|
|
|
+ public Long zremrangeByScore(String key, long min, long max) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Long num;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ num = jedis.zremrangeByScore(key, min, max);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return num;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询有序集合中某元素的分数
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param member 元素
|
|
|
+ * @return 删除成功的个数
|
|
|
+ */
|
|
|
+ public Double zscore(String key, String member) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Double score;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ score = jedis.zscore(key, member);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return score;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 给有序集合中某元素的分数增加(正数)或减少(负数)
|
|
|
+ *
|
|
|
+ * @param key key
|
|
|
+ * @param score 分数
|
|
|
+ * @param member 元素
|
|
|
+ * @return 新的分数
|
|
|
+ */
|
|
|
+ public Double zincrby(String key, double score, String member) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ Double newScore;
|
|
|
+ try {
|
|
|
+ jedis = getJedis();
|
|
|
+ newScore = jedis.zincrby(key, score, member);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) {
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
}
|
|
|
+ return newScore;
|
|
|
+ }
|
|
|
}
|
xusl