企业网站推广公司 知乎,网络营销都具有哪些功能,有没有人一起做网站,网站建设软件设施用Redis实现延迟队列#xff0c;我研究了两种方案#xff0c;发现并不简单
SpringBoot实现Redis失效监听事件—KeyExpirationEventMessageListener
Redis 监听过期的key#xff08;KeyExpirationEventMessageListener#xff09; 项目背景
需求上说#xff0c;需要延迟…用Redis实现延迟队列我研究了两种方案发现并不简单
SpringBoot实现Redis失效监听事件—KeyExpirationEventMessageListener
Redis 监听过期的keyKeyExpirationEventMessageListener 项目背景
需求上说需要延迟半小时才能更新数据状态。问过架构说项目暂不支持rocketmq。评估过kafka可惜支持度不够如果要实现也会相当复杂。
最终考量使用 redission 通过监听键失效事件实现延时更新状态效果
技术落地
引入pom
dependencygroupIdorg.redisson/groupIdartifactIdredisson/artifactIdversionx/version
/dependency配置类
Configuration
public class RedisConfig {Beanpublic RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory) {RedisMessageListenerContainer container new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);return container;}Beanpublic KeyExpirationEventMessageListener redisKeyExpirationListener(RedisMessageListenerContainer redisMessageListenerContainer){return new KeyExpirationEventMessageListener(redisMessageListenerContainer);}
}redis保存设置了过期时间的key
Autowired
private RedissonClient redissonClient;public void setExpiredKey(){//添加分布式锁避免重复设置相同keyRLock lock redissonClient.getLock(lockKey);if (lock.tryLock(5, 5, TimeUnit.SECONDS)) {if (!redissonClient.getBucket(key).isExists()) {//业务处理redissonClient.getBucket(key).set(Constants.SHORTAGE_ORDER_BUCKET, 30, TimeUnit.MINUTES);}}
}失效监听器listener
Component
public class MyListener extends KeyExpirationEventMessageListener {Overridepublic void onMessage(Message message, byte[] pattern) {//业务处理调用相关方法对失效的key进行相关处理}
}但注意这里会监听所有失效的key所以需进行相关过滤
其实就是底层原理就是 订阅-发布模式
