Redis 订阅发布(Pub/Sub) 详解 如何使用订阅发布

Redis 的发布订阅模式（Pub/Sub）允许客户端订阅一个或多个频道，当这些频道有新消息时，订阅者会收到这些消息。

以下是如何使用 Redis 的发布订阅模式的步骤：

1. 订阅频道：客户端可以订阅一个或多个频道。
2. 发布消息：发布者可以向已订阅的频道发送消息。
3. 接收消息：订阅频道的客户端会收到发布的消息。

示例代码（使用 Python 的 redis 库）：

import redis
 
# 连接到 Redis
client = redis.StrictRedis(host='localhost', port=6379, db=0)
 
# 定义订阅者的回调函数
def message_handler(message):
    print(f"Received: {message['data']}")
 
# 创建一个新的订阅者，并订阅 'channel-1'
sub = client.pubsub()
sub.subscribe(**{'channel-1': message_handler})
 
# 在另一个客户端，发布消息到 'channel-1'
client.publish('channel-1', 'Hello, Redis!')
 
# 运行订阅者，开始接收消息
sub.run()

在这个例子中，我们首先连接到 Redis，然后定义了一个回调函数 message_handler 来处理接收到的消息。接着，我们创建了一个订阅者，并订阅了名为 channel-1 的频道。在另一个客户端，我们发布了一条消息到 channel-1。订阅者接收到消息后，调用 message_handler 函数进行处理。