今天小編就為大家?guī)硪黄榻Bredis實(shí)現(xiàn)聊天室功能的文章。小編覺得挺實(shí)用的，為此分享給大家做個(gè)參考。一起跟隨小編過來看看吧。

豐縣網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)！從網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、自適應(yīng)網(wǎng)站建設(shè)等網(wǎng)站項(xiàng)目制作，到程序開發(fā)，運(yùn)營維護(hù)。創(chuàng)新互聯(lián)公司2013年成立到現(xiàn)在10年的時(shí)間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)。

首先，來介紹下關(guān)于pub/sub的幾個(gè)命令。

發(fā)布消息

publish channel message 向指定頻道發(fā)布消息

假如有一個(gè)車友群，此時(shí)有位用戶發(fā)布了條消息

127.0.0.1:6379> publish car:fans hello,everyone
(integer) 0

該命令的返回值是訂閱了此頻道的訂閱者數(shù)量。可以看到，目前還沒有人訂閱該頻道。

訂閱消息

subscribe channel [channel] 訂閱者可以訂閱一個(gè)或多個(gè)用戶

127.0.0.1:6379> subscribe car:fans
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "car:fans"
3) (integer) 1

此時(shí)，已經(jīng)有一個(gè)用戶加入了車友群。逐漸的，加群的人越來越多。

當(dāng)一個(gè)用戶發(fā)布了消息后，其他群人員都能看到該消息。

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"

注意：當(dāng)客戶端執(zhí)行了訂閱命令后，即進(jìn)入訂閱狀態(tài)，只能執(zhí)行pub/sub相關(guān)命令了。另外，新加群的用戶是看不到之前的消息的，因?yàn)榇朔N機(jī)制不會(huì)對(duì)消息進(jìn)行持久化。雖然功能受限，但勝在足夠簡單。

多說一句，功能不是越多越好，主要看適不適合場(chǎng)景。如果能勝任的話，肯定越簡單越好。

查看訂閱數(shù)

pubsub numsub [channel ...]

想要查看群里有多少用戶

127.0.0.1:6379> pubsub numsub car:fans
1) "car:fans"
2) (integer) 2

該群目前有2個(gè)用戶。

取消訂閱

unsubscribe [channel [channel ...]]

redis-cli UNSUBSCRIBE
1) "unsubscribe"
2) (nil)
3) (integer) 0

實(shí)戰(zhàn)

介紹完上面的知識(shí)后，我們就能完成一個(gè)聊天室的功能了。

發(fā)布消息的偽代碼十分簡單，發(fā)布消息的偽代碼如下：

function publist ($chanel, $message)
{
    $redis->publist($channel, $message);
}

獲取消息的偽代碼如下：

//設(shè)置php腳本執(zhí)行時(shí)間
set_time_limit(0);
//設(shè)置socket連接超時(shí)時(shí)間
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();
}

這里有幾個(gè)注意點(diǎn)：

• 消費(fèi)者需要?jiǎng)?chuàng)建redis長連接，

• 設(shè)置set_time_limit和default_socket_timeout，以確保阻塞獲取消息過程php不超時(shí)，socket連接不超時(shí)

關(guān)于Redis實(shí)現(xiàn)聊天室功能就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果喜歡這篇文章，不如把它分享出去讓更多的人看到。