Java

redis高级功能-超时触发事件

2018-02-23  本文已影响1056人  tuoxie119

问题提出

在和朋友讨论订单超时未支付自动关闭的实现时,考虑了一下几种方式

  1. Quartz 任务调度框架,更适合周期性的执行任务,对于订单超时未支付,只能采用5分钟一轮询数据库的形式实现
  2. Timer java原生定时工具,可少量使用,当数据量大时,性能不好控制
  3. Quartz + Timer 周期轮询(5分钟)数据库,查询出5分钟之内将要超时的订单,然后多线程创建timer完成订单的定时,这种实现方式比较复杂,但是可以在性能和功能方面,是可以实现的
  4. reids 键空间通知 以下将介绍此种方式

redis 键空间通知实现

过期事件通过Redis的订阅与发布功能(pub/sub)来进行分发。

redis服务端配置

超时的监听,并不需要自己发布,只有修改配置文件redis.conf中的:notify-keyspace-events Ex,默认为notify-keyspace-events ""

# K    键空间通知,以__keyspace@<db>__为前缀  
# E    键事件通知,以__keysevent@<db>__为前缀  
# g    del , expipre , rename 等类型无关的通用命令的通知, ...  
# $    String命令  
# l    List命令  
# s    Set命令  
# h    Hash命令  
# z    有序集合命令  
# x    过期事件(每次key过期时生成)  
# e    驱逐事件(当key在内存满了被清除时生成)  
# A    g$lshzxe的别名,因此”AKE”意味着所有的事件  

修改好配置文件后,redis会对设置了expire的数据进行监听,当数据过期时便会将其从redis中删除

java代码实现

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

利用MessageListenerAdapter,spring本身已经提供了的实现方式。
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 class MyRedisKeyExpiredMessageDelegate implements MessageDelegate {
  // implementation elided for clarity...
}

xml增加相关配置

<bean id="messageListener"
          class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">
        <constructor-arg>
            <bean class="com.xxx.MyRedisKeyExpiredMessageDelegate" />
        </constructor-arg>
    </bean>
    <bean id="redisContainer" class="org.springframework.data.redis.listener.RedisMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="messageListeners">
            <map>
                <entry key-ref="messageListener">
                    <list>
                        <bean class="org.springframework.data.redis.listener.ChannelTopic">
                            <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

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

监听程序

public class KeyExpiredListener extends JedisPubSub {
    @Override
    public void onPSubscribe(String pattern, int subscribedChannels) {
        System.out.println("onPSubscribe " + pattern + " " + subscribedChannels);
    }

    @Override
    public void onPMessage(String pattern, String channel, String message) {
        System.out.println("onPMessage pattern " + pattern + " " + channel + " " + message);
    }
}

订阅程序

public class Subscriber {
    public static void main(String[] args) {
        JedisPool pool = new JedisPool(new JedisPoolConfig(), "192.168.222.188",6379);
        Jedis jedis = pool.getResource();
        //只订阅patten匹配在超时事件
        jedis.psubscribe(new KeyExpiredListener(), "__key*@0__:expired");
     }
}

测试类

public class TestJedis {
    public static void main(String[] args) {
        JedisPool pool = new JedisPool(new JedisPoolConfig(), "192.168.222.188",6379);
        Jedis jedis = pool.getResource();
        jedis.select(0);
        jedis.set("notify", "你还在吗");
        jedis.expire("notify", 10);

        jedis.select(1);
        jedis.set("test","test");
        jedis.expire("test", 20);
    }
}

先运行订阅程序Subscriber

onPSubscribe __key*@0__:expired 1

再运行测试程序TestJedis,在0库和1库分别放入两个String值,并设置过期时间

Process finished with exit code 0

Subscriber 控制台打印内容

onPSubscribe __key*@0__:expired 1
onPMessage pattern __key*@0__:expired __keyevent@0__:expired notify

说明:
Subscriber 控制台只监 听到了0库的过期事件,因为订阅程序设置了匹配的patten为

__key*@0__:expired

redis数据库分为0-15共16个库,测试程序中jedis.select(n);为选择数据库

上一篇下一篇

猜你喜欢

热点阅读