SpringBoot監聽Redis的Key過期事件

原文：https://springboot.io/t/topic/24

在一些業務場景中，我們希望在Redis的key過期時，得到通知。

Redis的配置
修改conf文件
notify-keyspace-events "Ex"
該配置表示監聽key的過期事件，默認未開啟
該配置的其他信息（可以監聽N多事件），可以參閱配置文件的注釋，非常詳細
自定義監聽器
該監聽器會在key過期時候觸發

import java.nio.charset.StandardCharsets;

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 KeyExpiredListener extends KeyExpirationEventMessageListener {

private static final Logger LOGGER = LoggerFactory.getLogger(KeyExpiredListener.class);

public KeyExpiredListener(RedisMessageListenerContainer listenerContainer) {
super(listenerContainer);
}

@Override
public void onMessage(Message message, byte[] pattern) {
String channel = new String(message.getChannel(),StandardCharsets.UTF_8);
//過期的key
String key = new String(message.getBody(),StandardCharsets.UTF_8);
LOGGER.info("redis key 過期：pattern={},channel={},key={}",new String(pattern),channel,key);
}
@Confiugration配置 
import org.springframework.beans.factory.annotation.Autowired;
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;

import io.javaweb.redis.listener.KeyExpiredListener;

@Configuration
public class RedisConfiguration {

@Autowired
private RedisConnectionFactory redisConnectionFactory;

@Bean
public RedisMessageListenerContainer redisMessageListenerContainer() {
RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
return redisMessageListenerContainer;
}

@Bean
public KeyExpiredListener keyExpiredListener() {
return new KeyExpiredListener(this.redisMessageListenerContainer());
}
}
往Redis寫入一個key，並且設置過期時間

 

 

過期事件被觸發

 

 

 

————————————————
版權聲明：本文為CSDN博主「、YongTing」的原創文章，遵循CC 4.0 BY-SA版權協議，轉載請附上原文出處鏈接及本聲明。
原文鏈接：https://blog.csdn.net/weixin_38261597/article/details/89203525