使用Redis完成聊天室功能

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類型，它的功能更加強大的多。有興趣的朋友可以自己查閱相關資訊。

以上是使用Redis完成聊天室功能的詳細內容。更多資訊請關注PHP中文網其他相關文章！