redis提供了pub/sub(發布/訂閱)模式的消息機制。發布者向指定頻道發布消息，訂閱了該頻道的訂閱者就可以獲取消息。通過該機制，我們可以完成聊天室、公告牌等功能。
首先，來介紹下關于pub/sub的幾個命令。
發布消息
publish channel message 向指定頻道發布消息
假如有一個車友群，此時有位用戶發布了條消息
127.0.0.1:6379>?publish?car:fans?hello,everyone (integer)?0
該命令的返回值是訂閱了此頻道的訂閱者數量。可以看到，目前還沒有人訂閱該頻道。
訂閱消息
subscribe channel [channel] 訂閱者可以訂閱一個或多個用戶
127.0.0.1:6379>?subscribe?car:fans Reading?messages...?(press?Ctrl-C?to?quit) 1)?"subscribe" 2)?"car:fans" 3)?(integer)?1
此時，已經有一個用戶加入了車友群。逐漸的，加群的人越來越多。
當一個用戶發布了消息后，其他群人員都能看到該消息。
127.0.0.1:6379>?publish?car:fans?'How?are?you' (integer)?2127.0.0.1:6379>?subscribe?car:fans Reading?messages...?(press?Ctrl-C?to?quit) 1)?"subscribe" 2)?"car:fans" 3)?(integer)?1 1)?"message" 2)?"car:fans" 3)?"How?are?you"
注意：當客戶端執行了訂閱命令后，即進入訂閱狀態，只能執行pub/sub相關命令了。另外，新加群的用戶是看不到之前的消息的，因為此種機制不會對消息進行持久化。雖然功能受限，但勝在足夠簡單。
多說一句，功能不是越多越好，主要看適不適合場景。如果能勝任的話，肯定越簡單越好。
查看訂閱數
pubsub numsub [channel …]
想要查看群里有多少用戶
127.0.0.1:6379>?pubsub?numsub?car:fans 1)?"car:fans" 2)?(integer)?2
該群目前有2個用戶。
取消訂閱
unsubscribe [channel [channel …]]
redis-cli?UNSUBSCRIBE 1)?"unsubscribe" 2)?(nil) 3)?(integer)?0
實戰
介紹完上面的知識后，我們就能完成一個聊天室的功能了。
發布消息的偽代碼十分簡單，發布消息的偽代碼如下：
function?publist?($chanel,?$message) { ????$redis->publist($channel,?$message); }
獲取消息的偽代碼如下：
//設置php腳本執行時間 set_time_limit(0); //設置socket連接超時時間 ini_set('default_socket_timeout',?-1); ? //聲明頻道名稱 $channelName?=?"testpubsub"; ? try?{ ????$redis?=?new?Redis(); ????$redis->pconnect('localhost',?6379); ????$redis->subscribe([$channelName],?function?($redis,?$channel,?$msg) ????{ ????????echo?'channel:'?.?$channel?.?',message:'?.?$msg?.?PHP_EOL; ????}); }?catch?(Exception?$e)?{ ????echo?$e->getMessage(); }
這里有幾個注意點：
-
消費者需要創建redis長連接，
-
設置set_time_limit和default_socket_timeout，以確保阻塞獲取消息過程php不超時，socket連接不超時
目前，Redis提供了新的Stream類型，它的功能更加強大的多。有興趣的朋友可以自己查閱相關信息。
? 版權聲明
文章版權歸作者所有，未經允許請勿轉載。
THE END
