redis事件监听

我不是女神ヾ 2022-04-05 11:32 493阅读 0赞

redis自2.8.0之后版本提供[Keyspace Notifications][]功能，允许客户订阅Pub / Sub频道，以便以某种方式接收影响Redis数据集的事件。

> 可能收到的事件的例子如下：  
> 所有影响给定键的命令。  
> 所有接收LPUSH操作的密钥。  
> 所有密钥在数据库中过期0。

因为 Redis 目前的订阅与发布功能采取的是发送即忘（fire and forget）策略， 所以如果你的程序需要可靠事件通知（reliable notification of events）， 那么目前的键空间通知可能并不适合你：当订阅事件的客户端断线时， 它会丢失所有在断线期间分发给它的事件。并不能确保消息送达。未来有计划允许更可靠的事件传递，但可能这将在更一般的层面上解决，或者为Pub / Sub本身带来可靠性，或者允许Lua脚本拦截Pub / Sub消息来执行诸如推送将事件列入清单。

### 事件类型 ###

对于每个修改数据库的操作，键空间通知都会发送两种不同类型的事件消息：keyspace 和 keyevent。以 keyspace 为前缀的频道被称为键空间通知（key-space notification）， 而以 keyevent 为前缀的频道则被称为键事件通知（key-event notification）。

事件是用  __keyspace@DB__:KeyPattern 或者  __keyevent@DB__:OpsType 的格式来发布消息的。
    DB表示在第几个库；KeyPattern则是表示需要监控的键模式（可以用通配符，如：__key*__:*）；OpsType则表示操作类型。因此，如果想要订阅特殊的Key上的事件，应该是订阅keyspace。
    比如说，对 0 号数据库的键 mykey 执行 DEL 命令时， 系统将分发两条消息， 相当于执行以下两个 PUBLISH 命令：
    PUBLISH __keyspace@0__:sampleKey del
    PUBLISH __keyevent@0__:del sampleKey
    订阅第一个频道 __keyspace@0__:mykey 可以接收 0 号数据库中所有修改键 mykey 的事件， 而订阅第二个频道 __keyevent@0__:del 则可以接收 0 号数据库中所有执行 del 命令的键。

### 开启配置 ###

键空间通知通常是不启用的，因为这个过程会产生额外消耗。所以在使用该特性之前，请确认一定是要用这个特性的，然后修改配置文件，或使用config配置。相关配置项如下：

<table> 
 <thead> 
 <tr> 
 <th>字符</th> 
 <th>发送通知</th> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td>K</td> 
 <td>键空间通知，所有通知以 keyspace@ 为前缀，针对Key</td> 
 </tr> 
 <tr> 
 <td>E</td> 
 <td>键事件通知，所有通知以 keyevent@ 为前缀，针对event</td> 
 </tr> 
 <tr> 
 <td>g</td> 
 <td>DEL 、 EXPIRE 、 RENAME 等类型无关的通用命令的通知</td> 
 </tr> 
 <tr> 
 <td>$</td> 
 <td>字符串命令的通知</td> 
 </tr> 
 <tr> 
 <td>l</td> 
 <td>列表命令的通知</td> 
 </tr> 
 <tr> 
 <td>s</td> 
 <td>集合命令的通知</td> 
 </tr> 
 <tr> 
 <td>h</td> 
 <td>哈希命令的通知</td> 
 </tr> 
 <tr> 
 <td>z</td> 
 <td>有序集合命令的通知</td> 
 </tr> 
 <tr> 
 <td>x</td> 
 <td>过期事件：每当有过期键被删除时发送</td> 
 </tr> 
 <tr> 
 <td>e</td> 
 <td>驱逐(evict)事件：每当有键因为 maxmemory 政策而被删除时发送</td> 
 </tr> 
 <tr> 
 <td>A</td> 
 <td>参数 g$lshzxe 的别名，相当于是All</td> 
 </tr> 
 </tbody> 
</table>

输入的参数中至少要有一个 K 或者 E ， 否则的话， 不管其余的参数是什么， 都不会有任何通知被分发。上表中斜体的部分为通用的操作或者事件，而黑体则表示特定数据类型的操作。配置文件中修改 notify-keyspace-events “Kx”，注意：这个双引号是一定要的，否则配置不成功，启动也不报错。例如，“Kx”表示想监控某个Key的失效事件。

也可以通过config配置：CONFIG set notify-keyspace-events Ex （但非持久化）

Redis 使用以下两种方式删除过期的键：
    1.当一个键被访问时，程序会对这个键进行检查，如果键已经过期，那么该键将被删除。
    2.底层系统会在后台查找并删除那些过期的键，从而处理那些已经过期、但是不会被访问到的键。
    当过期键被以上两个程序的任意一个发现、 并且将键从数据库中删除时， Redis 会产生一个 expired 通知。
    Redis 并不保证生存时间（TTL）变为 0 的键会立即被删除： 如果程序没有访问这个过期键， 或者带有生存时间的键非常多的话， 那么在键的生存时间变为 0 ， 直到键真正被删除这中间， 可能会有一段比较显著的时间间隔。
    因此， Redis 产生 expired 通知的时间为过期键被删除的时候， 而不是键的生存时间变为 0 的时候。

由于通知收到的是redis key，value已经过期，无法收到，所以需要在key上标记业务数据。

### 实现步骤： ###

1.修改配置：键空间通知功能耗费CPU，默认关闭，需要修改配置文件redis.conf或 操作CONFIG SET命令，设置notify-keyspace-events选项，来启用或关闭该功能。

2.对Redis实例进行发布订阅，指定监听类和监听事件类型

3.监听类继承JedisPubSub，实现相应操作；

4.客户端进行操作，以触发订阅事件发生。

### 代码实例 ###

<dependency>
 <groupId>redis.clients</groupId>
 <artifactId>jedis</artifactId>
 <version>2.9.0</version>
 </dependency>

redisUtil配置和订阅

public void psubscribe(JedisPubSub jedisPubSub,String pattern) {
 	Jedis jedis = null;
 		try {
 			jedis = jedisPool.getResource();
 			String parameter = "notify-keyspace-events"; 
 			List<String> notify = jedis.configGet(parameter);
 			if("".equals(notify.get(1))){ 
 				jedis.configSet(parameter, "Ex"); 
 			}
 			
 			jedis.psubscribe(jedisPubSub , pattern);
 		} catch (Exception e) {
 			LOGGER.error("redis订阅异常", e);
 		} finally {
 			if (jedis != null) {
 				jedis.close();
 			}
 		}
 }

基于web项目监听类

@Component
    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(
            "pattern = [" + pattern + "], channel = [" + channel + "], message = [" + message + "]");
        //收到消息 key的键值，处理过期提醒
        }
    
        @PostConstruct
        public void init() {
            //不新建线程,会引起web项目启动阻塞
        	new Thread(){
        		public void run(){
        			redisUtil.psubscribe(keyExpiredListener,"__keyevent@15__:expired");
        		}
        	}.start();
        	
        }
    }

本文旨在描述基本实现的一些思路以及和spring-web做集成,相关工具类,并不进行提供,如有需要可以留言!

[Keyspace Notifications]: https://redis.io/topics/notifications