redis监听key过期事件的详细步骤_Redis_

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 监听订阅类 * @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 * 消息内容 * * @author * @date */ @Override public void onMessage(String channel, String message) { logger.info("channel{" + channel + "}message{" + message + "}"); } /** * * @Title: onPMessage * @Description: 取得按表达式的方式订阅的消息后的处理 * * @author * @date */ @Override public void onPMessage(String pattern, String channel, String message) { logger.info("Redis订阅监听超时通知开始pattern{" + pattern + "}channel{" + channel + "}message{" + message + "}"); long starTime = System.currentTimeMillis(); if (StringUtils.isBlank(message)) { logger.info("Redis订阅监听超时通知，message为空"); return; } long endTime = System.currentTimeMillis(); logger.info("Redis订阅监听超时通知完成pattern{" + pattern + "}channel{" + channel + "}message{" + message + "}共耗时{" + (endTime - starTime) / 1000 + "}秒"); } }

package com.shinedata.config.redis; import redis.clients.jedis.Jedis; /** * @ClassName Subscriber 订阅是阻塞的，单独开线程发起订阅,订阅过期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); } }

package com.shinedata.config.redis; import org.springframework.boot.CommandLineRunner; import org.springframework.stereotype.Component; /** * @ClassName RedisPublisherRunner 应用启用发起订阅 * @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"); } }

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(); //最大空闲连接数, 应用自己评估，不要超过ApsaraDB for Redis每个实例最大的连接数 config.setMaxIdle(500); config.setMinIdle(100); //最大连接数, 应用自己评估，不要超过ApsaraDB for Redis每个实例最大的连接数 config.setMaxTotal(6000); config.setMaxWaitMillis(5000); //每timeBetweenEvictionRunsMillis毫秒秒检查一次连接池中空闲的连接,把空闲时间超过minEvictableIdleTimeMillis毫秒的连接断开,直到连接池中的连接数到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(); } /** * 在多线程环境同步初始化 */ 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(); } } }

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); } } /** * 设置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的数组 * * @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; } /** * 设置key value,如果key已经存在则返回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); } } /** * 设置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.
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：Redis位图bitmap操作_Redis_
                                                                
下一篇：Redis中键和数据库通用指令详解_Redis_