redis監(jiān)聽key過期事件的詳細(xì)步驟
1、配置redis.conf文件
配置文件默認(rèn)是#注釋了的,改為notify-keyspace-events Ex 重啟redis,記住指定redis.conf配置文件啟動
如果是阿里云的redis,進(jìn)入redis管理頁面==>>左邊導(dǎo)航欄的參數(shù)設(shè)置
2、 配置一個key過期事件的監(jiān)聽器
package com.shinedata.config.redis; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import redis.clients.jedis.JedisPubSub; /** * @ClassName RedisKeyExpiredListener 監(jiān)聽訂閱類 * @Author yupanpan * @Date 2020/4/17 13:44 */ public class RedisKeyExpiredListener extends JedisPubSub { /** * 日志 */ private static Logger logger = LoggerFactory.getLogger(RedisKeyExpiredListener.class); /** * * @Title: onMessage * @Description: 取得訂閱的消息后的處理 * @param channel * 頻道 * @param message * 消息內(nèi)容 * * @author * @date */ @Override public void onMessage(String channel, String message) { logger.info("channel{" + channel + "}message{" + message + "}"); } /** * * @Title: onPMessage * @Description: 取得按表達(dá)式的方式訂閱的消息后的處理 * * @author * @date */ @Override public void onPMessage(String pattern, String channel, String message) { logger.info("Redis訂閱監(jiān)聽超時通知開始pattern{" + pattern + "}channel{" + channel + "}message{" + message + "}"); long starTime = System.currentTimeMillis(); if (StringUtils.isBlank(message)) { logger.info("Redis訂閱監(jiān)聽超時通知,message為空"); return; } long endTime = System.currentTimeMillis(); logger.info("Redis訂閱監(jiān)聽超時通知完成pattern{" + pattern + "}channel{" + channel + "}message{" + message + "}共耗時{" + (endTime - starTime) / 1000 + "}秒"); } }
3、訂閱key過期事件
key過期時redis會自動把key推進(jìn)訂閱事件,配置上面自己的監(jiān)聽器,有key過期事件會通過onMessage方法進(jìn)入,處理自己的業(yè)務(wù)邏輯,刪除key不會通知
package com.shinedata.config.redis; import redis.clients.jedis.Jedis; /** * @ClassName Subscriber 訂閱是阻塞的,單獨開線程發(fā)起訂閱,訂閱過期key,索引庫1 * @Author yupanpan * @Date 2020/4/17 14:29 */ public class RedisKeyExpiredSubscriberRunnable implements Runnable{ @Override public void run() { Jedis jedis = JedisUtils.getJedis(); RedisKeyExpiredListener listener=new RedisKeyExpiredListener(); jedis.subscribe(listener,"__keyevent@1__:expired"); JedisUtils.returnResource(jedis); } }
索引庫根據(jù)自己業(yè)務(wù)需要選擇,__keyevent@1__:expired 1代表為訂閱索引庫1中的key過期,索引庫有0-15
如果不寫為全部索引庫,為 __keyevent@__:expired
4、發(fā)起訂閱
這里在程序應(yīng)用啟動時發(fā)起(使用Spring自帶的Runner,在服務(wù)啟動時會執(zhí)行相應(yīng)的run方法)
package com.shinedata.config.redis; import org.springframework.boot.CommandLineRunner; import org.springframework.stereotype.Component; /** * @ClassName RedisPublisherRunner 應(yīng)用啟用發(fā)起訂閱 * @Author yupanpan * @Date 2020/4/20 14:11 */ @Component public class RedisPublisherRunner implements CommandLineRunner { @Override public void run(String... args) throws Exception { new Thread(new RedisKeyExpiredSubscriberRunnable()).start(); } }
測試
package com.shinedata; import com.google.common.collect.Lists; import com.shinedata.config.redis.JedisUtils; import com.shinedata.enums.InstScaleEnum; import com.shinedata.enums.SchoolTypeEnum; import com.shinedata.enums.StatusEnum; import com.shinedata.enums.UserTypeEnum; import com.shinedata.order.UserInstOrder; import com.shinedata.order.UserOrder; import com.shinedata.service.order.OrderAsyncService; import com.shinedata.util.RetryUtils; import com.shinedata.util.list.ListUtils; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import com.shinedata.service.UserService; import com.shinedata.timer.HuifuBillTimer; import redis.clients.jedis.Jedis; import java.util.List; @RunWith(SpringJUnit4ClassRunner.class) @SpringBootTest(classes = Application.class )//這里是啟動類 public class HuiBillTest extends BaseTest { @Autowired UserService userService; @Autowired private HuifuBillTimer huifuBillTimer; @Autowired OrderAsyncService orderAsyncService; @Test public void sendHuifuBill() throws InterruptedException { Jedis jedis = JedisUtils.getJedis(); jedis.select(1); jedis.setex("ypp", 20, "ypp"); } }
結(jié)果:
其他配置redis和工具類,這里配置的默認(rèn)索引庫為0.如果操作其他索引庫,自行配置或者直接使用jedis.select(int database)
JedisConfig
package com.shinedata.config.redis; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; /** * @ClassName JedisConfig * @Author yupanpan * @Date 2019/10/10 16:46 */ @Component public class JedisConfig extends RedisProperties { private static final Logger logger = LoggerFactory.getLogger(JedisConfig.class); private static JedisPool jedisPool = null; private static void initialPool() { try { JedisPoolConfig config = new JedisPoolConfig(); //最大空閑連接數(shù), 應(yīng)用自己評估,不要超過ApsaraDB for Redis每個實例最大的連接數(shù) config.setMaxIdle(500); config.setMinIdle(100); //最大連接數(shù), 應(yīng)用自己評估,不要超過ApsaraDB for Redis每個實例最大的連接數(shù) config.setMaxTotal(6000); config.setMaxWaitMillis(5000); //每timeBetweenEvictionRunsMillis毫秒秒檢查一次連接池中空閑的連接,把空閑時間超過minEvictableIdleTimeMillis毫秒的連接斷開,直到連接池中的連接數(shù)到minIdle為止 config.setTimeBetweenEvictionRunsMillis(600); config.setMinEvictableIdleTimeMillis(100); config.setTestOnBorrow(true); config.setTestOnReturn(false); jedisPool = new JedisPool(config, redisHost, redisPort, 5000, redisPassword); } catch (Exception e) { if (jedisPool != null) { jedisPool.close(); } logger.error("初始化Redis連接池失敗", e); } } /** * 初始化Redis連接池 */ static { initialPool(); } /** * 在多線程環(huán)境同步初始化 */ private static synchronized void poolInit() { if (jedisPool == null) { initialPool(); } } /** * 同步獲取Jedis實例 * * @return Jedis */ public Jedis getJedis() { if (jedisPool == null) { poolInit(); } Jedis jedis = null; try { if (jedisPool != null) { jedis = jedisPool.getResource(); } } catch (Exception e) { logger.error("同步獲取Jedis實例失敗" + e.getMessage(), e); returnResource(jedis); } return jedis; } /** * 釋放jedis資源 * * @param jedis */ @SuppressWarnings("deprecation") public static void returnResource(final Jedis jedis) { if (jedis != null) { jedis.close(); } } }
JedisUtils
package com.shinedata.config.redis; import org.checkerframework.checker.units.qual.min; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import redis.clients.jedis.BinaryClient; import redis.clients.jedis.BitOP; import redis.clients.jedis.BitPosParams; import redis.clients.jedis.Jedis; import javax.annotation.PostConstruct; import java.util.List; import java.util.Map; import java.util.Set; /** * @ClassName JedisUtils * @Author yupanpan * @Date 2019/10/9 15:10 */ @Component public class JedisUtils { private static final Logger logger = LoggerFactory.getLogger(JedisUtils.class); @Autowired private JedisConfig jedisConfig; private static JedisUtils jedisUtils; @PostConstruct public void init() { jedisUtils = this; jedisUtils.jedisConfig = this.jedisConfig; } public static Jedis getJedis() { return jedisUtils.jedisConfig.getJedis(); } /** * 獲取指定key的值,如果key不存在返回null,如果該Key存儲的不是字符串,會拋出一個錯誤 * * @param key * @return */ public static String get(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.get(key); } finally { returnResource(jedis); } } public static byte[] get(byte[] key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.get(key); } finally { returnResource(jedis); } } /** * 設(shè)置key的值為value * * @param key * @param value * @return */ public static String set(String key, String value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.set(key, value); } finally { returnResource(jedis); } } public static String set(byte[] key, byte[] value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.set(key, value); } finally { returnResource(jedis); } } /** * 刪除指定的key,也可以傳入一個包含key的數(shù)組 * * @param keys * @return */ public static Long del(String... keys) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.del(keys); } finally { returnResource(jedis); } } /** * 通過key向指定的value值追加值 * * @param key * @param str * @return */ public static Long append(String key, String str) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.append(key, str); } finally { returnResource(jedis); } } /** * 判斷key是否存在 * * @param key * @return */ public static Boolean exists(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); Boolean exists; try { exists = jedis.exists(key); } finally { jedis.close(); } return exists; } /** * 設(shè)置key value,如果key已經(jīng)存在則返回0 * * @param key * @param value * @return */ public static Long setnx(String key, String value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.setnx(key, value); } finally { returnResource(jedis); } } /** * 設(shè)置key value并指定這個鍵值的有效期-秒 * * @param key * @param seconds * @param value * @return */ public static String setex(String key, String value, int seconds) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); String setex; try { setex = jedis.setex(key, seconds, value); } finally { jedis.close(); } return setex; } public static String setex(byte[] key, byte[] value, int seconds) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); String setex; try { setex = jedis.setex(key, seconds, value); } finally { jedis.close(); } return setex; } /** * 通過key 和offset 從指定的位置開始將原先value替換 * * @param key * @param offset * @param str * @return */ public static Long setrange(String key, int offset, String str) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); Long setrange; try { setrange = jedis.setrange(key, offset, str); } finally { jedis.close(); } return setrange; } /** * 通過批量的key獲取批量的value * * @param keys * @return */ public static List<String> mget(String... keys) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.mget(keys); } finally { returnResource(jedis); } } /** * 批量的設(shè)置key:value,也可以一個 * * @param keysValues * @return */ public static String mset(String... keysValues) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.mset(keysValues); } finally { returnResource(jedis); } } /** * 批量的設(shè)置key:value,可以一個,如果key已經(jīng)存在則會失敗,操作會回滾 * * @param keysValues * @return */ public static Long msetnx(String... keysValues) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.msetnx(keysValues); } finally { returnResource(jedis); } } /** * 設(shè)置key的值,并返回一個舊值 * * @param key * @param value * @return */ public static String getSet(String key, String value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.getSet(key, value); } finally { returnResource(jedis); } } /** * 通過下標(biāo) 和key 獲取指定下標(biāo)位置的 value * * @param key * @param startOffset * @param endOffset * @return */ public static String getrange(String key, int startOffset, int endOffset) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.getrange(key, startOffset, endOffset); } finally { returnResource(jedis); } } /** * 通過key 對value進(jìn)行加值+1操作,當(dāng)value不是int類型時會返回錯誤,當(dāng)key不存在是則value為1 * * @param key * @return */ public static Long incr(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.incr(key); } finally { returnResource(jedis); } } /** * 通過key給指定的value加值,如果key不存在,則這是value為該值 * * @param key * @param integer * @return */ public static Long incrBy(String key, long integer) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.incrBy(key, integer); } finally { returnResource(jedis); } } /** * 對key的值做減減操作,如果key不存在,則設(shè)置key為-1 * * @param key * @return */ public static Long decr(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.decr(key); } finally { returnResource(jedis); } } /** * 減去指定的值 * * @param key * @param integer * @return */ public static Long decrBy(String key, long integer) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.decrBy(key, integer); } finally { returnResource(jedis); } } /** * 通過key獲取value值的長度 * * @param key * @return */ public static Long strLen(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.strlen(key); } finally { returnResource(jedis); } } /** * 通過key給field設(shè)置指定的值,如果key不存在則先創(chuàng)建,如果field已經(jīng)存在,返回0 * * @param key * @param field * @param value * @return */ public static Long hsetnx(String key, String field, String value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hsetnx(key, field, value); } finally { returnResource(jedis); } } /** * 通過key給field設(shè)置指定的值,如果key不存在,則先創(chuàng)建 * * @param key * @param field * @param value * @return */ public static Long hset(String key, String field, String value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hset(key, field, value); } finally { returnResource(jedis); } } /** * 通過key同時設(shè)置 hash的多個field * * @param key * @param hash * @return */ public static String hmset(String key, Map<String, String> hash) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hmset(key, hash); } finally { returnResource(jedis); } } /** * 通過key 和 field 獲取指定的 value * * @param key * @param failed * @return */ public static String hget(String key, String failed) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hget(key, failed); } finally { returnResource(jedis); } } /** * 設(shè)置key的超時時間為seconds * * @param key * @param seconds * @return */ public static Long expire(String key, int seconds) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.expire(key, seconds); } finally { returnResource(jedis); } } /** * 通過key 和 fields 獲取指定的value 如果沒有對應(yīng)的value則返回null * * @param key * @param fields 可以是 一個String 也可以是 String數(shù)組 * @return */ public static List<String> hmget(String key, String... fields) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hmget(key, fields); } finally { returnResource(jedis); } } /** * 通過key給指定的field的value加上給定的值 * * @param key * @param field * @param value * @return */ public static Long hincrby(String key, String field, Long value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hincrBy(key, field, value); } finally { returnResource(jedis); } } /** * 通過key和field判斷是否有指定的value存在 * * @param key * @param field * @return */ public static Boolean hexists(String key, String field) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hexists(key, field); } finally { returnResource(jedis); } } /** * 通過key返回field的數(shù)量 * * @param key * @return */ public static Long hlen(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hlen(key); } finally { returnResource(jedis); } } /** * 通過key 刪除指定的 field * * @param key * @param fields 可以是 一個 field * 也可以是 一個數(shù)組 * @return */ public static Long hdel(String key, String... fields) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hdel(key , fields); } finally { returnResource(jedis); } } /** * 通過key返回所有的field * * @param key * @return */ public static Set<String> hkeys(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hkeys(key); } finally { returnResource(jedis); } } /** * 通過key返回所有和key有關(guān)的value * * @param key * @return */ public static List<String> hvals(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hvals(key); } finally { returnResource(jedis); } } /** * 通過key獲取所有的field和value * * @param key * @return */ public static Map<String, String> hgetall(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.hgetAll(key); } finally { returnResource(jedis); } } /** * 通過key向list頭部添加字符串 * * @param key * @param strs 可以是一個string 也可以是string數(shù)組 * @return 返回list的value個數(shù) */ public static Long lpush(String key, String... strs) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.lpush(key, strs); } finally { returnResource(jedis); } } /** * 通過key向list尾部添加字符串 * * @param key * @param strs 可以是一個string 也可以是string數(shù)組 * @return 返回list的value個數(shù) */ public static Long rpush(String key, String... strs) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.rpush(key, strs); } finally { returnResource(jedis); } } /** * 通過key在list指定的位置之前或者之后 添加字符串元素 * * @param key * @param where LIST_POSITION枚舉類型 * @param pivot list里面的value * @param value 添加的value * @return */ public static Long linsert(String key, BinaryClient.LIST_POSITION where, String pivot, String value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.linsert(key, where, pivot, value); } finally { returnResource(jedis); } } /** * 通過key設(shè)置list指定下標(biāo)位置的value * 如果下標(biāo)超過list里面value的個數(shù)則報錯 * * @param key * @param index 從0開始 * @param value * @return 成功返回OK */ public static String lset(String key, Long index, String value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.lset(key, index, value); } finally { returnResource(jedis); } } /** * 通過key從對應(yīng)的list中刪除指定的count個 和 value相同的元素 * * @param key * @param count 當(dāng)count為0時刪除全部 * @param value * @return 返回被刪除的個數(shù) */ public static Long lrem(String key, long count, String value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.lrem(key, count, value); } finally { returnResource(jedis); } } /** * 通過key保留list中從strat下標(biāo)開始到end下標(biāo)結(jié)束的value值 * * @param key * @param start * @param end * @return 成功返回OK */ public static String ltrim(String key, long start, long end) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.ltrim(key, start, end); } finally { returnResource(jedis); } } /** * 通過key從list的頭部刪除一個value,并返回該value * * @param key * @return */ public static String lpop(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.lpop(key); } finally { returnResource(jedis); } } /** * 通過key從list尾部刪除一個value,并返回該元素 * * @param key * @return */ public static String rpop(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.rpop(key); } finally { returnResource(jedis); } } /** * 通過key從一個list的尾部刪除一個value并添加到另一個list的頭部,并返回該value * 如果第一個list為空或者不存在則返回null * * @param srckey * @param dstkey * @return */ public static String rpoplpush(String srckey, String dstkey) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.rpoplpush(srckey, dstkey); } finally { returnResource(jedis); } } /** * 通過key獲取list中指定下標(biāo)位置的value * * @param key * @param index * @return 如果沒有返回null */ public static String lindex(String key, long index) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.lindex(key, index); } finally { returnResource(jedis); } } /** * 通過key返回list的長度 * * @param key * @return */ public static Long llen(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.llen(key); } finally { returnResource(jedis); } } /** * 通過key獲取list指定下標(biāo)位置的value * 如果start 為 0 end 為 -1 則返回全部的list中的value * * @param key * @param start * @param end * @return */ public static List<String> lrange(String key, long start, long end) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.lrange(key, start, end); } finally { returnResource(jedis); } } /** * 通過key向指定的set中添加value * * @param key * @param members 可以是一個String 也可以是一個String數(shù)組 * @return 添加成功的個數(shù) */ public static Long sadd(String key, String... members) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.sadd(key, members); } finally { returnResource(jedis); } } /** * 通過key刪除set中對應(yīng)的value值 * * @param key * @param members 可以是一個String 也可以是一個String數(shù)組 * @return 刪除的個數(shù) */ public static Long srem(String key, String... members) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.srem(key, members); } finally { returnResource(jedis); } } /** * 通過key隨機(jī)刪除一個set中的value并返回該值 * * @param key * @return */ public static String spop(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.spop(key); } finally { returnResource(jedis); } } /** * 通過key獲取set中的差集 * 以第一個set為標(biāo)準(zhǔn) * * @param keys 可以 是一個string 則返回set中所有的value 也可以是string數(shù)組 * @return */ public static Set<String> sdiff(String... keys) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.sdiff(keys); } finally { returnResource(jedis); } } /** * 通過key獲取set中的差集并存入到另一個key中 * 以第一個set為標(biāo)準(zhǔn) * * @param dstkey 差集存入的key * @param keys 可以 是一個string 則返回set中所有的value 也可以是string數(shù)組 * @return */ public static Long sdiffstore(String dstkey, String... keys) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.sdiffstore(dstkey, keys); } finally { returnResource(jedis); } } /** * 通過key獲取指定set中的交集 * * @param keys 可以 是一個string 也可以是一個string數(shù)組 * @return */ public static Set<String> sinter(String... keys) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.sinter(keys); } finally { returnResource(jedis); } } /** * 通過key獲取指定set中的交集 并將結(jié)果存入新的set中 * * @param dstkey * @param keys 可以 是一個string 也可以是一個string數(shù)組 * @return */ public static Long sinterstore(String dstkey, String... keys) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.sinterstore(dstkey, keys); } finally { returnResource(jedis); } } /** * 通過key返回所有set的并集 * * @param keys 可以 是一個string 也可以是一個string數(shù)組 * @return */ public static Set<String> sunion(String... keys) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.sunion(keys); } finally { returnResource(jedis); } } /** * 通過key返回所有set的并集,并存入到新的set中 * * @param dstkey * @param keys 可以 是一個string 也可以是一個string數(shù)組 * @return */ public static Long sunionstore(String dstkey, String... keys) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.sunionstore(dstkey, keys); } finally { returnResource(jedis); } } /** * 通過key將set中的value移除并添加到第二個set中 * * @param srckey 需要移除的 * @param dstkey 添加的 * @param member set中的value * @return */ public static Long smove(String srckey, String dstkey, String member) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.smove(srckey, dstkey, member); } finally { returnResource(jedis); } } /** * 通過key獲取set中value的個數(shù) * * @param key * @return */ public static Long scard(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.scard(key); } finally { returnResource(jedis); } } /** * 通過key判斷value是否是set中的元素 * * @param key * @param member * @return */ public static Boolean sismember(String key, String member) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.sismember(key, member); } finally { returnResource(jedis); } } /** * 通過key獲取set中隨機(jī)的value,不刪除元素 * * @param key * @return */ public static String srandmember(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.srandmember(key); } finally { returnResource(jedis); } } /** * 通過key獲取set中所有的value * * @param key * @return */ public static Set<String> smembers(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.smembers(key); } finally { returnResource(jedis); } } /** * 通過key向zset中添加value,score,其中score就是用來排序的 * 如果該value已經(jīng)存在則根據(jù)score更新元素 * * @param key * @param score * @param member * @return */ public static Long zadd(String key, double score, String member) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zadd(key, score, member); } finally { returnResource(jedis); } } /** * 通過key刪除在zset中指定的value * * @param key * @param members 可以 是一個string 也可以是一個string數(shù)組 * @return */ public static Long zrem(String key, String... members) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zrem(key, members); } finally { returnResource(jedis); } } /** * 通過key增加該zset中value的score的值 * * @param key * @param score * @param member * @return */ public static Double zincrby(String key, double score, String member) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zincrby(key, score, member); } finally { returnResource(jedis); } } /** * 通過key返回zset中value的排名 * 下標(biāo)從小到大排序 * * @param key * @param member * @return */ public static Long zrank(String key, String member) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zrank(key, member); } finally { returnResource(jedis); } } /** * 通過key返回zset中value的排名 * 下標(biāo)從大到小排序 * * @param key * @param member * @return */ public static Long zrevrank(String key, String member) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zrevrank(key, member); } finally { returnResource(jedis); } } /** * 通過key將獲取score從start到end中zset的value * socre從大到小排序 * 當(dāng)start為0 end為-1時返回全部 * * @param key * @param start * @param end * @return */ public static Set<String> zrevrange(String key, long start, long end) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zrevrange(key, start, end); } finally { returnResource(jedis); } } /** * 通過key返回指定score內(nèi)zset中的value * * @param key * @param max * @param min * @return */ public static Set<String> zrangebyscore(String key, String max, String min) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zrevrangeByScore(key, max, min); } finally { returnResource(jedis); } } /** * 通過key返回指定score內(nèi)zset中的value * * @param key * @param max * @param min * @return */ public static Set<String> zrangeByScore(String key, double max, double min) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zrevrangeByScore(key, max, min); } finally { returnResource(jedis); } } /** * 返回指定區(qū)間內(nèi)zset中value的數(shù)量 * * @param key * @param min * @param max * @return */ public static Long zcount(String key, String min, String max) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zcount(key, min, max); } finally { returnResource(jedis); } } /** * 通過key返回zset中的value個數(shù) * * @param key * @return */ public static Long zcard(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zcard(key); } finally { returnResource(jedis); } } /** * 通過key獲取zset中value的score值 * * @param key * @param member * @return */ public static Double zscore(String key, String member) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zscore(key, member); } finally { returnResource(jedis); } } /** * 通過key刪除給定區(qū)間內(nèi)的元素 * * @param key * @param start * @param end * @return */ public static Long zremrangeByRank(String key, long start, long end) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zremrangeByRank(key, start, end); } finally { returnResource(jedis); } } /** * 通過key刪除指定score內(nèi)的元素 * * @param key * @param start * @param end * @return */ public static Long zremrangeByScore(String key, double start, double end) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.zremrangeByScore(key, start, end); } finally { returnResource(jedis); } } /** * 返回滿足pattern表達(dá)式的所有key * keys(*) 盡量不要用此方法,數(shù)據(jù)量太多會導(dǎo)致線程阻塞,匹配可控制范圍數(shù)據(jù)量小情況下可以使用 * 返回所有的key * * @param pattern * @return */ @Deprecated public static Set<String> keys(String pattern) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.keys(pattern); } finally { returnResource(jedis); } } /** * 通過key判斷值得類型 * * @param key * @return */ public static String type(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.type(key); } finally { returnResource(jedis); } } /**bit map*/ /** * 設(shè)置key指定偏移量的值 * @author yupanpan * @date 2019/11/15 11:09 * @param key * @param offset * @param value * @return java.lang.Boolean */ public static Boolean setbit(String key, long offset, boolean value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.setbit(key,offset,value); } finally { returnResource(jedis); } } /** * 設(shè)置key指定偏移量的值 * @author yupanpan * @date 2019/11/15 11:09 * @param key * @param offset * @param value 只能是1或0字符串 * @return java.lang.Boolean */ public static Boolean setbit(String key, long offset, String value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.setbit(key,offset,value); } finally { returnResource(jedis); } } /** * 獲取key指定偏移量的值 * @author yupanpan * @date 2019/11/15 11:09 * @param key * @param offset * @return java.lang.Boolean */ public static Boolean getbit(String key, long offset) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.getbit(key,offset); } finally { returnResource(jedis); } } /** * 統(tǒng)計key 偏移量被設(shè)置為1的bit數(shù). * @author yupanpan * @date 2019/11/15 11:09 * @param key * @return java.lang.Boolean */ public static Long bitcount(String key) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.bitcount(key); } finally { returnResource(jedis); } } /** * 一般情況下,給定的整個字符串都會被進(jìn)行計數(shù),通過指定額外的 start 或 end 參數(shù),可以讓計數(shù)只在特定的位上進(jìn)行。 * start 和 end 參數(shù)的設(shè)置和 GETRANGE 命令類似,都可以使用負(fù)數(shù)值:比如 -1 表示最后一個位,而 -2 表示倒數(shù)第二個位,以此類推。 * 不存在的 key 被當(dāng)成是空字符串來處理,因此對一個不存在的 key 進(jìn)行 BITCOUNT 操作,結(jié)果為 0 。 * @author yupanpan * @date 2019/11/15 11:12 * @param key * @param start * @param end * @return java.lang.Long */ public static Long bitcount(String key, long start, long end) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.bitcount(key, start, end); } finally { returnResource(jedis); } } /** * 對一個或多個保存二進(jìn)制位的字符串 key 進(jìn)行位元操作,并將結(jié)果保存到 destkey 上,時間復(fù)雜度:O(N),盡量少用 * 支持 AND 、 OR 、 NOT 、 XOR 這四種操作中的任意一種參數(shù)--BitOP * @author yupanpan * @date 2019/11/15 11:14 * @param op * @param destKey * @param srcKeys * @return java.lang.Long */ public static Long bitop(BitOP op, String destKey, String... srcKeys) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.bitop(op, destKey, srcKeys); } finally { returnResource(jedis); } } /** * 返回字符串里面第一個被設(shè)置為value的bit位/偏移量 * @author yupanpan * @date 2019/11/15 11:18 * @param key * @param value true在redis bitmap二進(jìn)制字符串代表為1 false為0 * @return java.lang.Long */ public static Long bitpos(String key, boolean value) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.bitpos(key,value); } finally { returnResource(jedis); } } public static Long bitpos(String key, boolean value, BitPosParams params) { Jedis jedis = jedisUtils.jedisConfig.getJedis(); try { return jedis.bitpos(key,value,params); } finally { returnResource(jedis); } } /** * 釋放jedis資源 * * @param jedis */ @SuppressWarnings("deprecation") public static void returnResource(final Jedis jedis) { if (jedis != null) { jedis.close(); } } }
代碼復(fù)制粘貼可用,需要修改為自己的redis鏈接信息
到此這篇關(guān)于redis監(jiān)聽key過期事件的詳細(xì)步驟的文章就介紹到這了,更多相關(guān)redis監(jiān)聽key過期事件內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Redis數(shù)據(jù)類型string和Hash詳解
大家都知道Redis中有五大數(shù)據(jù)類型分別是String、List、Set、Hash和Zset,本文給大家分享Redis數(shù)據(jù)類型string和Hash的相關(guān)操作,感興趣的朋友跟隨小編一起看看吧2022-03-03redis使用不當(dāng)導(dǎo)致應(yīng)用卡死bug的過程解析
本文主要記一次找因redis使用不當(dāng)導(dǎo)致應(yīng)用卡死bug的過程,文中通過示例代碼介紹的非常詳細(xì),需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-07-07