在启动好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 发布订阅示例相关推荐

  1. 5.Redis 发布订阅

    转自:http://www.runoob.com/redis/redis-tutorial.html Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub ...

  2. python redis订阅_Python -- Redis 发布订阅

    一.前言 Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息. Redis 客户端可以订阅任意数量的频道. 下图展示了频道 channel1 ...

  3. google的api key调用次数是多少_Sprint Boot如何基于Redis发布订阅实现异步消息系统的同步调用?...

    前言 在很多互联网应用系统中,请求处理异步化是提升系统性能一种常用的手段,而基于消息系统的异步处理由于具备高可靠性.高吞吐量的特点,因而在并发请求量比较高的互联网系统中被广泛应用.与此同时,这种方案也 ...

  4. 使用Spring Redis发布/订阅

    继续发现功能强大的Redis功能集,值得一提的是对发布/订阅消息的开箱即用支持. 发布/订阅消息传递是许多软件体系结构的重要组成部分. 某些软件系统要求消息传递解决方案提供高性能,可伸缩性,队列持久性 ...

  5. Redis发布订阅模式

    使用银行卡消费的时候,银行往往会通过微信.短信或邮件通知用户这笔交易的信息,这便是一种发布订阅模式,这里的发布是交易信息的发布,订阅则是各个渠道.这在实际工作中十分常用,Redis 支持这样的一个模式 ...

  6. 上下文管理、redis发布订阅、RabbitMQ发布订阅、SQLAlchemy

    一.上下文管理 import contextlib @contextlib.contextmanager def work_state(state_list,worker_thread):state_ ...

  7. Redis 发布订阅,小功能大用处,真没那么废材!

    假设我们有这么一个业务场景,在网站下单支付以后,需要通知库存服务进行发货处理. 上面业务实现不难,我们只要让库存服务提供给相关的给口,下单支付之后只要调用库存服务即可. 后面如果又有新的业务,比如说积 ...

  8. Redis发布订阅机制

    1. 什么是Redis Redis是一个开源的内存数据库,它以键值对的形式存储数据.由于数据存储在内存中,因此Redis的速度很快,但是每次重启Redis服务时,其中的数据也会丢失,因此,Redis也 ...

  9. Redis学习---(13)Redis 发布订阅

    Redis 发布订阅 Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息. Redis 客户端可以订阅任意数量的频道. 下图展示了频道 cha ...

最新文章

  1. Windows下配置Maven环境变量
  2. 2019世界机器人大赛圆满落幕,荆州中学等15支队伍获「全能奖」
  3. 优秀员工应该具备的11个特质
  4. 第一个Python程序
  5. python编写IP地址与十进制IP转换脚本
  6. JavaScript六种继承方式的递进推演
  7. UITableView长按拖动排序(支持不同行高,不同section间交换)
  8. caffe的python接口学习(5):生成deploy文件
  9. 前端打包混编压缩js代码,如何不重新打包,修改js文件内部配置参数?
  10. 【指纹识别】基于matlab GUI指纹预处理+特征点提取【含Matlab源码 1693期】
  11. html如何改成花体英文字体,花体英文在线转换
  12. 1.6万亿参数的语言模型:谷歌大脑提出Switch Transformer,预训练速度可达T5的7倍
  13. Java六种异常处理的陋习
  14. 小皮phpstudy无法启动mysql的解决方法
  15. 极品PS动作繁星散射GIF动画
  16. 解决fidder一直报“The sever(XXX) presented a certificate that did not validate,....”
  17. js打印时分页,每页都有表头和表尾
  18. 步步为营---- MuleEsb学习(一) 扫盲篇
  19. YY游戏云的AngularJS实践
  20. Vue.js使用Blob的方式实现excel表格的下载(流文件下载)

热门文章

  1. adb fastboot 模式开启流程
  2. 快解析动态域名解析,实现外网访问内网数据库
  3. 梯度消失和梯度爆炸及解决方法
  4. 初学编程之代码战争过关体验
  5. 国外水下无人潜航器及其通信技术发展综述
  6. mysql存储过程练习题,2016年计算机二级考试MySQL数据库练习题模拟
  7. java基础算法题(含答案)
  8. linux virsh console无法登入虚拟机,宿主机virsh console 登录异常
  9. C语言中extern关键字用法
  10. sql事务(Transaction)用法介绍及回滚实例