Wie SpringBoot Redis-Schlüsseländerungsereignisse überwacht

1. Funktionsübersicht

Mit der Keyspace-Benachrichtigung kann der Client Ereignisse empfangen, die den Redis-Schlüssel auf irgendeine Weise ändern, indem er den Kanal oder Modus abonniert.

Alle Befehle zum Ändern von Schlüsseltasten.

Alle Schlüssel, die den Befehl LPUSH-Schlüsselwert [value …] erhalten.

Alle abgelaufenen Schlüssel in der Datenbankdatenbank.

Ereignisse werden über die Abonnement- und Veröffentlichungsfunktionen (Pub/Sub) von Redis verteilt, sodass alle Clients, die die Abonnement- und Veröffentlichungsfunktionen unterstützen, die Keyspace-Benachrichtigungsfunktion direkt verwenden können, ohne Änderungen vorzunehmen.

Da die aktuellen Abonnement- und Veröffentlichungsfunktionen von Redis eine Fire-and-Forget-Strategie verfolgen, ist die aktuelle Schlüsselbereichsbenachrichtigung möglicherweise nicht für Sie geeignet, wenn Ihr Programm eine zuverlässige Benachrichtigung über Ereignisse erfordert: Wenn ein Client Ereignisse abonniert, wird die Verbindung getrennt verliert alle während der Verbindungstrennung an ihn verteilten Ereignisse.

In Zukunft wird eine zuverlässigere Ereignisverteilung unterstützt. Diese Unterstützung kann erreicht werden, indem die Abonnement- und Veröffentlichungsfunktionen selbst zuverlässiger gemacht werden oder indem das Abonnement und die Veröffentlichung von Nachrichten in Lua-Skripten überwacht werden eine Liste.

2. Ereignistypen

Für jeden Vorgang, der die Datenbank ändert, senden Keyspace-Benachrichtigungen zwei verschiedene Arten von Ereignissen.

Wenn Sie beispielsweise den Befehl DEL key [key …] auf der Taste mykey der Datenbank Nr. 0 ausführen, wird das System dies tun Verteilen Sie zwei Nachrichten, was dem Ausführen der folgenden zwei PUBLISH-Kanalnachricht-Befehle entspricht: 0 号数据库的键 mykey 执行 DEL key [key …]命令时， 系统将分发两条消息， 相当于执行以下两个 PUBLISH channel message 命令：

PUBLISH __keyspace@0__:mykey del
PUBLISH __keyevent@0__:del mykey

订阅第一个频道 __keyspace@0__:mykey 可以接收 0 号数据库中所有修改键 mykey 的事件， 而订阅第二个频道 __keyevent@0__:del则可以接收 0 号数据库中所有执行 del 命令的键。

以 keyspace 为前缀的频道被称为键空间通知（key-space notification）， 而以 keyevent 为前缀的频道则被称为键事件通知（key-event notification）。

当 del mykey 命令执行时:

• 键空间频道的订阅者将接收到被执行的事件的名字，在这个例子中，就是 del 。

• 键事件频道的订阅者将接收到被执行事件的键的名字，在这个例子中，就是 mykey 。

三、配置

因为开启键空间通知功能需要消耗一些 CPU ， 所以在默认配置下， 该功能处于关闭状态。

可以通过修改 redis.conf 文件， 或者直接使用 CONFIG SET 命令来开启或关闭键空间通知功能：

当 notify-keyspace-events 选项的参数为空字符串时，功能关闭。

另一方面，当参数不是空字符串时，功能开启。

notify-keyspace-events 的参数可以是以下字符的任意组合， 它指定了服务器该发送哪些类型的通知：

输入的参数中至少要有一个 K或者 E ， 否则的话， 不管其余的参数是什么， 都不会有任何通知被分发。

举个例子， 如果只想订阅键空间中和列表相关的通知， 那么参数就应该设为 Kl ， 诸如此类。

将参数设为字符串"AKE" 表示发送所有类型的通知。

每当一个键因为过期而被删除时，产生一个 expired 通知。

每当一个键因为maxmemory政策而被删除以回收内存时，产生一个 evicted 通知。

所有命令都只在键真的被改动了之后，才会产生通知。

