python中sub-pub机制实现Redis的订阅与发布
更新时间：2023年03月28日 15:04:23 作者：猪笨是念来过倒
本文主要介绍了python中sub-pub机制实现Redis的订阅与发布，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
先介绍一下redis的pub/sub功能：
Pub/Sub功能（means Publish, Subscribe）即发布及订阅功能。基于事件的系统中，Pub/Sub是目前广泛使用的通信模型，它采用事件作为基本的通信机制，提供大规模系统所要求的松散耦合的交互模式：订阅者(如客户端)以事件订阅的方式表达出它有兴趣接收的一个事件或一类事件；发布者(如服务器)可将订阅者感兴趣的事件随时通知相关订阅者。
通俗来讲，就是说我sub端（订阅者）一直监听着，一旦pub端（发布者）发布了消息，那么我就接收过来，举个例子，先是发布者：
#coding:utf-8
import time
import redis
number_list = ['300033', '300032', '300031', '300030']
signal = ['1', '-1', '1', '-1']
rc = redis.StrictRedis(host='***', port='6379', db=3, password='********')
for i in range(len(number_list)):
value_new = str(number_list[i]) + ' ' + str(signal[i])
rc.publish("liao", value_new) #发布消息到liao
接着我们来看看订阅者：
#coding:utf-8
import time
import redis
rc = redis.StrictRedis(host='****', port='6379', db=3, password='******')
ps = rc.pubsub()
ps.subscribe('liao') #从liao订阅消息
for item in ps.listen(): #监听状态：有消息发布了就拿过来
if item['type'] == 'message':
print item['channel']
print item['data']
关于数据结构，也就是item，是类似于：{'pattern': None, 'type': 'message', 'channel': 'liao', 'data': '300033 1'}这样的，所以可以通过channel来判断这个消息是属于哪一个队列里的。（运行程序的时候，先运行订阅者，在运行发布者程序）
总结，要点有两个：
- 一是连接方式。使用python连接redis有三种方式：①使用库中的Redis类（或StrictRedis类，其实差不多）；②使用ConnectionPool连接池（可保持长连接）；③使用Sentinel类（如果有多个redis做集群时，程序会自己选择一个合适的连接）。
- 二是订阅方法。这里使用的是StrictRedis类中的pubsub方法。连接好之后，可使用subscribe或psubscribe方法来订阅redis消息。其中subscribe是订阅一个频道，psubscribe可订阅多个频道（这样写的时候，作为参数的频道应该是一个列表）。之后就可以开始监听了。
到此这篇关于python中sub-pub机制实现Redis的订阅与发布 的文章就介绍到这了,更多相关python Redis的订阅与发布 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了Python中除法使用的注意事项,是Python程序设计很重要的技巧,需要的朋友可以参考下2014-08-08
这篇文章主要介绍了Python调用http-post接口的实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-08-08
这篇文章主要介绍了Python面向对象之继承和多态用法,结合实例形式分析了Python面向对象程序设计中继承与多态的原理及相关操作技巧,需要的朋友可以参考下2019-06-06
VGG16是Visual Geometry Group的缩写,它的名字来源于提出该网络的实验室,本文我们将使用PyTorch来实现VGG16网络,用于猫狗预测的二分类任务,我们将对VGG16的网络结构进行适当的修改,以适应我们的任务,需要的朋友可以参考下2023-08-08
这篇文章主要为大家详细介绍了python基于物品协同过滤算法实现代码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-05-05
基于文件路径中/ \ // \\的用法以及绝对相对路径的问题
这篇文章主要介绍了基于文件路径中/ \ // \\的用法以及绝对相对路径的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-02-02
这篇文章主要介绍了python2 对excel表格操作,结合完整实例形式分析了Python2 操作Excel表格的读取、写入相关操作技巧,需要的朋友可以参考下2020-02-02
下面小编就为大家带来一篇python引入导入自定义模块和外部文件的实例。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-07-07
这篇文章主要介绍了使用Python实现汉诺塔问题示例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-04-04
最近需要在后台运行脚本，本文主要介绍了Python脚本后台运行的五种方式，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-02-02
最新评论