使用列表實現任務隊列 優先順序隊列 按照規則訂閱 Redis也可以作為任務隊列。任務隊列顧名思義，就是“傳遞任務的隊列”。任務隊列與消息隊列什麼區別呢？任務隊列是邏輯模型，而消息隊列是通信模型，兩者是不同層次的抽象，用消息隊列可以實現任務隊列。 與任務隊列進行交互的實體有兩類，一類是生產者（produ ...
- 使用列表實現任務隊列
- 優先順序隊列
- 按照規則訂閱
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命令訂閱的規則。