比如说，当 SREM key member [member …]

config set notify-keyspace-events KEA

Das Abonnieren des ersten Kanals __keyspace@0__:mykey kann Ereignisse aller geänderten Schlüssel mykey in der Datenbank Nr. 0 empfangen, und Abonnieren des zweiten Kanals Ein Kanal __keyevent@0__:del kann alle Schlüssel empfangen, die den del-Befehl in der Datenbank Nr. 0 ausführen.

Kanäle mit dem Präfix „keyspace“ werden als Key-Space-Benachrichtigungen bezeichnet, und Kanäle mit dem Präfix „keyevent“ werden als Key-Event-Benachrichtigungen bezeichnet.

Wenn der Befehl del mykey ausgeführt wird:

• Abonnenten des Keyspace-Kanals erhalten den Namen des Ereignisses, das ausgeführt wurde, in diesem Fall del .

• Abonnenten des Schlüsselereigniskanals erhalten den Namen des Schlüssels, auf dem das Ereignis ausgeführt wurde, in diesem Fall mykey .
  

3. Konfiguration

Da das Einschalten der Tastenraum-Benachrichtigungsfunktion etwas CPU erfordert, ist diese Funktion in der Standardkonfiguration deaktiviert.

🎜Sie können die Keyspace-Benachrichtigungsfunktion aktivieren oder deaktivieren, indem Sie die Datei redis.conf ändern oder direkt den Befehl CONFIG SET verwenden: 🎜🎜Wenn der Parameter der Option notify-keyspace-events eine leere Zeichenfolge ist, wird die Funktion aktiviert aus. 🎜🎜Wenn der Parameter hingegen keine leere Zeichenfolge ist, ist die Funktion aktiviert. Die Parameter von 🎜🎜notify-keyspace-events können eine beliebige Kombination der folgenden Zeichen sein, die angeben, welche Arten von Benachrichtigungen der Server senden soll: 🎜🎜🎜🎜Die Eingabeparameter müssen mindestens einen K oder E</ haben Code> Andernfalls wird unabhängig von den übrigen Parametern keine Benachrichtigung zugestellt. 🎜🎜Wenn Sie beispielsweise nur Benachrichtigungen abonnieren möchten, die sich auf Listen im Schlüsselraum beziehen, sollte der Parameter auf <code>Kl usw. gesetzt werden. 🎜🎜Setzen Sie den Parameter auf die Zeichenfolge "AKE", um das Senden aller Arten von Benachrichtigungen anzugeben. 🎜🎜🎜 Immer wenn ein Schlüssel aufgrund von Ablauf gelöscht wird, wird eine Benachrichtigung abgelaufen generiert. 🎜🎜Generieren Sie eine evicted-Benachrichtigung, wenn ein Schlüssel aufgrund der maxmemory-Richtlinie gelöscht wird, um Speicher zurückzugewinnen. 🎜🎜🎜Alle Befehle generieren erst dann Benachrichtigungen, wenn der Schlüssel tatsächlich geändert wurde. 🎜🎜Wenn beispielsweise SREM-Schlüsselmitglied [member …] versucht, ein Element zu löschen, das nicht in der Sammlung vorhanden ist, schlägt der Löschvorgang fehl, da keine wirkliche Änderung am Schlüssel erfolgt Bei diesem Vorgang wird keine Benachrichtigung gesendet. 🎜🎜Wenn Sie Fragen zu der durch den Befehl generierten Benachrichtigung haben, verwenden Sie am besten den folgenden Befehl, um diese selbst zu überprüfen: 🎜🎜Redis verwendet die folgenden zwei Methoden, um abgelaufene Schlüssel zu löschen: 🎜🎜🎜Wenn auf einen Schlüssel zugegriffen wird, Das Programm überprüft diesen Schlüssel und wenn er abgelaufen ist, wird er gelöscht. 🎜🎜Das zugrunde liegende System sucht und löscht nach und nach abgelaufene Schlüssel im Hintergrund, um Schlüssel zu verarbeiten, die abgelaufen sind, auf die aber nicht zugegriffen werden kann. 🎜Wenn eines der beiden oben genannten Programme einen abgelaufenen Schlüssel entdeckt und der Schlüssel aus der Datenbank gelöscht wird, generiert Redis eine Benachrichtigung über den Ablauf. 🎜🎜🎜Redis garantiert nicht, dass ein Schlüssel, dessen TTL 0 wird, sofort gelöscht wird: Wenn das Programm nicht auf den abgelaufenen Schlüssel zugreift oder zu viele Schlüssel mit einem TTL vorhanden sind, wird der TTL des Schlüssels 0. Möglicherweise wird dies der Fall sein Es kann eine beträchtliche Zeitspanne dauern, bis der Schlüssel tatsächlich gelöscht wird. 🎜

