Python Redis的订阅和发布

订阅

# 订阅功能终端
>>> import redis
>>> r = redis.Redis()
# 打开订阅功能
>>> sub = r.pubsub()
# 声明订阅的频道
>>> sub.subscribe('fm87.7')
# 开始订阅,第一次会返回一条订阅信息,第二次开始持续订阅
>>> sub.parse_response()
['subscribe', 'fm87.7', 1L]
>>> sub.parse_response() #此时会一直等待数据

发布

打开新的终端,执行发布部分

# 发布功能终端
>>> import redis
>>> r = redis.Redis()
# 指定频道发送数据
>>> r.publish('fm87.7', 'send msg')

执行后,订阅终端会受到发布终端发布信息,如下:

['message', 'fm87.7', 'send msg']

可以将订阅终端使用while循环,进行持续订阅。如下

>>> import redis
>>> r = redis.Redis()
>>> sub = r.pubsub()
>>> sub.subscribe('fm87.7')
>>> while True:
...   sub.parse_response()
...
# 可以持续接受消息。
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,993评论 19 139
  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 173,559评论 25 708
  • 遇到很多问题时,之所以痛苦,是因为现实情况跟以前相比有所变化,不知所措,不能清晰的认识到问题的根结本质所在,
    莉莉俺的路西阅读 370评论 0 0
  • 今天23点熄灯,所以在还在收尾《立项报告》的时候就写日志(:зゝ∠) 目标 单词70(√) 算法导论第三章+第四章...
    Courage_CYY阅读 151评论 0 0
  • 借用前人的例子,曾经询问过学生“《格言录》《青年格言录》《青年励志格言录》你们最想看哪一本?”学生异口同声...
    含山云容阅读 281评论 0 0