redis的Pub/Sub功能
2024-10-19 09:35:04
Pub/Sub功能（即Publish,Subscribe）意思是发布及订阅功能。简单的理解就像我们订阅blog一样，不同的是，这里的客户端与server端采用长连接建立推送机制，一个客户端发布消息，可以在多个客户端收到通知。
发布订阅(pub/sub)是一种消息通信模式，主要的目的是解耦消息发布者和消息订阅者之间的耦合，这点和设计模式中的观察者模式比较相似。pub /sub不仅仅解决发布者和订阅者直接代码级别耦合也解决两者在物理部署上的耦合。redis作为一个pub/sub server，在订阅者和发布者之间起到了消息路由的功能。订阅者可以通过subscribe和psubscribe命令向redis server订阅自己感兴趣的消息类型，redis将消息类型称为通道(channel)。当发布者通过publish命令向redis server发送特定类型的消息时。订阅该消息类型的全部client都会收到此消息。这里消息的传递是多对多的。一个client可以订阅多个channel,也可以向多个channel发送消息。
| 客户端一 在监听tv1频道 | 客户端二 在监听tv1和tv2多个频道 | 发布者 |
| > subscribe tv1 Reading messages... (press Ctrl-C to quit) 1) "subscribe" # 显示订阅成功 2) "tv1" # 订阅的频道(通道)名称 3) (integer) 1 # 自己订阅的频道数量 |
> subscribe tv1 tv2 Reading messages... (press Ctrl-C to quit) 1) "subscribe" 2) "tv1" 3) (integer) 1 1) "subscribe" 2) "tv2" 3) (integer) 2 |
|
| > publish tv1 1111111111111 (integer) 2 发布tv1频道消息 返回int 2 表示有2个客户端收到了tv1频道消息 |
||
| > subscribe tv1 Reading messages... (press Ctrl-C to quit) 1) "subscribe" 2) "tv1" 3) (integer) 1 1) "message" #有消息 2) "tv1" #收到消息频道tv1 3) "1111111111111" #消息内容 |
> subscribe tv1 tv2 Reading messages... (press Ctrl-C to quit) 1) "subscribe" 2) "tv1" 3) (integer) 1 1) "subscribe" 2) "tv2" 3) (integer) 2 1) "message" #有消息 2) "tv1" #收到消息频道tv1 3) "1111111111111" #消息内容 |
<-- 说明：两客户端均收到了tv1频道消息。 |
| > publish tv2 222222222222 (integer) 1 继续发布tv2频道消息 返回 int 1 表示有1个客户端收到tv2频道消息 |
||
| > subscribe tv1 Reading messages... (press Ctrl-C to quit) 1) "subscribe" 2) "tv1" 3) (integer) 1 1) "message" 2) "tv1" 3) "1111111111111" |
> subscribe tv1 tv2 Reading messages... (press Ctrl-C to quit) 1) "subscribe" 2) "tv1" 3) (integer) 1 1) "subscribe" 2) "tv2" 3) (integer) 2 1) "message" 2) "tv1" 3) "1111111111111" 1) "message" #有消息 2) "tv2" #收到消息频道tv2 3) "2222222222222" #消息内容 |
<-- 说明：因为客户端一只订阅了tv1频道消息，其收不到此次tv2频道的消息内容；而客户端二订阅了tv1和tv2两个频道消息，故而能收到tv2的消息； |
最新文章
- Linux基础介绍【第八篇】
- C#之类的继承、抽象类和虚方法
- 页面静态化3 --- （伪静态+ob缓存）实现优化
- Android控件之MultiAutoCompleteTextView（自动匹配输入的内容）
- Linux系统编程@终端IO
- Java的云打印Lodop
- C语言基本概念
- 201521123080《Java程序设计》第7周学习总结
- 【转】Elasticsearch学习
- mysql中几个日期时间类型之间的区别和使用
- 背水一战 Windows 10 (119) - 后台任务: 后台下载任务（任务分组，组完成后触发后台任务）
- BCP导出数据到EXCEL
- luogu3380/bzoj3196 二逼平衡树 (树状数组套权值线段树)
- ajax传输中文参数乱码，本地使用tomcat不乱码，liunx+weblogic乱码
- Java：斐波那契数列
- TCP端口号范围及分类
- 02.将uboot，kernel，rootfs下载到开发板上
- Implementation：Sunday 字符串匹配
- 在此位置打开CMD
- Python学习之read()方法