服务端: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已取消订阅’