Redis 发布订阅

简介

Redis的发布订阅（Pub/Sub）功能允许客户端订阅一个或多个频道，当某个频道有消息发布时，订阅该频道的客户端会收到相应的消息。发布订阅模式在实际应用中被广泛应用，比如在聊天室、实时数据推送、通知等场景下都可以使用发布订阅模式实现。

发布订阅模式的基本概念

在Redis中，发布订阅模式涉及到以下几个基本概念：

• 发布者（Publisher）：发布消息的客户端
• 频道（Channel）：一种消息分类的方式，发布者可以将消息发布到一个或多个频道中
• 订阅者（Subscriber）：订阅频道的客户端
• 消息（Message）：发布者发布到频道中的消息

发布订阅模式的实现

Redis的发布订阅模式通过以下命令实现：

• SUBSCRIBE channel [channel ...]：订阅一个或多个频道，订阅者将收到所有在订阅的频道发布的消息
• UNSUBSCRIBE [channel [channel ...]]：取消订阅一个或多个频道
• PUBLISH channel message：将消息发布到指定的频道中，所有订阅该频道的客户端都会收到该消息

发布订阅模式的示例

下面是一个简单的发布订阅模式的示例：

import redis
import threading

# 创建Redis连接
r = redis.Redis(host='localhost', port=6379, db=0)

# 发布消息的方法
def publish_message():
    while True:
        message = input("Please input your message:")
        r.publish('my_channel', message)

# 订阅频道的方法
def subscribe_channel():
    p = r.pubsub()
    p.subscribe('my_channel')
    for message in p.listen():
        print(f"Received message: {message['data'].decode('utf-8')}")

# 启动两个线程，一个用于发布消息，一个用于订阅频道
if __name__ == '__main__':
    t1 = threading.Thread(target=publish_message)
    t2 = threading.Thread(target=subscribe_channel)
    t1.start()
    t2.start()

在上面的示例中，我们首先创建了一个名为my_channel的频道，然后创建了两个线程，一个用于发布消息，一个用于订阅频道。在发布消息的线程中，我们使用r.publish方法将消息发布到my_channel频道中。在订阅频道的线程中，我们首先使用r.pubsub方法创建一个PubSub对象，然后使用p.subscribe方法订阅my_channel频道，并使用p.listen方法获取频道中的消息，然后将消息打印到控制台中。