python实现发布订阅

订阅者：

import redis
rc = redis.StrictRedis(host=‘127.0.0.1‘, port=‘6379‘, db=0)
ps = rc.pubsub()
ps.subscribe(‘lbky‘)  # 从lbky订阅消息
for item in ps.listen():  # 监听状态：有消息发布了就拿过来
    print(item)
    if item[‘type‘] == ‘message‘:
        print(item[‘channel‘],item[‘data‘])
发布者：

import redis
number_list = [‘a‘, ‘b‘, ‘c‘, ‘d‘]
signal = [‘A‘, ‘B‘, ‘C‘, ‘D‘]

rc = redis.StrictRedis(host=‘127.0.0.1‘, port=‘6379‘, db=0)
for i in range(len(number_list)):
    value_new = str(number_list[i]) + ‘ ‘ + str(signal[i])
    rc.publish("lbky", value_new)  # 发布消息到lbky

python实现发布订阅

原文：https://www.cnblogs.com/llbky/p/11378326.html