1. 发布-订阅概念

发布-订阅模式包含两种角色，分别为发布者和订阅者。

订阅者可以订阅一个或者若干个频道（channel）；
而发布者可以向指定的频道发送消息，所有订阅此频道的订阅者都可以收到此消息；

2. 发布-订阅命令

发布模式的命令为：

publish channel message

订阅模式的命令为：

subscribe channel [channel...]

取消给定的一个或多个频道的信息。

unsubscribe channel [channel ...]

3. 发布-订阅实例

publish 命令的返回值表示接收到这条消息的订阅者数量，没有客户端订阅该频道时返回 0 。

127.0.0.1:6379> publish channel "hello"
(integer) 0
127.0.0.1:6379>

发出去的消息不会做持久化处理，也就是说当客户端订阅该频道后，只能收到后续发布到该频道的消息，之前发送的就收不到了。

127.0.0.1:6379> subscribe channel
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel"
3) (integer) 1

进入订阅状态的客户端可能收到 3 种类型的回复，每种类型的回复都包含 3 个值：

第 1 个是消息的类型，根据消息类型的不同，
第二、三值的含义也不同。

消息类型取值有以下 3 种：

subscribe

表示订阅成功的反馈信息，第二个值是订阅成功的频道名称，第三个值是当前客户端订阅的频道数量；
message

表示接收到的消息，第二个值表示产生消息的频道名称，第三个值是消息的内容；
unsubscribe

表示成功取消订阅某个频道，第二个值是对应的频道名称，第三个值是当前客户端订阅的频道数量；当此值为 0 时客户端会退出订阅状态，之后就可以执行其它非 “发布-订阅” 模式的命令了；

127.0.0.1:6379> publish channel "hello"
(integer) 0
127.0.0.1:6379> publish channel "How are you"
(integer) 1
127.0.0.1:6379>
127.0.0.1:6379> unsubscribe channel      # 取消订阅某个频道
1) "unsubscribe"      # 表示成功取消订阅某个频道
2) "channel"          # 对应的频道名称
3) (integer) 0          # 第三个值是当前客户端订阅的频道数量
127.0.0.1:6379>

127.0.0.1:6379> subscribe channel
Reading messages... (press Ctrl-C to quit)
1) "subscribe"        # 订阅成功的反馈信息
2) "channel"      # 订阅成功的频道名称
3) (integer) 1      # 当前客户端订阅的频道数量1) "message"        # 表示接收到的消息
2) "channel"      # 第二个值表示产生消息的频道名称
3) "How are you"  # 第三个值是消息的内容

4. 多频道发布订阅模式

以上只是单个频道的发布订阅, 如果想订阅多个频道，则需要使用使用 psubscribe 命令，后面跟着我们要订阅的频道的表达式，* 代表任意值，订阅多个频道：

127.0.0.1:6379> PSUBSCRIBE greets*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "greets*"
3) (integer) 1

发布消息:

root@171669ba8bdb:/data# redis-cli
127.0.0.1:6379> publish greet1 "hello"
(integer) 0
127.0.0.1:6379> publish greets_1 "hello"
(integer) 1
127.0.0.1:6379> publish greets_2 "world"
(integer) 1
127.0.0.1:6379> publish greets_3 "I am redis"
(integer) 1
127.0.0.1:6379>

订阅者收到的消息:

127.0.0.1:6379> psubscribe greets*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "greets*"
3) (integer) 1
1) "pmessage"
2) "greets*"
3) "greets_1"
4) "hello"
1) "pmessage"
2) "greets*"
3) "greets_2"
4) "world"
1) "pmessage"
2) "greets*"
3) "greets_3"
4) "I am redis"

5. 发布订阅模式缺点

PubSub 的生产者传递过来一个消息，Redis 会直接找到相应的消费者传递过去。如果一个消费者都没有，那么消息直接丢弃。如果开始有三个消费者，一个消费者突然挂掉了，生产者会继续发送消息，另外两个消费者可以持续收到消息。但是挂掉的消费者重新连上的时候，这断连期间生产者发送的消息，对于这个消费者来说就是彻底丢失了。

如果 Redis 停机重启，PubSub 的消息是不会持久化的，毕竟 Redis 宕机就相当于一个消费者都没有，所有的消息直接被丢弃。

Redis 笔记（10）— 发布订阅模式（发布订阅单个信道、订阅信道后的返回值分类、发布订阅多个信道）相关推荐

设计模式笔记 10.Facade 外观模式(结构型模式)
10. Facade 外观模式 2008-8-18 动机(Motivation) 上述A方案的问题在于组件的客户和组件中各种复杂的子系统有了过多的耦合,随着外部客户程序和各子系统的演化,这种 ...
【数据结构笔记10】二叉树的先序、中序、后序遍历，中序遍历的堆栈/非递归遍历算法，层序遍历，确定一个二叉树，树的同构
本次笔记内容: 3.3.1 先序中序后序遍历 3.3.2 中序非递归遍历 3.3.3 层序遍历 3.3.4 遍历应用例子小白专场:题意理解及二叉树表示小白专场:程序框架.建树及同构判别文章目录 ...
Redis 高级特性（2）—— 发布订阅模式
Redis 高级特性 -- 发布订阅 1. 发布-订阅介绍 "发布-订阅"模式包含两种角色,分别为发布者和订阅者.订阅者可以订阅一个或者若干个频道(channel),而发布者可以向 ...
发布订阅模式vs观察者模式
背景最近在研究react的状态管理器zustand时,研究源码时发现其组件注册绑定是通过观察者模式结合react hooks实现更新的.而联想之前写vue的时候,经常会用到vue内置的自定义事件进行 ...
【设计模式】692- TypeScript 设计模式之发布-订阅模式
前言在之前两篇自测清单中,和大家分享了很多 JavaScript 基础知识,大家可以一起再回顾下~ 本文是我在我们团队内部"「现代 JavaScript 突击队」"分享的一篇内容 ...
【EventBus】发布-订阅模式 ( Android 中使用发布-订阅模式进行通信 )
文章目录一.拷贝发布-订阅模式相关类二.完整代码示例一.拷贝发布-订阅模式相关类将上一篇博客 [EventBus]发布-订阅模式 ( 使用代码实现发布-订阅模式 ) 写的发布-订阅模 ...
JavaScript 设计模式之观察者模式与发布订阅模式
前言在软体工程中,设计模式(design pattern)是对软体设计中普遍存在(反复出现)的各种问题,所提出的解决方案. 设计模式并不直接用来完成程式码的编写,而是描述在各种不同情况下,要怎么解决 ...
Javascript中理解发布--订阅模式
Javascript中理解发布--订阅模式阅读目录发布订阅模式介绍如何实现发布--订阅模式? 发布---订阅模式的代码封装如何取消订阅事件? 全局--发布订阅对象代码封装理解模块间通信回到 ...
设计模式之发布订阅模式
发布--订阅模式简介发布--订阅模式又叫观察者模式,它定义对象间的一种一对多的依赖关系,多个观察者对象都依赖于一个目标对象,当目标对象的状态发生变化时,所有依赖于这个对象的观察者对象都会收到通知. ...

Redis 笔记（10）— 发布订阅模式（发布订阅单个信道、订阅信道后的返回值分类、发布订阅多个信道）