Redis 發布訂閱(pub/sub)是一種消息通信模式：發送者(pub)發送消息，訂閱者(sub)接收消息。

Redis 客戶端可以訂閱任意數量的頻道。

下圖展示了頻道 channel1 ， 以及訂閱這個頻道的三個客戶端 —— client2 、 client5 和 client1 之間的關系：

當有新消息通過 PUBLISH 命令發送給頻道 channel1 時， 這個消息就會被發送給訂閱它的三個客戶端：

實例

以下實例演示了發布訂閱是如何工作的。在我們實例中我們創建了訂閱頻道名為 redisChat:

redis 127.0.0.1:6379> SUBSCRIBE redisChat

Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "redisChat"
3) (integer) 1

現在，我們先重新開啟個 redis 客戶端，然後在同一個頻道 redisChat 發布兩次消息，訂閱者就能接收到消息。

redis 127.0.0.1:6379> PUBLISH redisChat "Redis is a great caching technique"

(integer) 1

redis 127.0.0.1:6379> PUBLISH redisChat "Learn redis by w3cschool.cc"

(integer) 1

# 訂閱者的客戶端會顯示如下消息
1) "message"
2) "redisChat"
3) "Redis is a great caching technique"
1) "message"
2) "redisChat"
3) "Learn redis by w3cschool.cc"

Redis 發布訂閱命令

下表列出了 redis 發布訂閱常用命令：

Redis發布訂閱與ActiveMQ的比較

（1）ActiveMQ支持多種消息協議，包括AMQP，MQTT，Stomp等，並且支持JMS規範，但Redis沒有提供對這些協議的支持；
（2）ActiveMQ提供持久化功能，但Redis無法對消息持久化存儲，一旦消息被發送，如果沒有訂閱者接收，那麽消息就會丟失；
（3）ActiveMQ提供了消息傳輸保障，當客戶端連接超時或事務回滾等情況發生時，消息會被重新發送給客戶端，Redis沒有提供消息傳輸保障。
總之，ActiveMQ所提供的功能遠比Redis發布訂閱要復雜，畢竟Redis不是專門做發布訂閱的，但是如果系統中已經有了Redis，並且需要基本的發布訂閱功能，就沒有必要再安裝ActiveMQ了，因為可能ActiveMQ提供的功能大部分都用不到，而Redis的發布訂閱機制就能滿足需求。

Redis實現任務隊列

使用Redis實現任務隊列首先想到的就是Redis的列表類型，因為在Redis內部，==列表類型是由雙向鏈表實現==的。

實現任務隊列，只需讓生產者將任務使用LPUSH加入到某個鍵中，然後另一個消費者不斷地使用RPOP命令從該鍵中取出任務即可。

//生產者只需將task LPUSH到隊列中
127.0.0.1:6379> LPUSH queue task
(integer) 1
127.0.0.1:6379> LRANGE queue 0 -1
1) "task"
//消費者只需從隊列中LPOP任務，如果為空則輪詢。
127.0.0.1:6379> LPOP queue
"task"

BLPOP指令可以在隊列為空時處於阻塞狀態。就不用處於輪詢的狀態。

127.0.0.1:6379> BLPOP queue 0   //0表示無限制等待
//消費者當隊列為空則處於阻塞狀態。
//生產者將task LPUSH到隊列中，處於阻塞狀態的消費者離開返回
127.0.0.1:6379> LPUSH queue task
(integer) 1

//消費者立刻“消費”，取出task。
127.0.0.1:6379> BLPOP queue 0
1) "queue"
2) "task"
(13.38s)

優先級隊列

當一個隊列中有許多任務仍然沒有來得及被消費者及時消費時，如果出現緊急的消息，則不得不等待隊列中的任務被一一取出，因此，需要實現一個優先級隊列，當優先級隊列不為空時，消費者優先取出優先級隊列中的任務去執行。

BLPOP命令可以同時接收多個鍵BLPOP key [key ...] timeout，當所有鍵（列表類型）都為空時，則阻塞，當其中一個有元素則會從該鍵返回。==如果多個鍵都有元素則按照從左到右的順序取第一個鍵中的一個元素，因此可以借此特性實現優先級隊列。==

127.0.0.1:6379> LPUSH queue1 first 
(integer) 1
127.0.0.1:6379> LPUSH queue2 second
(integer) 1

//當兩個鍵都有元素時，按照從左到右的順序取第一個鍵中的一個元素
127.0.0.1:6379> BRPOP queue1 queue2 0
1) "queue1"
2) "first"
127.0.0.1:6379> BRPOP queue1 queue2 0
1) "queue2"
2) "second"

Redis發布訂閱