redis 超时失效key的监听触发和事件监听
2018-02-09 17:08
537 查看
转载:
redis 超时失效key 的监听触发
Redis 事件监听
Redis 发布订阅
1、事件通过 Redis 的订阅与发布功能(pub/sub)来进行分发,故需要订
阅
0表示db0根据自己的dbindex选择合适的数字
2、修改 redis.conf 文件
修改
3、重启redis , 即可测试失效事件的触发, 监听获取的值为 key
java实现:
1.首先需要一个消息监听器类
该类需要继承JedisPubSub ,并实现其抽象方法,通过方法的名称很清楚的看出来,这个监听器是用来订阅一个频道,在订阅该频道,取消订阅,收到消息等状态会对应调用相关的方法
2、订阅测试类(or 启一个异步线程去设置监听器)
该类实现对频道redisChatTest的订阅监听,频道的订阅,取消订阅,收到消息都会调用listener对象的对应方法
注意:subscribe是一个阻塞的方法,在取消订阅该频道前,会一直阻塞在这,只有当取消了订阅才会执行下面的other code,参考上面代码,我在onMessage里面收到消息后,调用了this.unsubscribe(); 来取消订阅,这样才会执行后面的other code
3、发布消息测试类
这个类向频道redisChatTest发布消息,第二步因为订阅了该频道,所以会收到该消息。
redis 超时失效key 的监听触发
Redis 事件监听
Redis 发布订阅
1、事件通过 Redis 的订阅与发布功能(pub/sub)来进行分发,故需要订
阅
__keyevent@0__:expired通道,
0表示db0根据自己的dbindex选择合适的数字
2、修改 redis.conf 文件
修改
notify-keyspace-events Ex
# 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”意味着所有的事件
3、重启redis , 即可测试失效事件的触发, 监听获取的值为 key
java实现:
1.首先需要一个消息监听器类
该类需要继承JedisPubSub ,并实现其抽象方法,通过方法的名称很清楚的看出来,这个监听器是用来订阅一个频道,在订阅该频道,取消订阅,收到消息等状态会对应调用相关的方法
package com.sogou.baike.testimport.testSubscribe; import redis.clients.jedis.JedisPubSub; /** * Created by denglinjie on 2016/6/29. */ public class RedisMsgPubSubListener extends JedisPubSub { @Override public void unsubscribe() { super.unsubscribe(); } @Override public void unsubscribe(String... channels) { super.unsubscribe(channels); } @Override public void subscribe(String... channels) { super.subscribe(channels); } @Override public void psubscribe(String... patterns) { super.psubscribe(patterns); } @Override public void punsubscribe() { super.punsubscribe(); } @Override public void punsubscribe(String... patterns) { super.punsubscribe(patterns); } @Override public void onMessage(String channel, String message) { System.out.println("channel:" + channel + "receives message :" + message); this.unsubscribe(); } @Override public void onPMessage(String pattern, String channel, String message) { } @Override public void onSubscribe(String channel, int subscribedChannels) { System.out.println("channel:" + channel + "is been subscribed:" + subscribedChannels); } @Override public void onPUnsubscribe(String pattern, int subscribedChannels) { } @Override public void onPSubscribe(String pattern, int subscribedChannels) { } @Override public void onUnsubscribe(String channel, int subscribedChannels) { System.out.println("channel:" + channel + "is been unsubscribed:" + subscribedChannels); } }
2、订阅测试类(or 启一个异步线程去设置监听器)
该类实现对频道redisChatTest的订阅监听,频道的订阅,取消订阅,收到消息都会调用listener对象的对应方法
public class TestSubscribe { @Test public void testSubscribe() throws Exception{ Jedis jedis = new Jedis("localhost"); RedisMsgPubSubListener listener = new RedisMsgPubSubListener(); jedis.subscribe(listener, "__keyevent@0__:expired"); //other code } }
注意:subscribe是一个阻塞的方法,在取消订阅该频道前,会一直阻塞在这,只有当取消了订阅才会执行下面的other code,参考上面代码,我在onMessage里面收到消息后,调用了this.unsubscribe(); 来取消订阅,这样才会执行后面的other code
3、发布消息测试类
这个类向频道redisChatTest发布消息,第二步因为订阅了该频道,所以会收到该消息。
Public class TestPublish { @Test public void testPublish() throws Exception{ Jedis jedis = new Jedis("localhost"); jedis.publish("redisChatTest", "我是天才"); Thread.sleep(5000); jedis.publish("redisChatTest", "我牛逼"); Thread.sleep(5000); jedis.publish("redisChatTest", "哈哈"); } }
相关文章推荐
- JAVA实现redis超时失效key 的监听触发
- JAVA实现redis超时失效key 的监听触发
- redis 超时失效key 的监听触发
- redis 超时失效key 的监听触发
- redis 超时失效key 的监听触发
- springboot实现监听redis key失效事件
- 监听session,在其失效时触发事件
- js监听鼠标键盘动作,超时不动作触发相应动作
- Session超时后的事件监听处理
- 关于select 被选中触发事件,onclick事件失效问题
- jquery触发select的change事件失效
- c# 与java 相同实现 自定义事件的触发及监听
- HTML5:百度地图手机端单触点单击和长按事件,解决部分手机点地图击失效,多触点、拖动依然触发长按的bug
- javafx 可监听list的setAll方法 不触发监听事件
- 动态添加的元素,设置监听事件;input:text事件只触发一次
- nodejs事件的监听与触发的理解分析
- tomcat触发ServletContext初始化监听事件的源码(原创)
- 项目学习——后台事件监听并触发相应操作
- js监听Enter事件的触发进行查找
- 监听input text中内容发生变化时触发事件