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