Redis 事件相关

事件

Redis 提供了几种事件类型可以监听，主要通过 Redis 通知系统来实现。这些通知事件可以通过订阅 Redis 频道来接收。常见的 Redis 事件监听主要有以下几类：

1. 键空间通知（Keyspace Notifications）

这些通知会在 Redis 中对键进行操作时触发，如键的设置、删除、过期等。你可以配置监听以下几种操作：

set：当键被设置时触发。
del：当键被删除时触发。
expire：当键的过期时间到期时触发。
evicted：当键被驱逐时触发。
rename：当键被重命名时触发。
ttl：当键的 TTL（过期时间）发生变化时触发。
配置键空间通知时，你可以通过设置 notify-keyspace-events 配置项来定义需要监听的事件类型。例如：

redis-server --notify-keyspace-events Ex

2. 自定义事件

Redis 允许你通过 PUBLISH 命令发布和 SUBSCRIBE 命令订阅自定义消息事件。这是 Redis 内置的发布 - 订阅模式，用于实时消息传递和事件通知。

subscribe：订阅消息频道。
publish：向频道发布消息。
psubscribe：通过模式订阅频道。
punsubscribe：取消模式订阅。
这种方式主要用于实现事件广播和消息队列。

3. 慢查询事件（Slow Log）

Redis 会记录慢查询，用户可以通过查询 SLOWLOG 来获取执行时间较长的命令。当某些命令执行超过设定的时间阈值时，会记录为慢查询事件。

SLOWLOG：可以查询慢查询日志，了解哪些命令耗时较长。

4. 事务事件（Transaction Events）

Redis 的事务通过 MULTI、EXEC、WATCH 等命令来执行原子操作，事务操作的开始和提交等事件可以通过相应的命令返回值和日志进行监听。

5. Redis 连接/断开事件（Connection Events）

Redis 还提供了一些连接相关的事件，如客户端连接、断开、认证等。虽然这些事件不像键空间事件那样直接暴露，但可以通过监控 Redis 的日志、使用 CLIENT 命令等方式来间接获取。

配置键空间通知的示例

要开启键空间通知，可以在 Redis 配置文件 redis.conf 中设置：

notify-keyspace-events Ex

或者动态设置：

CONFIG SET notify-keyspace-events Ex

其中：

E 表示键过期事件。
x 表示键删除事件。
然后，你可以通过订阅相应的频道来接收这些事件。例如，订阅键过期事件：

PSUBSCRIBE __keyevent@0__:expired

总结

Redis 提供了灵活的事件监听机制，可以用于实现高效的缓存失效策略、数据同步、消息通知等功能。如果你有具体的应用场景，可以进一步根据需要配置和使用这些事件监听。

实践

自定义事件

1. Jedis 库的使用

首先，你需要在 Java 项目中添加 Jedis 依赖。如果使用 Maven，可以在 pom.xml 中加入以下依赖：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>4.2.3</version> <!-- 请根据需要调整版本 -->
</dependency>

2. 发布事件（PUBLISH）

要向 Redis 发布消息，你可以使用 Jedis 的 publish 方法。以下是一个简单的示例：

import redis.clients.jedis.Jedis;

public class RedisPublisher {
    public static void main(String[] args) {
        // 创建一个 Jedis 连接
        try (Jedis jedis = new Jedis("localhost", 6379)) {
            // 发布消息到 "mychannel" 频道
            String channel = "mychannel";
            String message = "Hello, Redis!";
            jedis.publish(channel, message);
            System.out.println("消息已发布: " + message);
        }
    }
}

在这个示例中，publish 方法将消息发送到指定的频道 "mychannel"。

要订阅 Redis 频道并监听事件，你可以使用 Jedis 的 subscribe 方法。下面是一个订阅事件的示例：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class RedisSubscriber {
    public static void main(String[] args) {
        // 创建一个 Jedis 连接
        try (Jedis jedis = new Jedis("localhost", 6379)) {
            // 创建一个 JedisPubSub 实例，重写 message 方法来处理接收到的消息
            JedisPubSub jedisPubSub = new JedisPubSub() {
                @Override
                public void onMessage(String channel, String message) {
                    System.out.println("收到消息: " + message + " 来自频道: " + channel);
                }
            };

            // 订阅 "mychannel" 频道
            System.out.println("等待接收消息...");
            jedis.subscribe(jedisPubSub, "mychannel");
        }
    }
}

在这个示例中，JedisPubSub 是一个回调类，你可以重写 onMessage 方法来处理接收到的消息。subscribe 方法会阻塞线程，直到收到发布的消息。

4. 异步订阅

如果你想实现异步订阅，避免阻塞主线程，可以将订阅操作放到一个单独的线程中。例如：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class RedisAsyncSubscriber {
    public static void main(String[] args) {
        // 创建一个新线程来进行订阅
        new Thread(() -> {
            try (Jedis jedis = new Jedis("localhost", 6379)) {
                // 创建一个 JedisPubSub 实例，处理接收到的消息
                JedisPubSub jedisPubSub = new JedisPubSub() {
                    @Override
                    public void onMessage(String channel, String message) {
                        System.out.println("异步接收到消息: " + message + " 来自频道: " + channel);
                    }
                };

                // 订阅 "mychannel" 频道
                jedis.subscribe(jedisPubSub, "mychannel");
            }
        }).start();

        System.out.println("订阅已启动...");
    }
}

在这个示例中，我们通过启动一个新线程来进行订阅操作，从而不阻塞主线程。

5. 键空间通知（Keyspace Notifications）

如果你想监听 Redis 键空间事件（如键的过期、删除等），你可以设置 notify-keyspace-events 参数并使用订阅来接收这些事件。以下是一个监听过期事件的例子：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class RedisKeyspaceNotification {
    public static void main(String[] args) {
        try (Jedis jedis = new Jedis("localhost", 6379)) {
            // 订阅键空间过期事件
            JedisPubSub jedisPubSub = new JedisPubSub() {
                @Override
                public void onMessage(String channel, String message) {
                    System.out.println("键过期事件: " + message + " 来自频道: " + channel);
                }
            };

            // 订阅键空间过期事件频道
            jedis.subscribe(jedisPubSub, "__keyevent@0__:expired");
        }
    }
}

在这个例子中，__keyevent@0__:expired 是监听键过期事件的频道。当某个键在数据库 0 中过期时，订阅者会收到通知。

6. 配置 Redis 启用键空间通知

要启用键空间通知，你需要确保 Redis 配置文件中启用了该功能，或者动态配置。你可以在 Redis 配置文件中设置：

notify-keyspace-events Ex

或者使用命令动态设置：

CONFIG SET notify-keyspace-events Ex