H5W3
当前位置:H5W3 > python > 正文

python利用redis实现订阅与发布

服务端:

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已取消订阅’

本文地址:H5W3 » python利用redis实现订阅与发布

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址