因此， Redis 产生expired通知的时间为过期键被删除的时候， 而不是键的生存时间变为 0 的时候。

三、案例

按上文内容，我们先将redis的键空间通知开启,我们开启所有的通知，在可以端中测试后没问题再到代码中测试。

连接到redis 输入一下命令

config set notify-keyspace-events KEA

订阅键空间和键事件的主题

psubscribe '__key*__:*'#对所有库键空间通知
 
psubscribe '__keyspace@2__:*' #是对db2数据库键空间通知
 
psubscribe '__keyspace@2__:order*' #是对db2数据库，key前缀为order所有键的键空间通知

创建一个 key :name valus:zhangsan

set name wsl

观察订阅的窗口 会受到两个消息，第一个是：键空间 第二个是键事件，键空间是内容是操作指令，主题中包含有key，键事件主题中包含了指令，内容是key。

到这里说明已经开启了键空间通知

代码

以下代码采用string类型演示

在配置一下MessageListenerContainer类，将我们写好的监听类添加到该类中即可,删除和过期都是需要添加，我这里就一起添加了后面就不做演示。

@Configuration
public class RedisConfig {
 
    @Autowired
    private RedisTemplate redisTemplate;
 
    @Autowired
    private RedisUpdateAndAddListener redisUpdateAndAddListener;
 
    @Autowired
    private RedisDeleteListener redisDeleteListener;
 
    @Autowired
    private RedisExpiredListener redisExpiredListener;
 
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        //监听所有的key的set事件
        container.addMessageListener(redisUpdateAndAddListener, redisUpdateAndAddListener.getTopic());
        //监听所有key的删除事件
        container.addMessageListener(redisDeleteListener,redisDeleteListener.getTopic());
        //监听所有key的过期事件
        container.addMessageListener(redisExpiredListener,redisExpiredListener.getTopic());
        return container;
    }
 
 
}

新增和修改都是set指令

所以监听的主题都一样,实现MessageListener接口，重写onMessage这里就是收到消息的处理逻辑

@Component
@Data
public class RedisUpdateAndAddListener implements MessageListener {
	//监听的主题
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:set");
 
    @Override
    public void onMessage(Message message,byte[] pattern){
        String topic = new String(pattern);
        String msg = new String(message.getBody());
        System.out.println("收到key更新或修改，消息主题是："+ topic+",消息内容是："+msg);
    }
 
}

在redis中对name这个key进行set操作

set name wsl

在控制台就可以看到name这个key被操作了

删除

跟上面的更新监听一样，只需要把订阅主题更改一下即可。同样需要添加到这个RedisMessageListenerContainer，上面已经添加，这里不做演示

@Component
@Data
public class RedisDeleteListener implements MessageListener {
 
    //监听主题
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:del");
 
    /**
     *
     * @param message 消息
     * @param pattern 主题
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String topic = new String(pattern);
        String msg = new String(message.getBody());
        System.out.println("收到key的删除，消息主题是："+ topic+",消息内容是："+msg);
    }
}

在redis输入命令，del name 在控制台可以看到已经收到消息了。

过期

如上面的操作方式一样

@Data
@Component
public class RedisExpiredListener implements MessageListener {
 
    //监听主题
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:expired");
 
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String topic = new String(pattern);
        String msg = new String(message.getBody());
        System.out.println("收到key的过期，消息主题是："+ topic+",消息内容是："+msg);
    }
}

 在redis中写一个定时删除的keySETEX age 18 3三秒后就可以控制台打印了相关信息

Das obige ist der detaillierte Inhalt vonWie SpringBoot Redis-Schlüsseländerungsereignisse überwacht. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!