ZBLOG

python redis 处理消息案例

下面是一个简单的 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 方法取消订阅。

本站部分文章来源于网络,版权归原作者所有,如有侵权请联系站长删除。
转载请注明出处:https://golang.0voice.com/?id=1974

分享:
扫描分享到社交APP
上一篇
下一篇
发表列表
游客 游客
此处应有掌声~
评论列表

还没有评论,快来说点什么吧~

联系我们

在线咨询: 点击这里给我发消息

微信号:3007537140

上班时间: 10:30-22:30

关注我们
x

注册

已经有帐号?