下面是一个简单的 Python Redis 处理消息的案例:
import redis
# 连接到 Redis 服务器
r = redis.Redis(host='localhost', port=6379, db=0)
# 发布消息
r.publish('message_channel', 'Hello, Redis!')
# 订阅消息
p = r.pubsub()
p.subscribe('message_channel')
for message in p.listen():
print(message)
以上代码中,首先建立与 Redis 服务器的连接,然后使用 publish
方法向频道 message_channel
发布一条消息。接着使用 pubsub
方法订阅该频道,并通过 listen
方法监听消息。当有新的消息发布到 message_channel
频道时,程序会自动获取并打印该消息。
需要注意的是,Redis 的订阅操作必须在独立的线程中执行,否则会阻塞主线程。如果需要同时处理多个频道的消息,可以在订阅时传入一个列表,如:p.subscribe(['channel1', 'channel2'])
。同时也可以使用 unsubscribe
方法取消订阅。