首页 > 代码库 > 使用redis pub/sub 时间订阅与发布消息
使用redis pub/sub 时间订阅与发布消息
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 时间订阅与发布消息
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。