在Spring Boot中，可以使用spring-boot-starter-data-redis依赖来配置Redis的键值变化监听。以下是一个简单的例子，展示如何配置和监听Redis键的变化。
- 添加依赖到你的
pom.xml：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>- 在
application.properties或application.yml中配置Redis：
# application.properties
spring.redis.host=localhost
spring.redis.port=6379- 创建一个Redis键值变化监听器：
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RedisKeyListenerConfig {
@Bean
RedisMessageListenerContainer redisMessageListenerContainer(
RedisConnectionFactory redisConnectionFactory) {
final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(redisConnectionFactory);
container.addMessageListener(keyExpirationListener(), topic());
return container;
}
@Bean
KeyExpirationEventMessageListener keyExpirationListener() {
return new KeyExpirationEventMessageListener() {
@Override
public void onMessage(Message message, byte[] pattern) {
// 处理键的到期事件
String expiredKey = message.toString();
System.out.println("Key expired: " + expiredKey);
}
};
}
@Bean
String topic() {
// 这里可以指定特定的通道，例如__keyevent@0__:expired
return "__keyevent@0__:expired";
}
}在这个配置中，我们定义了一个RedisMessageListenerContainer，它使用redisConnectionFactory来创建与Redis的连接，并添加了一个监听器keyExpirationListener来处理过期事件。这个监听器会监听默认的通道__keyevent@0__:expired，当有键过期时，它会打印出过期的键。
要监听非过期事件（如键的设置或删除），你需要订阅相应的Redis通道，例如__keyevent@0__:set或__keyevent@0__:del。
确保你的Redis服务器配置允许发送键过期事件给客户端。在Redis配置文件redis.conf中，确保以下设置：
notify-keyspace-events ExEx代表键事件，表示发送所有类型的键事件通知。根据需要，你可以只启用特定的事件类型，例如E表示键事件，g表示一般事件，或者组合它们。