当前位置:网站首页>【redis】redis之过期监听
【redis】redis之过期监听
2022-08-09 08:00:00 【Ctrl练习生-谢哥哥blog】
redis之过期监听
使用场景:在我们项目中,需要把支付超时的订单,更新状态并回退库存等操作。在这里,使用redis过期监听就能做到
↓↓↓下面上代码↓↓↓
首先需要redis监听生效就需要配置如下代码
yml文件
RedisListenerConfig.java
@Slf4j
@Configuration
public class RedisListenerConfig {
@Bean
public RedisMessageListenerContainer container(RedisConnectionFactory redisConnectionFactory) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(redisConnectionFactory);
log.info("redis监听配置生效");
return container;
}
}
使用
RedisKeyExpirationListener.java
@Slf4j
@Configuration
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
@Value("${spring.redis.database}")
private Integer redisDatabase;
private final RedisTemplate<String, String> redisTemplate;
public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer, RedisTemplate<String, String> redisTemplate) {
super(listenerContainer);
this.redisTemplate = redisTemplate;
}
@Override
public void onMessage(Message message, byte[] bytes) {
log.info("过期监听事件启动");
RedisSerializer<?> serializer = redisTemplate.getValueSerializer();
String channel = String.valueOf(serializer.deserialize(message.getChannel()));
// 获取过期的Key值
String body = String.valueOf(serializer.deserialize(message.getBody()));
// DB0 key过期监听
if (StrUtil.format("[email protected]{}__:expired", redisDatabase).equals(channel)) {
System.out.println("第" + redisDatabase + "个DB库的key过期,key:" + body);
}
}
}
我们测试一下
等待30秒…
结果如下
总结
如果觉得不错,可以点赞+收藏或者关注下博主。感谢阅读!
边栏推荐
猜你喜欢
随机推荐
磁盘管理与挂载
MySql作业练习题
JS基础1
204. 数素数
MDK Keil debug时, watch1中全局变量不更新
编程洗衣机:字符串输出后的乱码
The Servlet,
CUDA和cuDNN 安装10.0版本
App testing
测试和开发之间的恩恩怨怨
(二)、灰色预测模型(GM1,1)
Collection 接口 & List 接口
ssh:connect to host master port 22:Network is unreachable
Cookie and Session Details
Different styles of Flask-restful
MySQL数据库
Exclude null values when Oracle limits
.net(五) 业务层实现
The story of the disappearing WLAN of Windows 10 computers
Selenium测试案例一步步学之(2)Selenium自动测试脚本模块化(下)