基本概念
Redis的过期回调可以实现我们的redsi的key在过期的时候回调一些接口从而来实现项目中需要的一些功能。比如我们想在订单超时的时候进行关闭，可以用这个来进行一个简单的实现，当然实际的项目中能否这样使用我们暂且不做讨论，这里只是举个例子。
Redis的事件回调的特点
Redis是怎么实现过期的？
redis的过期是根据上次更新时间和当前时间的差值，比较看是否大于设置的过期时间，大于就过期。但是redis服务宕机了之后设置了过期时间的key如果还没有过期，就会导致过期时间失效，变成永久的key。
另外要注意，redis过期的key不会立马删除，因为redis采用定时删除和惰性删除，有可能到了过期时间但是key还没有删除，这个时候我redis宕机了，重启之后即使是已经过期了的key也会变成永久的。
过期事件回调的应用实战
首先打开redis的配置文件，然后将notify-keyspace-events Ex这个配置的注释打开，由于打开这个回调的通知会对redis的性能有一定的影响，所以官方默认是关闭的。这个Ex参数的作用就是生命是过期事件才进行发布通知。
然后引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
<version>2.1.9.RELEASE</version>
</dependency>
创建配置类
package com.dongmu.config;
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.ChannelTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
@Configuration
public class RedisConfiguration {
@Autowired
private RedisConnectionFactory redisConnectionFactory;
@Bean
public ChannelTopic expireTopic(){
return new ChannelTopic("test01");
}
@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(){
RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
return redisMessageListenerContainer;
}
}
这里说明一下为什么需要这个配置类RedisMessageListenerContainer ，这个类在我们下面创建一个监听器类的时候需要用到这个对象作为入参，所以必须创建，不然由于构造函数参数缺少没无法创建监听器bean对象。
创建监听器bean对象
package com.dongmu.listener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
super(listenerContainer);
}
@Autowired
StringRedisTemplate stringRedisTemplate;
@Override
public void onMessage(Message message,byte[] pattern){
String expireKey = message.toString();
System.out.println(expireKey);
if (expireKey.startsWith("dongmu:test")){
System.out.println(expireKey+"过期了");
}
}
}
onMessage方法里面可以处理我们的逻辑。
下面编写一个Controller进行测试
@Autowired
StringRedisTemplate redisTemplate;
@RequestMapping("/redis/test")
public void RedisTest(){
redisTemplate.opsForValue().set("dongmu:test:key1","mytestkey1",5, TimeUnit.SECONDS);
}
访问接口
结果
可以发现这里的过期通知生效了。
redis的过期回调实现订单的超时关闭
redis的过期回调并不能够保存可靠性，所以一般不能这样用，如果这样用的话还要定时扫描数据库处理已经超时的订单，不能完全依靠redis的过期回调通知，另外redis 的过期时间有可能变成永久的，而且开启了过期回调会影响redis的性能，所以尽量不要这样用，小项目的话可以尝试以下，大项目的或者要求比较高的场景一定要使用专业的消息中间件。
docker中配置redis
一般我们的linux服务器上的redis可能会安装在docker容器内部，这个时候想要修改容器中redis的配置就需要做挂载，步骤如下：
docker pull redis #下载最新版本的redis
#下面这一步会把我们的内部的文件夹挂载到外部文件夹以及映射的端口，
#要注意这个命令里面指定了配置文件
docker run -p 9999:6379 --name redis -v /usr/local/docker:/etc/redis -v /usr/local/docker/data:/data -d redis redis-server /etc/redis/redis.conf --appendonly yes
#然后我们利用下载最新的redsi的配置文件，在配置文件中指定redis的密码，
#注意这里配置文件一定要用和这个版本一致的配置文件不然还会报错
requirepass ***(这里写你的密码)
maxclients 1000（最大的连接数量）
#同时把过期回调的注释打开
notify-keyspace-events Ex
#配置好了之后我们启动docker 中的redis容器即可
dockers start 容器id
亲测服务器上过期回调成功
对于已经启动的redis我们还可以查看docker的配置
docker inspect redis #即可查看