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）— 发布订阅模式（发布订阅单个信道、订阅信道后的返回值分类、发布订阅多个信道）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。