我要评论1. 示例场景
电商平台常会发放「限时优惠券」（比如 “满 100 减 20，30 分钟内有效”“24 小时专属券”），核心诉求是：
- 优惠券一旦超过有效期，必须自动标记为 “已失效”，用户无法再使用；
- 避免用户在优惠券过期后仍尝试用券下单，导致订单支付异常；
- 无需定时任务轮询（比如每分钟扫全量表），减少数据库压力；
- 精准触发失效逻辑（优惠券到期瞬间就处理，而非定时任务的 “延迟生效”）。
如果用传统定时任务方案，会面临两个核心问题：
- 优惠券发放时间分散（用户随时领券），无法精准设定轮询规则（比如 30 分钟有效期的券，有的用户 10:01 领，有的 10:05 领，定时任务间隔设短了耗性能，设长了失效不及时）；
- 全量表轮询会频繁查询数据库，高并发下（比如大促发百万张券）数据库扛不住。
此时，用「redis 监听键过期」的方案就能完美解决，既精准又低耗。
2. 配置 redis 开启key 过期通知
- redis 默认关闭键空间通知，需要先开启并指定监听的事件类型。
方式一：临时配置（重启 redis 失效）
# 开启过期事件监听，也可按需指定（如只监听过期+驱逐：kxke） 127.0.0.1:6379> config set notify-keyspace-events ex
方式 二：永久配置
- 修改redis配置文件redis.conf，查看 notify-keyspace-events 配置项，修改为
notify-keyspace-events ex，并重启redis生效，相关参数说明如下：
k：keyspace 事件，事件以 keyspace@ 为前缀进行发布 e：keyevent 事件，事件以 keyevent@ 为前缀进行发布 g：一般性的，非特定类型的命令，比如del，expire，rename等 $：字符串特定命令 l：列表特定命令 s：集合特定命令 h：哈希特定命令 z：有序集合特定命令 x：过期事件，当某个键过期并删除时会产生该事件 e：驱逐事件，当某个键键因redis内存达到maxmemory上限，被淘汰策略删除时触发 a：g$lshzxe的别名，因此”ake”意味着所有事件
3. 添加pom文件
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-data-redis</artifactid>
</dependency>4. redislistenerconfig配置类
- 实现监听 redis key过期时间
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;
@configuration
public class redislistenerconfig {
@bean
redismessagelistenercontainer container(redisconnectionfactory connectionfactory) {
redismessagelistenercontainer container = new redismessagelistenercontainer();
container.setconnectionfactory(connectionfactory);
return container;
}
}5. rediskeyexpirationlistener监听类
- 实现
keyexpirationeventmessagelistener接口，查看源码发现，该接口监听所有db的过期事件 keyevent@*:expired" - 键过期事件并非“实时触发”：redis 采用 “惰性删除 + 定期删除” 策略，过期键可能延迟触发事件。
/**
* 监听所有db的过期事件__keyevent@*__:expired"
*/
@component
@slf4j
public class rediskeyexpirationlistener extends keyexpirationeventmessagelistener {
public rediskeyexpirationlistener(redismessagelistenercontainer listenercontainer) {
super(listenercontainer);
}
/**
* 针对 redis 数据失效事件，进行数据处理
* @param message
* @param pattern
*/
@override
public void onmessage(message message, byte[] pattern) {
// 获取到失效的 key，进行取消订单业务处理
string expiredkey = message.tostring();
log.info("失效的key:{}", expiredkey);
}
}
6. 使用线程池优化
- 先定义一个专门处理过期事件业务的线程池，避免使用默认线程池导致资源竞争：
/**
* 过期事件异步处理线程池配置
*/
@configuration
@enableasync // 开启异步注解支持
public class rediseventexecutorconfig {
/**
* 自定义线程池，处理过期事件的业务逻辑
*/
@bean("redisexpireeventexecutor")
public executor redisexpireeventexecutor() {
threadpooltaskexecutor executor = new threadpooltaskexecutor();
// 核心线程数（根据业务压力调整）
executor.setcorepoolsize(5);
// 最大线程数
executor.setmaxpoolsize(20);
// 队列容量（缓冲待处理的任务）
executor.setqueuecapacity(1000);
// 线程名前缀（便于日志排查）
executor.setthreadnameprefix("redis-expire-event-");
// 拒绝策略：队列满+线程数到最大时，由提交任务的线程执行（避免任务丢失）
executor.setrejectedexecutionhandler(new threadpoolexecutor.callerrunspolicy());
// 线程空闲超时时间
executor.setkeepaliveseconds(60);
// 初始化线程池
executor.initialize();
return executor;
}
}
// 在监听类中调用
@component
public class redisexpirebusinessservice {
@async("redisexpireeventexecutor")
public void handleexpiredkeyasync(string expiredkey) {
try {
system.out.println("异步处理过期key：" + expiredkey + "，线程：" + thread.currentthread().getname());
} catch (exception e) {
system.err.println("处理过期key失败：" + expiredkey + "，异常：" + e.getmessage());
}
}
}
7. 进一步优化
如果过期事件量极大（比如每秒上万），仅靠线程池可能不够，可叠加以下方案：
7.1. 引入消息队列（如 rocketmq/kafka）
- 监听器只做 “生产消息”：将过期 key 发送到消息队列；
- 单独的消费者服务处理业务逻辑：解耦redis监听和业务处理，支持削峰填谷。
7.2. 优化 redis 监听容器线程池
redismessagelistenercontainer 自身也有监听线程池，可调整参数避免监听线程不够用：
@bean
public redismessagelistenercontainer redismessagelistenercontainer(redisconnectionfactory connectionfactory) {
redismessagelistenercontainer container = new redismessagelistenercontainer();
container.setconnectionfactory(connectionfactory);
// 设置监听线程池的核心参数（默认线程数可能不足）
container.settaskexecutor(new threadpooltaskexecutor() {{
setcorepoolsize(3); // 监听线程数，根据事件量调整
setmaxpoolsize(5);
setthreadnameprefix("redis-listener-");
initialize();
}});
return container;
}
以上就是springboot监听redis key过期事件的几种方式的详细内容，更多关于springboot监听redis key过期事件的资料请关注代码网其它相关文章！
发表评论