java 监听rediskey过期还有值

### Java 实现监听 Redis 键过期并处理 为了实现监听 Redis 中键的过期事件，在 Java 应用程序中可以利用 `RedisMessageListenerContainer` 和自定义的消息监听器来捕获这些事件。当某个键设置了过期时间并且该键确实有过期行为发生时，可以通过特定频道接收到通知。 对于键空间通知的支持需要在 Redis 配置文件中开启相应的选项[^1]： ```properties notify-keyspace-events Ex ``` 此配置使得服务器能够发送与键到期有关的通知消息给客户端。其中参数 E 表示启用过期事件而 x 则表示只对数据库中的实际删除动作感兴趣（即仅限于因 TTL 达到零而导致的数据移除）。一旦完成上述设置之后，则可以在应用程序内部通过如下方式创建一个用于接收此类信号的服务组件[^2]。 下面是一个完整的例子展示怎样构建这样的功能模块： #### 1. 定义监听容器 Bean 首先确保已经注册了一个 `RedisMessageListenerContainer` 的实例作为 Spring 上下文中的一部分，这允许我们向它添加不同的监听者对象以便它们能响应来自不同主题的信息流。 ```java @Configuration public class RedisListenerConfig { @Bean public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) { final var listenerContainer = new RedisMessageListenerContainer(); listenerContainer.setConnectionFactory(connectionFactory); // 添加对 __keyevent@*__:expired 模式的监听支持 listenerContainer.addMessageListener(new KeyExpirationEventMessageListener(), new PatternTopic("__keyevent@0__:expired")); return listenerContainer; } } ``` 这里特别注意模式字符串 `"__keyevent@0__:expired"` ，其指定了要关注的是编号为 0 的数据库里所有因为到达生存期限被清除掉的对象；如果应用涉及多个库则需调整这部分逻辑以适应具体需求。 #### 2. 创建专门的监听类 接下来就是编写具体的业务处理器——每当检测到目标条件满足时就会触发执行相应方法体内的代码片段。在此处假设希望打印日志记录或者调用其他服务接口来进行进一步的操作。 ```java @Component class KeyExpirationEventMessageListener implements MessageListener { private static final Logger logger = LoggerFactory.getLogger(KeyExpirationEventMessageListener.class); @Override public void onMessage(Message message, byte[] pattern) { String expiredKey = new String(message.getBody()); logger.info("Detected expiration of key: {}", expiredKey); // 进行业务逻辑判断是否存在对应的值以及后续处理... Optional<String> valueOpt = redisTemplate.opsForValue().getOperations() .boundValueOps(expiredKey).get(); if (valueOpt.isPresent()) { String value = valueOpt.get(); processExpiredKeyValuePair(expiredKey, value); } else { logger.warn("No value found for the expired key."); } } private void processExpiredKeyValuePair(String key, String value){ // 处理已过期但仍存在的键-值对的具体逻辑 System.out.println("Processing expired key-value pair: [" + key + ", " + value + "]"); } } ``` 需要注意的是由于 Redis 设计上不会保留已被标记为过期但尚未真正从内存中消失的数据项，因此尝试读取刚经历自动清理过程后的实体可能会失败。所以在访问之前最好先确认是否仍然可以获得关联的内容再决定采取何种行动。