使用redis pub/sub 时间订阅与发布消息
2021-06-07 19:02
标签:.com 处理 sub 使用 host 地址 channel image 调用 此处我把 public 同 subscribe 放在同一个函数中运行。 测试结果: 此外,这只是可以读出订阅后收到的消息。程序若要对消息进行处理,则需要使用回调函数。 运行环境: python-2.7 Ubuntu 16.4 使用redis pub/sub 时间订阅与发布消息 标签:.com 处理 sub 使用 host 地址 channel image 调用 原文地址:http://www.cnblogs.com/etkmmmfa/p/7324293.htmlimport 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
文章标题:使用redis pub/sub 时间订阅与发布消息
文章链接:http://soscw.com/index.php/essay/91867.html