[集群聊天服务器]---- 使用Redis实现发布订阅功能
import redis
# 连接到Redis服务器
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)
# 订阅频道
channel = "chat"
pubsub = redis_client.pubsub()
pubsub.subscribe(channel)
print(f"订阅频道 {channel} 成功，等待消息...")
try:
for message in pubsub.listen():
if message['type'] == 'message':
print(f"接收到消息: {message['data'].decode()}")
except KeyboardInterrupt:
pubsub.unsubscribe(channel)
print(f"取消订阅频道 {channel}")这段代码演示了如何使用redis-py库来订阅一个Redis频道，并在收到消息时进行处理。当运行这段代码时，它会连接到Redis服务器，订阅指定的频道，并打印接收到的消息。按下Ctrl+C可以取消订阅并退出程序。
评论已关闭