通过python实现Redis的订阅与发布
通过python实现Redis的订阅与发布
Pub/Sub功能（means Publish, Subscribe）即发布及订阅功能。基于事件的系统中，Pub/Sub是目前广泛使用的通信模型，它采用事件作为基本的通信机制，提供大规模系统所要求的松散耦合的交互模式；
订阅者(如客户端)以事件订阅的方式表达出它有兴趣接收的一个事件或一类事件；
发布者(如服务器)可将订阅者感兴趣的事件随时通知相关订阅者。
通俗来讲，就是说我sub端（订阅者）一直监听着，一旦pub端（发布者）发布了消息，那么我就接收过来，举个例子，先是发布者：
前提说明：由于下面才是的redis实例是腾讯云的redis实例，腾讯云Redis 2.8主从版实例的认证方式是实例id:密码的方式；
#coding:utf-8
import redis
host = '10.66.XX.XX'
port = 6379
user='crs-pte25qxx'
pwd='XXXXXX'
number_list = ['300033', '300032', '300031', '300030']
signal = ['1', '-1', '1', '-1']
rc = redis.Strict<a href="http://www.seiang.com/?tag=redis" title="查看更多关于Redis的文章" target="_blank">Redis</a>(host=host, port=port, password=user+':'+pwd)
for i in range(len(number_list)):
value_new = str(number_list[i]) + ' ' + str(signal[i])
rc.publish("wjq", value_new)接着我们来看看订阅者：
#coding:utf-8
import redis
host = '10.66.XX.XX'
port = 6379
user='crs-pte25qxx'
pwd='XXXXXX'
rc = redis.Strict<a href="http://www.seiang.com/?tag=redis" title="查看更多关于Redis的文章" target="_blank">Redis</a>(host=host, port=port, password=user+':'+pwd)
ps = rc.pubsub()
ps.subscribe('wjq')
for item in ps.listen():
if item['type'] == 'message':
print item['channel']
print item['data']注意：这里运行程序的时候先运行订阅者，在运行发布者程序 关于数据结构，也就是item变量，类似于：{‘pattern’: None, ‘type’: ‘message’, ‘channel’: ‘wjq’, ‘data’: ‘3000331’}这样的，所以可以通过channel来判断这个消息是属于哪一个队列里的。
针对上面的代码解释两点： 1、连接方式；使用python连接redis有三种方式： ①使用库中的Redis类（或StrictRedis类，其实差不多）； ②使用ConnectionPool连接池（可保持长连接）； ③使用Sentinel类（如果有多个redis做集群时，程序会自己选择一个合适的连接）。
2、订阅方法；这里使用的是StrictRedis类中的pubsub方法。连接好之后，可使用subscribe或psubscribe方法来订阅redis消息。其中subscribe是订阅一个频道，psubscribe可订阅多个频道（这样写的时候，作为参数的频道应该是一个列表），之后就可以开始监听了
腾讯云开发者
