网站关键词优化外包服务,多语言网站实现,自己能建设网站,济南标场馆建设有新进展1. 事件通过 Redis 的订阅与发布功能#xff08;pub/sub#xff09;来进行分发,故需要订 阅 __keyevent0__:expired 通道 0表示db0 根据自己的dbindex选择合适的数字 2. 修改 redis.conf 文件 修改 notify-keyspace-events Ex # K 键空间通知#xff0c;以__keyspacepub/sub来进行分发,故需要订 阅 __keyevent0__:expired 通道 0表示db0 根据自己的dbindex选择合适的数字 2. 修改 redis.conf 文件 修改 notify-keyspace-events Ex # K 键空间通知以__keyspacedb__为前缀
# E 键事件通知以__keyseventdb__为前缀
# 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. 首先需要一个消息监听器类 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); }
} 该类需要继承JedisPubSub 并实现其抽象方法通过方法的名称很清楚的看出来这个监听器是用来订阅一个频道在订阅该频道取消订阅收到消息等状态会对应调用相关的方法 2. 订阅测试类 public class TestSubscribe { Test public void testSubscribe() throws Exception{ Jedis jedis new Jedis(localhost); RedisMsgPubSubListener listener new RedisMsgPubSubListener(); jedis.subscribe(listener, __keyevent0__:expired); //other code }
} 该类实现对频道redisChatTest的订阅监听频道的订阅取消订阅收到消息都会调用listener对象的对应方法 注意subscribe是一个阻塞的方法在取消订阅该频道前会一直阻塞在这只有当取消了订阅才会执行下面的other code参考上面代码我在onMessage里面收到消息后调用了this.unsubscribe(); 来取消订阅这样才会执行后面的other code 3. 发布消息测试类 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, 哈哈); }
} 这个类向频道redisChatTest发布消息第二步因为订阅了该频道所以会收到该消息。转载于:https://www.cnblogs.com/chen-lhx/p/6626371.html
