Spring+Redis(keyspace notification)实现定时任务（订单过期自动关闭）

小咪咪 2022-06-01 14:10 252阅读 0赞

### 1.起因 ###

最近公司项目要做订单超期未支付需自动关闭，首先想到的是用spring的定时器（@Schedule），结果领导举各种例子说会影响性能，只能作罢。后来想能不能基于redis实现，学习（baidu）之后，大概就是使用redis的[Keyspace Notifications][]，大概就是利用该机制可以在key失效之后，提供一个回调，实际上是redis会给客户端发送一个消息。是需要redis版本2.8以上，conf配置需设置notify-keyspace-events Ex，请示领导之后也得到了同意。

### 2.整合实现 ###

大致思路就是让spring做客户端订阅'\_\_keyevent@0\_\_:expired'频道就可以了。在这里给出两种实现方式。

1.利用MessageListenerAdapter，spring本身已经提供了的实现方式。

首先自定义一个MessageDelegate 接口并实现

![复制代码][copycode.gif]

1 public interface MyMessageDelegate {
     2   void handleMessage(String message);
     3   void handleMessage(Map message); void handleMessage(byte[] message);
     4   void handleMessage(Serializable message);
     5   // pass the channel/pattern as well
     6   void handleMessage(Serializable message, String channel);
     7  }
     8 
     9 public class MyRedisKeyExpiredMessageDelegate implements MessageDelegate {
    10   // implementation elided for clarity...
    11 }

![复制代码][copycode.gif]

xml增加相关配置

![复制代码][copycode.gif]

![复制代码][copycode.gif]

具体可参考官方文档：[http://docs.spring.io/spring-data/redis/docs/1.7.8.RELEASE/reference/html/\#redis:pubsub:subscribe][http_docs.spring.io_spring-data_redis_docs_1.7.8.RELEASE_reference_html_redis_pubsub_subscribe]

2.即自定义一个OrderPubSub类继承自JedisPubSub，然后在spring启动的时候就订阅这个OrderPubSub。

![复制代码][copycode.gif]

1 public class OrderSubscribe extends JedisPubSub {
     2     
     3     public void onPSubscribe(String pattern, int subscribedChannels) {   
     4         
     5     }  
     6       
     7     public void onPMessage(String pattern, String channel, String message) {    
     8             if ("__keyevent@0__:expired".equals(channel)) {
     9                 //do some thing
    10             }
    11     }
    12 }
    13 
    14 public class RedisInitSubscrib implements InitializingBean{  
    15     
    16     JedisPool pool;
    17 
    18     @Override
    19     public void afterPropertiesSet() throws Exception {
    20         pool.getResource().psubscribe(new OrderSubscribe(), "*");
    21         
    22     }
    23     
    24 }

![复制代码][copycode.gif]

当key失效后，收到消息的内容（即方法中的message参数）就是key的值，这样就可以做自定义的操作了。

### 3.后记 ###

欢迎大家留言交流，关于订单自动关闭如果有更好的方式，还望不吝赐教，O(∩\_∩)O谢谢。

[Keyspace Notifications]: https://redis.io/topics/notifications
[copycode.gif]: /images/20220601/ca09351ac8484f51bfba57ba7269cfd9.png
[http_docs.spring.io_spring-data_redis_docs_1.7.8.RELEASE_reference_html_redis_pubsub_subscribe]: http://docs.spring.io/spring-data/redis/docs/1.7.8.RELEASE/reference/html/#redis:pubsub:subscribe