码迷,mamicode.com
首页 > Web开发 > 详细

使用redis pub/sub 时间订阅与发布消息

时间:2017-08-09 13:01:07      阅读:281      评论:0      收藏:0      [点我收藏+]

标签:.com   处理   sub   使用   host   地址   channel   image   调用   

import redis
import time

r=redis.StrictRedis(host="127.0.0.1",port=6379)
#你也可以选择使用地址池的方式建立连接

while True:
  if __name__=__main__:
    dis=Get_Distance()
    p=r.publish()
    p.subscribe("first channel") #订阅

    r.publish("first channel",dis) #发布(调用了Get_Distance 函数)
    p.get_message()
    time.sleep(0.5) #在网络状态不佳时,若挂起时间太短则返回值为None
    a=p.get_message()
    print a     

此处我把 public 同 subscribe 放在同一个函数中运行。

测试结果:

技术分享

 

此外,这只是可以读出订阅后收到的消息。程序若要对消息进行处理,则需要使用回调函数。

 

运行环境:

python-2.7

Ubuntu 16.4

使用redis pub/sub 时间订阅与发布消息

标签:.com   处理   sub   使用   host   地址   channel   image   调用   

原文地址:http://www.cnblogs.com/etkmmmfa/p/7324293.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!