Redis入門(5) - 消息通知

• 使用列表實現任務隊列
• 優先級隊列
• 按照規則訂閱

Redis也能夠做爲任務隊列。任務隊列顧名思義，就是「傳遞任務的隊列」。任務隊列與消息隊列什麼區別呢？任務隊列是邏輯模型，而消息隊列是通訊模型，二者是不一樣層次的抽象，用消息隊列能夠實現任務隊列。

與任務隊列進行交互的實體有兩類，一類是生產者（producer），一類是消費者（consumer）。生產者會將須要處理的任務放入任務隊列中，而消費者則不斷地從任務隊列中讀入任務信息並執行。

使用任務隊列能夠達到鬆耦合的效果，生產者和消費者無需知道彼此的實現細節，只須要約定好任務的描述格式。這使得生產者和消費者能夠由不一樣的團隊使用不一樣的編程語言編寫。

並且這種模型下，消費者能夠很容易地進行擴展，並能夠分佈在不一樣的服務器，下降單臺服務器的負載。

使用列表實現任務隊列

Redis的列表類型支持從一邊PUSH、從另外一邊POP的操做，用做隊列很是合適。只需生產者經過LPUSH命令將任務加入列表中，另外一邊讓消費者不斷使用RPOP命令從列表中取出便可。但不但願消費者不停RPOP，能夠用BRPOP改進。BRPOP在列表中沒有元素時BRPOP命令會一直阻塞住鏈接，直到有新元素加入。

BRPOP命令接收兩個參數，第一個是鍵名，第二個是超時時間，單位是秒。當超過了此時間仍然沒有得到新元素的話就會返回nil。超時時間設置爲0時，若是沒有新元素加入列表就會永遠阻塞下去。

開啓多個客戶端

爲了測試消息通知，能夠開啓多個redis-cli實例。
若是使用的是redis的docker鏡像的話，能夠先啓動一個redis容器做爲redis server：

docker run --name redisserver -d -p 6379:6379 redis redis-server

redis-server命令能夠啓動redis server。
而後能夠多開幾個終端，都執行下面的命令以啓動redis容器，並鏈接以前啓動的redisserver，這樣就能夠做爲redis client使用了：

docker run -it --link redisserver:redis --rm redis redis-cli -h redisserver -p 6379

在實例A中輸入：

BRPOP queue 0

接下來實例A會一直處於阻塞狀態。而後在實例B中向隊列加入元素：

LPUSH queue taskk

這時立刻就能夠在實例A中看到返回結果，同時能夠驗證queue中剛剛加入的元素已經被取走了。
與BRPOP對應，還有BLPOP命令。

優先級隊列

BRPOP命令能夠同時接收多個鍵，如：

BRPOP queue:1 queue:2 queue:3 0

這時它會同時檢測這幾個鍵，若是全部鍵都沒有元素則阻塞，若是其中有一個鍵有元素則會從該鍵中彈出元素。
若是多個鍵都有元素則按照從左到右的順序取第一個鍵中的一個元素。

藉助這些特性能夠實現優先級隊列，queue:1 queue:2 queue:3三個隊列中，queue:1的優先級最高，這個隊列中的任務會優先被消費。

好比在一個網站中，向用戶發送的郵件中帳號激活郵件的優先級比活動推廣郵件的優先級高，這時就能夠將這兩種郵件放在不一樣的隊列，用BRPOP來優先發送激活郵件。

「發佈/訂閱」模式

除了實現任務隊列外，Redis還提供了一組命令可讓開發者實現「發佈/訂閱」（publish/subscribe）模式。「發佈/訂閱」模式一樣能夠實現進程間的消息傳遞。
用列表類型實現的任務隊列中，一個任務只能被一個消費者消費，多個生產者均可以向隊列推送任務；
在「發佈/訂閱」模式下，一條消息能夠被全部訂閱這個頻道訂閱者接收，多個發佈者也均可以向指定的頻道推送消息。

在redis-cli實例A發佈消息：

PUBLISH channel.1 msg1

PUBLISH命令的返回值表示接收到這條消息的訂閱者數量。發出去的消息不會被持久化，客戶端訂閱channel.1後只能收到後續發佈到該頻道的消息，以前發送的是收不到的。

在redis-cli實例B訂閱channel.1

SUBSCRIBE channel.1

SUBSCRIBE命令能夠同時訂閱多個頻道。

執行SUBSCRIBE命令後客戶端會進入訂閱狀態，處於此狀態下客戶端只能使用屬於「發佈/訂閱」模式的命令，這些命令有SUBSCRIBE/UNSUBSCRIBE/PSUBSCRIBE/PUNSUBSCRIBE。

但在redis-cli中進入訂閱狀態後是沒法退出到非訂閱狀態的，只能關閉cli。

實例B已經訂閱了channel.1，這時若是再從實例A向channel.1發佈消息msg1，實例B就會收到下面的響應：

1) "message"
2) "channel.1"
3) "msg1"

第一行是消息類型，消息類型的取值有subscribe/message/unsubscribe。
當消息類型爲message時，第二行表示頻道名稱，第三行是消息的內容；
當消息類型爲subscribe時，表示訂閱成功的反饋信息。第二行是訂閱成功的頻道名稱，第三行是當前客戶端訂閱的頻道數量。
當消息類型爲unsubscribe時，第二行是對應的頻道名稱，第三行是當前客戶端訂閱的頻道數量，當此值爲0時客戶端會退出訂閱狀態。

按照規則訂閱

除了可使用SUBSCRIBE命令訂閱指定名稱的頻道外，還可使用PSUBSCRIBE命令按照按照指定的規則訂閱多個頻道。如：

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

訂閱規則支持glob風格通配符格式，channel.中能夠匹配任意數量的字符。
使用PSUBSCRIBE命令能夠重複訂閱一個頻道，如某客戶端執行了PSUBSCRIBE channel.? channel.?*，這時向channel.2發佈消息後該客戶端會收到兩條消息。

PUNSUBSCRIBE命令能夠退訂指定的規則

PUNSUBSCRIBE [pattern ...]

若是沒有指定pattern參數，則會退訂全部由PSUBSCRIBE訂閱的規則。

使用PUNSUBSCRIBE命令只能退訂經過PSUBSCRIBE命令訂閱的規則，不會影響直接經過SUBSCRIBE命令訂閱的頻道；一樣UNSUBSCRIBE命令也不會影響經過PSUBSCRIBE命令訂閱的規則。