redis发布订阅案例

发布:

import redis

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
conn = redis.Redis(connection_pool=pool)
conn.publish('fm104.5','sb')
发布

订阅1

import redis

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
conn = redis.Redis(connection_pool=pool)
pb = conn.pubsub()
pb.subscribe('fm104.5')

while True:
    msg = pb.parse_response()
    print(msg)
订阅

 相对RabbitMQ较弱

原文地址:https://www.cnblogs.com/catherine007/p/8678559.html