使用Python连接redis(redis作MQ使用)

1、安装redis Python客户端
easy_install.exe redis

2、启动redis

sudo redis-server

3、编写接收端

import redis
rc = redis.Redis(host='mt.ematchina.com')

ps = rc.pubsub()

ps.subscribe(['foo', 'bar'])

#rc.publish('foo', 'hello world')

for item in ps.listen():

if item['type'] == 'message':

# print item['channel']

print item['data']

4、编写发送端

import redis

rc = redis.Redis(host='mt.ematchina.com')

ps = rc.pubsub()

ps.subscribe(['foo', 'bar'])

rc.publish('foo', 'hello world')

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。