springboot listener_Springboot 监听redis key的过期事件
项目中常常会碰到这样的需求,用户下订单后,30分钟未完成自动取消订单的功能。
有人说这个简单呀,写个定时任务就搞定了。除了定时任务之外,难道就没有其他的方法来实现吗?有--Redis 的键空间通知事件。
在Redis 2.8.0之后提供Keyspace Notifications功能,当我们将<key,value>键值对使用Redis缓存并设置缓存失效时间的时候,会触发Redis的键事件通知,客户端订阅这个通知,服务端将会把对应的通知事件发送给客户端,客户端收到通知,然后根据自己的不同业务进行处理。要注意的是因为Redis的发布订阅模式采用的是发送即忘的策略,当订阅的客户端断线时,会丢失所有在断线期间发送给他的事件通知。当你的程序需要一个可靠的事件通知时,Redis的键空间通知就不适合了。
事件类型
键空间通知都会发送两种不同类型的事件消息:keyspace 和 keyevent。以 keyspace 为前缀的频道被称为键空间通知(key-space notification), 而以 keyevent 为前缀的频道则被称为键事件通知(key-event notification)。
开启配置
修改Redis的redis.conf
# notify-keyspace-events Ex
# By default all notifications are disabled because most users don't need
# this feature and the feature has some overhead. Note that if you don't
# specify at least one of K or E, no events will be delivered.
notify-keyspace-events "Ex"
键空间通知通常是不启用的,因为这个过程会产生额外消耗。所以在使用该特性之前,请确认一定是要用这个特性的,然后修改配置文件
# K 键空间通知,以__keyspace@<db>__为前缀
# E 键事件通知,以__keysevent@<db>__为前缀
# g del , expipre , rename 等类型无关的通用命令的通知, ...
# $ String命令
# l List命令
# s Set命令
# h Hash命令
# z 有序集合命令
# x 过期事件(每次key过期时生成)
# e 驱逐事件(当key在内存满了被清除时生成)
# A g$lshzxe的别名,因此”AKE”意味着所有的事件
springboot 中的处理方式
添加Redis 消息监听的配置
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;/*** @ClassName RedisListenerConfig* @Description* @Author ZhaoDeLin* @Date 2019/9/16 15:15* @Email: casablanca523@163.com**/
@Configuration
public class RedisListenerConfig {@BeanRedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);return container;}
}
添加Redis key过期事件的监听
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;/*** @ClassName RedisKeyExpirationListener* @Description 监听redis的过期事件* @Author ZhaoDeLin* @Date 2019/9/16 15:18* @Email: casablanca523@163.com**/
@Component
@Slf4j
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {super(listenerContainer);}public void onMessage(Message message, byte[] pattern){String expiredKey = message.toString();log.info("redis key过期:{}",expiredKey);//业务逻辑处理。。。}
}
springboot listener_Springboot 监听redis key的过期事件相关推荐
- SpringBoot监听redis Key变化事件详解
键空间通知(keyspace notification) 一 .功能概览 键空间通知使得客户端可以通过订阅频道或模式, 来接收那些以某种方式改动了 Redis key变化的事件. 所有修改key键的命 ...
- 监听Redis Key事件
文章目录 1.使用场景 2.使用 开启 redis 的事件监听与发布 Springboot集成 1.使用场景 处理订单过期自动取消,比如下单30分钟未支付自动更改订单状态. 注意:只能适用于单机red ...
- Spring Boot 监听 Redis Key 失效事件实现定时任务
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 作者:彭超 https://antoniopeng.com 业务场 ...
- redis 能不能监听特定的key失效_php监听redis key失效触发回调事件
订单超时.活动过期解决方案:php监听redis key失效触发回调事件 Redis 的 2.8.0 版本之后可用,键空间消息(Redis Keyspace Notifications),配合 2.0 ...
- redis 能不能监听特定的key失效_Spring boot实现监听Redis key失效事件实现和其它方式...
1.pom 中添加依赖 org.springframework.boot spring-boot-starter-data-redis 2.定义配置RedisListenerConfig /** * ...
- php 监听redis,php监听redis key失效触发回调事件_后端开发
php中使用fsockopen实现异步请求(代码示例)_后端开发 php执行一段程序,有可能几毫秒就执行完毕,也有可能耗时较长.例如,用户下单这个事件,如果调用了些第三方服务进行发邮件.短信.推送等通 ...
- php 监听redis,php监听redis key失效触发回调事件
订单超时.活动过期解决方案:php监听redis key失效触发回调事件 Redis 的 2.8.0 版本之后可用,键空间消息(Redis Keyspace Notifications),配合 2.0 ...
- 多服务监听Redis key失效通知,并指定特定机器进行处理业务
#1.修改 redis.conf 配置 找到notify-keyspace-events 并将notify-keyspace-events 修改为 notify-keyspace-events Ex ...
- 使用线程监听Redis多个频道及多个数据类型
1.说明: 使用手动创建线程的方式,对应的一个线程监听一个频道或者数据类型,而对应new 出来的线程对象放在了map中,根据key为频道名称或数据类型名称,value为线程对象. 此方式为了随时可以手 ...
最新文章
- 年仅 16 岁的黑客少年,竟是搅乱 IT 巨头的幕后主使?
- 支持向量机ModuleNotFoundError: No module named ‘sklearn.datasets.samples_generator‘
- 【转】 使用 AppFuse 快速构建 J2EE 应用
- 小余学调度:学习记录(2021.8.30-2021-9.5)
- 真香!腾讯再发阳光普照奖:每人100股,价值超6万!
- 【李宏毅机器学习】Tips for Deep Learning(p14) 学习笔记
- 计算机工程与应用3天外审,200629计算机工程与应用.pdf
- Composer的Autoload源码实现2——注册与运行
- 超级楼梯[HDU2041]
- LOJ#2764. 「JOI 2013 Final」JOIOI 塔
- 通过网络启动计算机,实现通过局域网唤醒计算机的两种方法
- 6. ROS编程入门--路径跟随(Trajectory following)
- sxt_(015)_request处理表单数据及乱码
- html表格方式实现商品详情
- cookie跨域,实现单点登录
- The JAVA_HOME environment variable is not defined correctly This environment variable is needed to r
- 诺禾-心源性猝死基因分型研究
- Kafka分区副本重分配源码分析
- C++广度优先搜索算法之抓住那头牛(Catch that cow)
- uniapp uview 框架的form表单,输入校验手机号、校验微信号