redis 发布订阅示例
在启动好redis后,我打开两个终端作为两个客户端
左边的客户端输入:
SUBSCRIBE channel1
表示左边的客户端订阅了channel1的频道,当有人在channel1中发信息左边的客户端都会收到
现在右边的客户端通过如下指令向channel1中发送一个hello,可以看到左边客户端立刻收到了hello。
publish channel1 hello
python 代码 :
dingyue.py
import redis
class RedisSubscri():def __init__(self,host,port):self.coon=redis.Redis(host="10.0.6.81",port=6379)def publish(self,message,channel):#发布self.coon.publish(channel,message)def subscribe(self,channel):#订阅pub=self.coon.pubsub()pub.subscribe(channel)pub.parse_response()return pubdef unsubsceribe(self,channel):#取消订阅self.coon.pubsub().unsubscribe(channel)
发布端:
from redisPublishSubscribe.dingyue import RedisSubscriredisd=RedisSubscri(host='10.0.6.81',port=6379)
n = "channel1"
m = "hello"
# m = "取消订阅"
redisd.publish(m,n) # m为发布的信息,n为发布的频道
订阅端:
from redisPublishSubscribe.dingyue import RedisSubscri
if __name__=="__main__":resad = RedisSubscri(host='10.0.6.81',port=6379)subscribe_channel = "channel1" # 订阅的频道名称meaaag = resad.subscribe(subscribe_channel)print('监听开始')while True:meaaage=meaaag.parse_response()recv_msg = meaaage[2].decode('utf-8')print(recv_msg)
redis 发布订阅示例相关推荐
- 5.Redis 发布订阅
转自:http://www.runoob.com/redis/redis-tutorial.html Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub ...
- python redis订阅_Python -- Redis 发布订阅
一.前言 Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息. Redis 客户端可以订阅任意数量的频道. 下图展示了频道 channel1 ...
- google的api key调用次数是多少_Sprint Boot如何基于Redis发布订阅实现异步消息系统的同步调用?...
前言 在很多互联网应用系统中,请求处理异步化是提升系统性能一种常用的手段,而基于消息系统的异步处理由于具备高可靠性.高吞吐量的特点,因而在并发请求量比较高的互联网系统中被广泛应用.与此同时,这种方案也 ...
- 使用Spring Redis发布/订阅
继续发现功能强大的Redis功能集,值得一提的是对发布/订阅消息的开箱即用支持. 发布/订阅消息传递是许多软件体系结构的重要组成部分. 某些软件系统要求消息传递解决方案提供高性能,可伸缩性,队列持久性 ...
- Redis发布订阅模式
使用银行卡消费的时候,银行往往会通过微信.短信或邮件通知用户这笔交易的信息,这便是一种发布订阅模式,这里的发布是交易信息的发布,订阅则是各个渠道.这在实际工作中十分常用,Redis 支持这样的一个模式 ...
- 上下文管理、redis发布订阅、RabbitMQ发布订阅、SQLAlchemy
一.上下文管理 import contextlib @contextlib.contextmanager def work_state(state_list,worker_thread):state_ ...
- Redis 发布订阅,小功能大用处,真没那么废材!
假设我们有这么一个业务场景,在网站下单支付以后,需要通知库存服务进行发货处理. 上面业务实现不难,我们只要让库存服务提供给相关的给口,下单支付之后只要调用库存服务即可. 后面如果又有新的业务,比如说积 ...
- Redis发布订阅机制
1. 什么是Redis Redis是一个开源的内存数据库,它以键值对的形式存储数据.由于数据存储在内存中,因此Redis的速度很快,但是每次重启Redis服务时,其中的数据也会丢失,因此,Redis也 ...
- Redis学习---(13)Redis 发布订阅
Redis 发布订阅 Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息. Redis 客户端可以订阅任意数量的频道. 下图展示了频道 cha ...
最新文章
- Windows下配置Maven环境变量
- 2019世界机器人大赛圆满落幕,荆州中学等15支队伍获「全能奖」
- 优秀员工应该具备的11个特质
- 第一个Python程序
- python编写IP地址与十进制IP转换脚本
- JavaScript六种继承方式的递进推演
- UITableView长按拖动排序(支持不同行高,不同section间交换)
- caffe的python接口学习(5):生成deploy文件
- 前端打包混编压缩js代码,如何不重新打包,修改js文件内部配置参数?
- 【指纹识别】基于matlab GUI指纹预处理+特征点提取【含Matlab源码 1693期】
- html如何改成花体英文字体,花体英文在线转换
- 1.6万亿参数的语言模型:谷歌大脑提出Switch Transformer,预训练速度可达T5的7倍
- Java六种异常处理的陋习
- 小皮phpstudy无法启动mysql的解决方法
- 极品PS动作繁星散射GIF动画
- 解决fidder一直报“The sever(XXX) presented a certificate that did not validate,....”
- js打印时分页,每页都有表头和表尾
- 步步为营---- MuleEsb学习(一) 扫盲篇
- YY游戏云的AngularJS实践
- Vue.js使用Blob的方式实现excel表格的下载(流文件下载)