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

cjcmay

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 接口并实现
　　

public interface MyMessageDelegate {　　

   void handleMessage(String message);　　

   void handleMessage(Map message); void handleMessage(byte[] message);　　

   void handleMessage(Serializable message);　　

   // pass the channel/pattern as well　　
   void handleMessage(Serializable message, String channel);
　　
  }
　　

　　
public>　　
   // implementation elided for clarity...
　　
}
　　

　　xml增加相关配置
　　

     <bean　　class
="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">　　<constructor-arg>
　　<bean />
　　</constructor-arg>
　　</bean>
　　<bean>
　　<property name="connectionFactory" ref="connectionFactory" />
　　<property name="messageListeners">
　　<map>
　　<entry key-ref="messageListener">
　　<list>
　　<bean>
　　<constructor-arg value="__keyevent@0__:expired" />
　　</bean>
　　</list>
　　</entry>
　　</map>
　　</property>
　　</bean>   
　　

　　具体可参考官方文档：http://docs.spring.io/spring-data/redis/docs/1.7.8.RELEASE/reference/html/#redis:pubsub:subscribe
　　2.即自定义一个OrderPubSub类继承自JedisPubSub，然后在spring启动的时候就订阅这个OrderPubSub。
　　

public>

　　
     public void onPSubscribe(String pattern, int subscribedChannels) {   
　　
         
　　
     }  
　　
      
　　
     public void onPMessage(String pattern, String channel, String message) {   
　　
             if ("__keyevent@0__:expired".equals(channel)) {
　　
                 //do some thing
　　
             }
　　
     }
　　
}
　　


　　
public>　　
     
　　
     JedisPool pool;
　　

　　
     @Override
　　
     public void afterPropertiesSet() throws Exception {
　　
         pool.getResource().psubscribe(new OrderSubscribe(), "*");
　　
         
　　
     }
　　
     
　　
}
　　

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

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

Keyspace Notifications