• 欢迎访问DBA的辛酸事儿,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站
  • 欢迎大家关注博主公众号:DBA的辛酸事儿
  • 博文中若有错误的地方,请大家指正,大家的指正是我前进的动力

通过python实现Redis的订阅与发布

NoSQL数据库 SEian.G 2年前 (2019-03-05) 824次浏览 已收录 0个评论

Redis系列文章请参考:Redis系列文章

在前面的一篇文章中已经介绍了Redis的发布和订阅功能《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可订阅多个频道(这样写的时候,作为参数的频道应该是一个列表),之后就可以开始监听了。通过python实现Redis的订阅与发布

通过python实现Redis的订阅与发布


如果您觉得本站对你有帮助,那么可以收藏和推荐本站,帮助本站更好地发展,在此谢过各位网友的支持。
转载请注明原文链接:通过python实现Redis的订阅与发布
喜欢 (2)
SEian.G
关于作者:
用心去记录工作,用心去感受生活,用心去学着成长;座右铭:苦练七十二变,笑对八十一难
发表我的评论
取消评论
表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

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