快捷導(dǎo)航

SpringBoot監(jiān)聽Redis key失效事件的實現(xiàn)代碼

更新時間：2024年02月20日 11:11:11 作者：是阿洋啊

這篇文章給大家介紹了SpringBoot實現(xiàn)監(jiān)聽Redis key失效事件的方法,文中通過代碼示例給大家講解的非常詳細(xì),具有一定的參考價值,需要的朋友可以參考下

一. 開啟Redis key過期提醒

方式一：修改配置文件

redis.conf

# 默認(rèn) notify-keyspace-events ""
notify-keyspace-events Ex

方式二：命令行開啟

CONFIG SET notify-keyspace-events Ex
CONFIG GET notify-keyspace-events

二. notify-keyspace-events

notify-keyspace-events 選項的默認(rèn)值為空

notify-keyspace-events 的參數(shù)可以是以下字符的任意組合，它指定了服務(wù)器該發(fā)送哪些類型的通知。

字符	發(fā)送的通知
K	鍵空間通知，所有通知以 keyspace@ 為前綴
E	鍵事件通知，所有通知以 keyevent@ 為前綴
g	DEL 、 EXPIRE 、 RENAME 等類型無關(guān)的通用命令的通知
$	字符串命令的通知
l	列表命令的通知
s	集合命令的通知
h	哈希命令的通知
z	有序集合命令的通知
x	過期事件：每當(dāng)有過期鍵被刪除時發(fā)送
e	驅(qū)逐(evict)事件：每當(dāng)有鍵因為 maxmemory 政策而被刪除時發(fā)送
A	參數(shù) g$lshzxe 的別名

三. Coding

初始化一個Spring Boot項目
pom.xml

<dependencies>
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-data-redis</artifactId>
	</dependency>
	<dependency>
		<groupId>org.projectlombok</groupId>
		<artifactId>lombok</artifactId>
	</dependency>
</dependencies>

定義配置類`RedisListenerConfig

@Configuration
public class RedisListenerConfig {

	@Bean
	RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
		RedisMessageListenerContainer container = new RedisMessageListenerContainer();
		container.setConnectionFactory(connectionFactory);
		return container;
	}

}

定義監(jiān)聽器實現(xiàn)KeyExpirationEventMessageListener接口
查看源碼發(fā)現(xiàn)，該接口監(jiān)聽所有db的過期事件keyevent@*:expired"定義Status1ExpirationListener監(jiān)聽狀態(tài)1到期

@Slf4j
@Component
public class Status1ExpirationListener extends KeyExpirationEventMessageListener {

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

	@Autowired
	private StringRedisTemplate stringRedisTemplate;

	@Override
	public void onMessage(Message message, byte[] pattern) {
		// message.toString()可以獲取失效的key
		String expiredKey = message.toString();
		// 業(yè)務(wù)處理
	}

}

定義Status2ExpirationListener監(jiān)聽狀態(tài)2到期

@Slf4j
@Component
public class Status2ExpirationListener extends KeyExpirationEventMessageListener {

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

	@Override
	public void onMessage(Message message, byte[] pattern) {
		// message.toString()可以獲取失效的key
		String expiredKey = message.toString();
		// 業(yè)務(wù)處理
	}

}