Spring Boot + Redis 实现过期Key监听：实战教程与配置详解

本文主要探讨了如何在Spring Boot项目中结合Redis实现监听过期Key的功能，以支持订单业务中对有效期的管理。Spring Boot与Redis的集成通常用于缓存数据和简化配置，而过期Key的监控则有助于自动化处理一些业务逻辑。 首先，要在Spring Boot项目中引入Spring Data Redis的依赖，以便使用Redis客户端和相关功能： ```xml <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> ``` 配置Spring Boot的Redis连接参数，包括数据库、主机、端口和密码，确保服务能够正确连接到Redis实例： ```yaml spring: redis: database: 0 host: 127.0.0.1 password: redis_123456 port: 6379 ``` 为了监听过期Key，需要修改Redis服务器的配置文件`redis.conf`，增加`notify-keyspace-events Ex`参数，这将启用键空间事件通知，仅监听键的过期事件。 接下来，创建一个专门用于处理过期Key的监控类，这个类需要继承`KeyExpirationEventMessageListener`接口。这是一个监听器，当Redis中的键过期时，会触发该类的方法执行相应的业务操作： ```java import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.data.redis.connection.Message; import org.springframework.data.redis.listener.KeyExpirationEventMessageListener; import org.springframework.data.redis.listener.RedisMessageListenerContainer; public class ExpiredKeyListener extends KeyExpirationEventMessageListener { private static final Logger logger = LoggerFactory.getLogger(ExpiredKeyListener.class); @Override public void onMessage(Message message, byte[] pattern) { String key = new String(message.getBody(), StandardCharsets.UTF_8); try { // 在这里处理过期Key的具体业务逻辑，如更新订单状态或删除过期数据 logger.info("Key {} has expired, processing...", key); // 业务代码... } catch (Exception e) { logger.error("Error handling expired key", e); } } } ``` 最后，在Spring Boot应用启动时，需要设置RedisMessageListenerContainer来注册监听器： ```java import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RedisConfig { @Bean public RedisMessageListenerContainer redisListenerContainer() { RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(redisConnectionFactory()); container.addMessageListener(new ExpiredKeyListener(), "EXPIRE"); return container; } // 其他Redis连接工厂配置... } ``` 这样，当Redis中的Key过期时，Spring Boot应用会自动接收到通知，并调用`ExpiredKeyListener`中的`onMessage`方法执行相应的业务逻辑。这种方式简化了定期检查过期Key的定时任务，提高了系统的响应性和灵活性。