1 Star 30 Fork 23

贾又飞/spring-boot-redis-case

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
RedisUtils.java 37.55 KB
一键复制 编辑 原始数据 按行查看 历史
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524
package com.jyf.redis.common.utils;
import com.jyf.redis.common.config.MyJedisPoolConfig;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.Pipeline;
import redis.clients.jedis.Tuple;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 基于jedis的redis操作工具类
* @author Mr.贾
* @time 2019/8/3 22:30
*/
public final class RedisUtils {
/*
除了该工具类提供的方法外,还可以在外面调用getJedis()方法,获取到jedis实例后,调用它原生的api来操作
*/
/**
* 获取jedis对象,并选择redis库。jedis默认是0号库,可传入1-16之间的数选择库存放数据
* 原则上使用一个redis库存放数据,通过特定的key的命令规则来区分不同的数据就行了。
*
* @param index redis库号。使用可变参数的目的就是该参数可传可不传。
* @return 返回jedis对象
*/
public static Jedis getJedis(int... index) {
Jedis jedis = MyJedisPoolConfig.getJedisPool().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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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 static 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() {
}
public static void main(String[] args) {
JedisPool jedisPool = MyJedisPoolConfig.getJedisPool();
JedisPool jedisPool1 = MyJedisPoolConfig.getJedisPool();
System.out.println(jedisPool == jedisPool1);//true
}
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Java
1
https://gitee.com/JYFlyer/spring-boot-redis-case.git
git@gitee.com:JYFlyer/spring-boot-redis-case.git
JYFlyer
spring-boot-redis-case
spring-boot-redis-case
master

搜索帮助