Redis发布订阅
Redis 提供了发布/订阅功能,允许客户端订阅一个或多个频道,当这些频道有消息发布时,订阅的客户端会收到消息。
以下是使用 Redis 发布订阅功能的 Python 示例代码:
发布消息:
import redis
# 连接到 Redis
r = redis.Redis(host='localhost', port=6379, db=0)
# 发布消息到频道 'channel1'
r.publish('channel1', 'Hello, World!')
订阅消息:
import redis
# 连接到 Redis
r = redis.Redis(host='localhost', port=6379, db=0)
# 创建一个发布订阅对象
pubsub = r.pubsub()
# 订阅频道 'channel1'
pubsub.subscribe('channel1')
# 监听订阅的频道,打印接收到的消息
for message in pubsub.listen():
print(message)
运行订阅代码后,如果有其他客户端向同一频道发布消息,订阅的客户端将会收到消息。每当有新消息发布到 'channel1',订阅的客户端会打印出消息的内容。
评论已关闭