python利用redis实现订阅与发布

• H5W3
• 2021-02-21 18:55:16

服务端：

import redis
rc = redis.Redis(host = '127.0.0.1')
ps = rc.pubsub()
ps.subscribe(['sub1', 'sub2'])
while True:
    input = raw_input("publish:")
    if input == 'over':
        print '停止发布'
    rc.publish('sub1', input)
    rc.publish('sub2', input)

客户端：

import redis
rc = redis.Redis(host = '127.0.0.1')
ps = rc.pubsub()
ps.subscribe(['sub1', 'sub2'])
for item in ps.listen():
    if item['type'] == 'message':
        data = item['data']
    if item['data'] == 'over':
        ps.unsubscribe('sub1')
        print ‘sub1已取消订阅’

以上是 python利用redis实现订阅与发布 的全部内容， 来源链接： www.h5w3.com/116121.html