同步订阅
在Redis中，订阅频道时，客户端会一直阻塞等待消息到来。如果频道中没有消息到来，客户端将一直阻塞。这种订阅方式称为同步订阅。
在一些场景下，我们可能需要异步获取订阅频道中的消息，而不是阻塞等待。Redis提供了异步订阅的方式，可以通过以下步骤来实现：
- 使用
SUBSCRIBE channel或PSUBSCRIBE pattern方法订阅频道或模式。 - 创建一个新的连接，使用该连接执行其他命令，而不是在已订阅的连接上执行。
- 在新连接中使用
BRPOP key [key ...] timeout命令在新连接中使用BRPOP key [key ...] timeout命令等待订阅频道中的消息。这里的BRPOP命令可以阻塞等待列表中的元素，当列表中有元素到达时，该命令返回并返回元素的值和键。 - 在新连接中使用
UNSUBSCRIBE [channel [channel ...]]或PUNSUBSCRIBE [pattern [pattern ...]]命令取消订阅频道或模式。
下面是一个异步订阅的示例：
代码语言：javascript复制import redis
import threading
import time
# 创建Redis连接
r1 = redis.Redis(host='localhost', port=6379, db=0)
r2 = redis.Redis(host='localhost', port=6379, db=0)
# 发布消息的方法
def publish_message():
while True:
message = input("Please input your message:")
r1.publish('my_channel', message)
# 异步订阅频道的方法
def subscribe_channel():
p = r2.pubsub()
p.subscribe('my_channel')
while True:
message = p.get_message(timeout=1)
if message:
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()在上面的示例中，我们使用p.get_message(timeout=1)方法等待订阅频道中的消息。如果在1秒内没有收到消息，该方法将返回None。
