Spring boot实现监听Redis key失效事件实现和其它方式

需求：

处理订单过期自动取消，比如下单30分钟未支付自动更改订单状态

用户绑定隐私号码当订单结束取消绑定等

解决方案1：

可以利用redis自带的key自动过期机制，下单时将订单id写入redis，过期时间30分钟，30分钟后检查订单状态，如果未支付，则进行处理但是key过期了redis有通知吗？答案是肯定的。

开启redis key过期提醒

修改redis相关事件配置。找到redis配置文件redis.conf，只需修改配置文件redis.conf中的：notify-keyspace-events Ex，默认为notify-keyspace-events ""，查看“notify-keyspace-events”的配置项，如果没有，添加“notify-keyspace-events Ex”，如果有值，添加Ex，相关参数说明如下：

K：keyspace事件，事件以__keyspace@<db>__为前缀进行发布；

E：keyevent事件，事件以__keyevent@<db>__为前缀进行发布；

g：一般性的，非特定类型的命令，比如del，expire，rename等；

$：字符串特定命令；

l：列表特定命令；

s：集合特定命令；

h：哈希特定命令；

z：有序集合特定命令；

x：过期事件，当某个键过期并删除时会产生该事件；

e：驱逐事件，当某个键因maxmemore策略而被删除时，产生该事件；

A：g$lshzxe的别名，因此”AKE”意味着所有事件。

Redis测试：

打开一个redis-cli ,监控db0的key过期事件

打开另一个redis-cli ,发送定时过期key

观察上一个redis-cli ,会发现收到了过期的key hello，但是无法收到过期的value world

根据这个特性在springboot中使用

1.pom 中添加依赖

  <!-- redis -->

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-data-redis</artifactId>

        </dependency>

2.定义配置RedisListenerConfig

/**

 * @author mazhq

 * @Title: RedisListenerConfig

 * @ProjectName: zeus

 * @date 2019/2/20 11:25

 */

@Configuration

public class RedisListenerConfig {

    @Bean

    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();

        container.setConnectionFactory(connectionFactory);

        //container.addMessageListener(new RedisExpiredListener(), new PatternTopic("__keyevent@0__:expired"));

        return container;

    }

}

3.定义监听器，实现KeyExpirationEventMessageListener接口，查看源码发现，该接口监听所有db的过期事件keyevent@*:expired"

/**

 * @author mazhq

 * @Title: RedisKeyExpirationListener

 * @ProjectName: zeus

 * @date 2019/2/20 11:26

 */

@Component

public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {

    private final static Logger logger = LoggerFactory.getLogger(RedisKeyExpirationListener.class);

    @Autowired

    private RedisClient redisClient;

    /**

     * Creates new {@link MessageListener} for {@code __keyevent@*__:expired} messages.

     *

     * @param listenerContainer must not be {@literal null}.

     */

    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {

        super(listenerContainer);

    }

    @Override

    public void onMessage(Message message, byte[] pattern) {

        // 用户做自己的业务处理即可,注意message.toString()可以获取失效的key

        String expiredKey = message.toString();

        if(expiredKey.startsWith("zeus:order")){

            //TODO

        }

    }

}

或者打开RedisListenerConfig中 container.addMessageListener(new RedisExpiredListener(), new PatternTopic("__keyevent@0__:expired")); 注释，再定义监听器，监控__keyevent@0__:expired事件，即db0过期事件。这个地方定义的比较灵活，可以自己定义监控什么事件。

public class RedisExpiredListener implements MessageListener {

    /**

     * 客户端监听订阅的topic，当有消息的时候，会触发该方法;

     * 并不能得到value, 只能得到key。

     * 姑且理解为: redis服务在key失效时(或失效后)通知到java服务某个key失效了, 那么在java中不可能得到这个redis-key对应的redis-value。

     *      * 解决方案:

     *  创建copy/shadow key, 例如 set vkey "vergilyn"; 对应copykey: set copykey:vkey "" ex 10;

     *  真正的key是"vkey"(业务中使用), 失效触发key是"copykey:vkey"(其value为空字符为了减少内存空间消耗)。

     *  当"copykey:vkey"触发失效时, 从"vkey"得到失效时的值, 并在逻辑处理完后"del vkey"

     *

     * 缺陷:

     *  1: 存在多余的key; (copykey/shadowkey)

     *  2: 不严谨, 假设copykey在 12:00:00失效, 通知在12:10:00收到, 这间隔的10min内程序修改了key, 得到的并不是 失效时的value.

     *  (第1点影响不大; 第2点貌似redis本身的Pub/Sub就不是严谨的, 失效后还存在value的修改, 应该在设计/逻辑上杜绝)

     *  当"copykey:vkey"触发失效时, 从"vkey"得到失效时的值, 并在逻辑处理完后"del vkey"

     *

     */

    @Override

    public void onMessage(Message message, byte[] bytes) {

        byte[] body = message.getBody();// 建议使用: valueSerializer

        byte[] channel = message.getChannel();

        System.out.print("onMessage >> " );

        System.out.println(String.format("channel: %s, body: %s, bytes: %s"

                ,new String(channel), new String(body), new String(bytes)));

    }

}

解决方案2

使用spring + quartz定时任务（支持任务信息写入mysql,多节点分布式执行任务），下单成功后，生成一个30分钟后运行的任务，30分钟后检查订单状态，如果未支付，则进行处理

解决方案3

将订单过期时间信息写入mysql，按分钟轮询查询mysql，如果超时则进行处理，效率差！时间精准度底！

结论

推荐使用方案1和方案2

巴特西