项目中常常会碰到这样的需求,用户下订单后,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的过期事件相关推荐

  1. SpringBoot监听redis Key变化事件详解

    键空间通知(keyspace notification) 一 .功能概览 键空间通知使得客户端可以通过订阅频道或模式, 来接收那些以某种方式改动了 Redis key变化的事件. 所有修改key键的命 ...

  2. 监听Redis Key事件

    文章目录 1.使用场景 2.使用 开启 redis 的事件监听与发布 Springboot集成 1.使用场景 处理订单过期自动取消,比如下单30分钟未支付自动更改订单状态. 注意:只能适用于单机red ...

  3. Spring Boot 监听 Redis Key 失效事件实现定时任务

    点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 作者:彭超 https://antoniopeng.com 业务场 ...

  4. redis 能不能监听特定的key失效_php监听redis key失效触发回调事件

    订单超时.活动过期解决方案:php监听redis key失效触发回调事件 Redis 的 2.8.0 版本之后可用,键空间消息(Redis Keyspace Notifications),配合 2.0 ...

  5. redis 能不能监听特定的key失效_Spring boot实现监听Redis key失效事件实现和其它方式...

    1.pom 中添加依赖 org.springframework.boot spring-boot-starter-data-redis 2.定义配置RedisListenerConfig /** * ...

  6. php 监听redis,php监听redis key失效触发回调事件_后端开发

    php中使用fsockopen实现异步请求(代码示例)_后端开发 php执行一段程序,有可能几毫秒就执行完毕,也有可能耗时较长.例如,用户下单这个事件,如果调用了些第三方服务进行发邮件.短信.推送等通 ...

  7. php 监听redis,php监听redis key失效触发回调事件

    订单超时.活动过期解决方案:php监听redis key失效触发回调事件 Redis 的 2.8.0 版本之后可用,键空间消息(Redis Keyspace Notifications),配合 2.0 ...

  8. 多服务监听Redis key失效通知,并指定特定机器进行处理业务

    #1.修改 redis.conf 配置 找到notify-keyspace-events 并将notify-keyspace-events 修改为 notify-keyspace-events Ex ...

  9. 使用线程监听Redis多个频道及多个数据类型

    1.说明: 使用手动创建线程的方式,对应的一个线程监听一个频道或者数据类型,而对应new 出来的线程对象放在了map中,根据key为频道名称或数据类型名称,value为线程对象. 此方式为了随时可以手 ...

最新文章

  1. 年仅 16 岁的黑客少年,竟是搅乱 IT 巨头的幕后主使?
  2. 支持向量机ModuleNotFoundError: No module named ‘sklearn.datasets.samples_generator‘
  3. 【转】 使用 AppFuse 快速构建 J2EE 应用
  4. 小余学调度:学习记录(2021.8.30-2021-9.5)
  5. 真香!腾讯再发阳光普照奖:每人100股,价值超6万!
  6. 【李宏毅机器学习】Tips for Deep Learning(p14) 学习笔记
  7. 计算机工程与应用3天外审,200629计算机工程与应用.pdf
  8. Composer的Autoload源码实现2——注册与运行
  9. 超级楼梯[HDU2041]
  10. LOJ#2764. 「JOI 2013 Final」JOIOI 塔
  11. 通过网络启动计算机,实现通过局域网唤醒计算机的两种方法
  12. 6. ROS编程入门--路径跟随(Trajectory following)
  13. sxt_(015)_request处理表单数据及乱码
  14. html表格方式实现商品详情
  15. cookie跨域,实现单点登录
  16. The JAVA_HOME environment variable is not defined correctly This environment variable is needed to r
  17. 诺禾-心源性猝死基因分型研究
  18. Kafka分区副本重分配源码分析
  19. C++广度优先搜索算法之抓住那头牛(Catch that cow)
  20. uniapp uview 框架的form表单,输入校验手机号、校验微信号

热门文章

  1. win10查看端口占用
  2. 校内模拟赛 Zbq's Music Challenge
  3. Django (八) 中间件验证码富文本缓存
  4. flask 必知必会
  5. 在64位Ubuntu上编译32位程序常见错误
  6. C# 获取枚举的描述属性
  7. Node.js 得到当前目录下文件修改文件名
  8. mysqldump 定时备份数据(全量)
  9. 解决VirtualBox错误:“FATAL:No bootable medium found!”
  10. VC 6中使用不同调用规范的函数在符号文件里的表示方式