六. Redis当中的“发布” 和 “订阅” 的详细讲解说明(图文并茂)

六. Redis当中的“发布” 和 “订阅” 的详细讲解说明(图文并茂)

---

1. 发布 和 订阅的概念

发布和订阅是什么？

一句话： Redis 发布(pub) 订阅(sub) 是一种消息通信模式：发送者(pub) 发送信息，订阅者(sub) 接收信息 。

• 订阅：subscribe
• 发布：publish

Redis 客户端可以订阅任意数量的频道。

客户端订阅频道示意图：

当给这个频道发布消息后，消息就会发送给订阅了的客户端：

发布了一个消息 Hello ，给了对应的频道，然后这些订阅了该频道的客户端，就会读取到发布的（Hello）的消息。

客户端可以订阅多个频道。

可以发布多个消息给多个频道 。

如何理解发布和订阅模式：

任务队列：

1. 顾名思义，就是“传递消息的队列”

2. 与任务队列进行交互的实体有两类：

   1. 一类是：生产者(producer) ，
   2. 另一类则是消费者(consumer)

   生产者 将需要处理的任务放入到任务队列 当中，而消费者 则不断地从任务队列中读取任务信息并执行。

如何简单理解：

1. Subscriber：看作是收音机 。可以收到多个频道，并以队列方式显示。
2. Publisher：看做是电台 。可以往不同的 FM 频道中发送消息。
3. Channel：不同频率的 FM 频道

从 Pub/Sub 的机制来看，它更像是一个广播系统，多个订阅者(Subscriber) 可以订阅多个频道(Channel) ，多个发布者(Publisher) 可以往多个频道(Channel) 中发布消息。

简单通俗一点就是说：发布消息到一个中间件 上，而订阅/配置了这个中间件的客户端，就会实时/接收到这个发送到中间件上的消息。

2. 发布订阅模式分类

2.1 一个发布者，多个订阅者

一个发布者，多个订阅者

主要应用：通知、公告。

可以作为消息队列或者消息管道。

2.2 多个发布者，一个订阅者

多个发布者，一个订阅者

各应用程序作为 Publisher 向 Channel 中发送消息，Subscriber 端收到消息后执行相应的业务逻辑，比如写数据库，显示。

主要应用：排行榜，投票，计数 。

2.3 多个发布者，多个订阅者

多个发布者，多个订阅者。

可以向不同的 Channel 中发送消息，由不同的 Subscriber 接收

主要应用：群聊，聊天

3. Redis 命令行实现发布和订阅

关于Redis 实现发布和订阅有如下 6 个相关的命令：

1. PUBLISH channel msg 将消息 message 发送到指定的频道 channel

2. SUBSCRIBE channel [channel ...] 订阅频道，可以同时订阅多个频道

3. UNSUBSCRIBE [channel ...] 取消订阅指定的频道，如果不指定频道，则会取消所订阅的所以频道

4. PSUBSCRIBE pattern [pattern ...] 订阅一个或多个符合给定模式的频道，每个模式以 * 作为匹配符，比如it* 匹配所有以 it 开头的频道(it.news，it.blog，it.tweets 等等)；news.* 匹配所有以 news. 开头的频道(new.it，new.global.today 等等)，诸如此类。

5. PUNSUBSCRIBE [pattern [pattern ...]] 退订指定的规则，如果没有参数则会退订掉所i有规则 。

6. PUBSUB <subcommand> [argument [argument …]]是一个查看订阅与发布系统状态的内省命令，

代码示例：

# client-1 订阅 news.it 和 news.sport 两个频道client-1> SUBSCRIBE news.it news.sport
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "news.it"
3) (integer) 1
1) "subscribe"
2) "news.sport"
3) (integer) 2# client-2 订阅 news.it 和 news.internet 两个频道client-2> SUBSCRIBE news.it news.internet
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "news.it"
3) (integer) 1
1) "subscribe"
2) "news.internet"
3) (integer) 2# 首先， client-3 打印所有活跃频道
# 注意，即使一个频道有多个订阅者，它也只输出一次，比如 news.itclient-3> PUBSUB CHANNELS
1) "news.sport"
2) "news.internet"
3) "news.it"# 接下来， client-3 打印那些与模式 news.i* 相匹配的活跃频道
# 因为 news.sport 不匹配 news.i* ，所以它没有被打印redis> PUBSUB CHANNELS news.i*
1) "news.internet"
2) "news.it"

4. Redis 命令行实现发布和订阅

4.1 一个发布者，多个订阅者演示

让 client01 ，client02 两个客户端都订阅上 channel1 频道。

127.0.0.1:6379> subscribe channel1  # 让客户端订阅 channel1频道

当订阅上了一个频道，就会实时监听该频道的存在的内容。所以我们想要退出的话，可以 Ctrl + C 或者 quit

让 client02 也订阅上channel 频道，进行接收消息。

127.0.0.1:6379> subscribe channel1

两个 Client 客户端都订阅上了 channel1 频道了。

接下来，让 publish 客户端向 channel1 频道发送信息。看看 ，client01 ,client02 两个订阅了 channel1的客户端是否会监听到 发送的信息。

127.0.0.1:6379> publish channel1 "hello,jack" 

4.2 多个发布者，一个订阅者演示

这里我们演示：让 client01 客户端通过订阅 channel1 频道，实时监听/接收： publish01和 publish02 向 channel 发送的信息。

127.0.0.1:6379> subscribe channel1

127.0.0.1:6379> publish channel1 "hello tom"

127.0.0.1:6379> publish channel1 "hello lihua"

---

4.3 多个发布者，多个订阅者演示

让 publish01，publish01两个客户端都向 channel1 频道发送消息，client01 和 client02 都订阅 channel1 频道，接收/监听该 (channel1) 频道的信息。

---

127.0.0.1:6379> subscribe channel1
127.0.0.1:6379> subscribe channel1
# 返回的是订阅者的数量

127.0.0.1:6379> publish channel1 "hello AAA"

127.0.0.1:6379> publish channel1 "BBB"

5. 注意事项：

1. publish 同一时刻只能向一个 channel 频道发送信息，不可以多个。

2. subscribe 命令可以同一时刻订阅多个 channel 频道。 返回的是订阅者的数量。

3. 发布的消息没有持久化，所以订阅的客户端, 只能收到订阅后发布的消息。无法接收该客户端还没订阅上时已经发布的消息(错过的消息 )。

6. 最后：

“在这个最后的篇章中，我要表达我对每一位读者的感激之情。你们的关注和回复是我创作的动力源泉，我从你们身上吸取了无尽的灵感与勇气。我会将你们的鼓励留在心底，继续在其他的领域奋斗。感谢你们，我们总会在某个时刻再次相遇。”