python利用redis实现订阅与发布
服务端:
import redisrc = 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 redisrc = 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