说明
redis key过期监听通知一定要 开启key过期通知功能。
事件通过 Redis 的订阅与发布功能（pub/sub）来进行分发,故需要订阅 keyevent@0:expired 这个topic通道
解释：keyevent@2 :expired
__keyevent 必须以此开头；
@2 表示监听第二个数据库；
:expired 表示过期事件
1、redis 开启key过期通知
1、修改 redis.conf 文件 ，编辑/etc/redis/redis.conf文件，添加或启用以下内容（过期通知）：
配置详解:| 字符 | 发送通知 |
|—-|—————————————-|
| K | 键空间通知，所有通知以 keyspace@ 为前缀，针对Key |
| E | 键事件通知，所有通知以 keyevent@ 为前缀，针对event |
| g | DEL 、 EXPIRE 、 RENAME 等类型无关的通用命令的通知 |
| $ | 字符串命令的通知 |
| l | 列表命令的通知 |
| s | 集合命令的通知 |
| h | 哈希命令的通知 |
| z | 有序集合命令的通知 |
| x | 过期事件：每当有过期键被删除时发送 |
| e | 驱逐(evict)事件：每当有键因为 maxmemory 政策而被删除时发送 |
| A | 参数 g$lshzxe 的别名，相当于是All |将
notify-keyspace-events ""改为notify-keyspace-events "Ex"然后、重启redis , 即可测试失效事件的触发, 监听获取的值为 key
2、或者登陆redis-cli之后，输入以下命令：
config set notify-keyspace-events Ex
需要的jar包
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.8.4.RELEASE</version>
</dependency>
配置文件
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
......
default-lazy-init="false">
<context:property-placeholder location="classpath:redis.properties"
ignore-unresolvable="true"/>
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxIdle" value="1000"/>
<property name="minIdle" value="1000"/>
<property name="maxTotal" value="100"/>
<property name="testOnBorrow" value="true"/>
<property name="testOnReturn" value="true"/>
</bean>
<bean id="jedisConnectionFactory"
class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
p:host-name="127.0.0.1"
p:port="6379"
p:pool-config-ref="jedisPoolConfig"
p:use-pool="true"
p:database="${redis.database}"/>
<bean id="RedisTemplate" class="org.springframework.data.redis.core.RedisTemplate"
p:connection-factory-ref="jedisConnectionFactory"
p:keySerializer-ref="stringRedisSerializer"
p:valueSerializer-ref="JdkSerializationRedisSerializer"/>
<bean id="stringRedisSerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
<bean id="JdkSerializationRedisSerializer"
class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
<bean id="messageListener" class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">
<constructor-arg>
<bean class="com.mmall.concurrency.listener.RedisKeyExpiredListener"/>
</constructor-arg>
</bean>
<bean id="redisContainer" class="org.springframework.data.redis.listener.RedisMessageListenerContainer">
<property name="connectionFactory" ref="jedisConnectionFactory" />
<property name="messageListeners">
<map>
<entry key-ref="messageListener">
<list>
<!-- <bean class="org.springframework.data.redis.listener.ChannelTopic">-->
<!-- <constructor-arg value="__keyevent@1__:expired" />-->
<!-- </bean>-->
<!-- <bean class="org.springframework.data.redis.listener.PatternTopic">-->
<!-- <constructor-arg value="*" />-->
<!-- </bean>-->
<!-- <bean class="org.springframework.data.redis.listener.PatternTopic">-->
<!-- <constructor-arg value="'__key*__:*" />-->
<!-- </bean>-->
<bean class="org.springframework.data.redis.listener.ChannelTopic">
<constructor-arg value="__keyevent@2__:expired"/>
</bean>
</list>
</entry>
</map>
</property>
</bean>
</beans>
```java
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
/**
* redis监听
* 监听类需要实现MessageListener,监听到redis key过期的时候会自动执行到onMessage方法
* @version 1.0
*/
@Slf4j
public class RedisKeyExpiredListener implements MessageListener {
private static final String FAIL_KEY = "fail:key";
@Autowired
private TestService testService;
@Override
public void onMessage(Message message, byte[] bytes) {
String expiredKey = message.toString();// 获取失效的key
log.info("=========>失效的key:{}", expiredKey);
if (expiredKey.startsWith(FAIL_KEY )) {
// 进行相应的业务处理....
}
}
}
上面就可以完成监听的功能！！！！
上面的代码还可以改写成下面的形式
@Component(value ="SERVICE_NAME")
@Slf4j
public class RedisKeyExpiredListener implements MessageListener {
private static final String FAIL_KEY = "fail:key";
@Autowired
private TestService testService;
@Override
public void onMessage(Message message, byte[] bytes) {
String expiredKey = message.toString();// 获取失效的key
log.info("=========>失效的key:{}", expiredKey);
if (expiredKey.startsWith(FAIL_KEY )) {
// 进行相应的业务处理....
}
}
}
import com.mmall.concurrency.listener.RedisKeyExpiredListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
/**
* redis监听容器
* @author 12706
*/
@Configuration
public class RedisConfig {
@Autowired
@Qualifier(value = "SERVICE_NAME")//指定的是自己写的RedisMessageListener
private RedisKeyExpiredListener redisKeyExpiredListener;
@Autowired
private RedisTemplate redisTemplate;
@Bean
public RedisMessageListenerContainer container(MessageListenerAdapter listenerAdapter) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(redisTemplate.getConnectionFactory());
container.addMessageListener(listenerAdapter, new PatternTopic("__keyevent@0__:expired"));
//这里是监听redis第一个库里面key的过期
return container;
}
@Bean
public MessageListenerAdapter listenerAdapter() {
return new MessageListenerAdapter(redisKeyExpiredListener);
}
}
原文链接: https://onlyou.blog.csdn.net//article/details/103538926