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


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

回到顶部