Redis如何實現聊天室功能？

今天小編就為大家帶來一篇介紹Redis實現聊天室功能的文章。小編覺得挺實用的，為此分享給大家做個參考。一起跟隨小編過來看看吧。

首先，來介紹下關于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實現聊天室功能就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果喜歡這篇文章，不如把它分享出去讓更多的人看到。