您好,登錄后才能下訂單哦!
今天就跟大家聊聊有關(guān)如何在php中使用redis 處理websocket聊天記錄,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。
具體代碼如下所示:
<?phpini_set('display_errors', 'on'); class chatClass { private $redis; //這個(gè)變量模擬用戶當(dāng)前狀態(tài),是否登錄,是否可查看 public $checkUserReadable = false; //構(gòu)造函數(shù)鏈接redis數(shù)據(jù)庫(kù) public function __construct() { $this -> redis = new Redis(); $this -> redis -> connect('127.0.0.1', '6379'); $this -> redis -> auth('***cnblogs.com/handle'); } /* 發(fā)送消息時(shí)保存聊天記錄 * 這里用的redis存儲(chǔ)是list數(shù)據(jù)類型 * 兩個(gè)人的聊天用一個(gè)list保存 * * @from 消息發(fā)送者id * @to 消息接受者id * @meassage 消息內(nèi)容 * * 返回值,當(dāng)前聊天的總聊天記錄數(shù) */ public function setChatRecord($from, $to, $message) { $data = array('from' => $from, 'to' => $to, 'message' => $message, 'sent' => time()/*, 'recd' => 0*/); $value = json_encode($data); //生成json字符串 $keyName = 'rec:' . $this -> getRecKeyName($from, $to); //echo $keyName; $res = $this -> redis -> lPush($keyName, $value); if (!$this -> checkUserReadable) {//消息接受者無法立刻查看時(shí),將消息設(shè)置為未讀 $this -> cacheUnreadMsg($from, $to); } return $res; } /* * 獲取聊天記錄 * @from 消息發(fā)送者id * @to 消息接受者id * @num 獲取的數(shù)量 * * 返回值,指定長(zhǎng)度的包含聊天記錄的數(shù)組 */ public function getChatRecord($from, $to, $num) { $keyName = 'rec:' . $this -> getRecKeyName($from, $to); //echo $keyName; $recList = $this -> redis -> lRange($keyName, 0, (int)($num)); return $recList; } /* * 當(dāng)用戶上線時(shí),或點(diǎn)開聊天框時(shí),獲取未讀消息的數(shù)目 * @user 用戶id * * 返回值,一個(gè)所有當(dāng)前用戶未讀的消息的發(fā)送者和數(shù)組 * 數(shù)組格式為‘消息發(fā)送者id'=>‘未讀消息數(shù)目' * */ public function getUnreadMsgCount($user) { return $this -> redis -> hGetAll('unread_' . $user); } /* * 獲取未讀消息的內(nèi)容 * 通過未讀消息數(shù)目,在列表中取得最新的相應(yīng)消息即為未讀 * @from 消息發(fā)送者id * @to 消息接受者id * * 返回值,包括所有未讀消息內(nèi)容的數(shù)組 * * */ public function getUnreadMsg($from, $to) { $countArr = $this -> getUnreadMsgCount($to); $count = $countArr[$from]; $keyName = 'rec:' . $this -> getRecKeyName($from, $to); return $this -> redis -> lRange($keyName, 0, (int)($count)); } /* * 將消息設(shè)為已讀 * 當(dāng)一個(gè)用戶打開另一個(gè)用戶的聊天框時(shí),將所有未讀消息設(shè)為已讀 * 清楚未讀消息中的緩存 * @from 消息發(fā)送者id * @to 消息接受者id * * 返回值,成功將未讀消息設(shè)為已讀則返回true,沒有未讀消息則返回false */ public function setUnreadToRead($from, $to) { $res = $this -> redis -> hDel('unread_' . $to, $from); return (bool)$res; } /* * 當(dāng)用戶不在線時(shí),或者當(dāng)前沒有立刻接收消息時(shí),緩存未讀消息,將未讀消息的數(shù)目和發(fā)送者信息存到一個(gè)與接受者關(guān)聯(lián)的hash數(shù)據(jù)中 * * @from 發(fā)送消息的用戶id * @to 接收消息的用戶id * * 返回值,當(dāng)前兩個(gè)用戶聊天中的未讀消息 * */ private function cacheUnreadMsg($from, $to) { return $this -> redis -> hIncrBy('unread_' . $to, $from, 1); } /*生成聊天記錄的鍵名,即按大小規(guī)則將兩個(gè)數(shù)字排序 * @from 消息發(fā)送者id * @to 消息接受者id * * */ private function getRecKeyName($from, $to) { return ($from > $to) ? $to . '_' . $from : $from . '_' . $to; } } /* * 下面為測(cè)試用的代碼 ,偽造數(shù)據(jù)模擬場(chǎng)景 * 假定有兩個(gè)用戶id為2和3 ,2 向 3 發(fā)送消息 * $chat = new chatClass(); $chat -> checkUserReadable = true; for ($i = 0; $i < 20; $i++) { $chat -> setChatRecord('2', '3', 'message_' . $i); } echo 'get 20 chat records</br>'; $arr = $chat -> getChatRecord('2', '3', 20); for ($j = 0; $j < count($arr); $j++) { echo $arr[$j] . '</br>'; } $chat -> checkUserReadable = false; for ($m = 0; $m < 5; $m++) { $chat -> setChatRecord('2', '3', 'message_' . $m); } echo "</br>"; $umsg_1 = $chat -> getUnreadMsgCount(3); echo "Unread message counts "; echo "</br>"; print_r($umsg_1); echo "Unread message content </br> "; $umsgContent = $chat -> getUnreadMsg(2, 3); for ($n = 0; $n < count($umsgContent); $n++) { echo $arr[$n] . '</br>'; } echo "</br>"; $chat -> setUnreadToRead(2, 3); $umsg_2 = $chat -> getUnreadMsgCount(3); echo "</br>"; echo "Unread message counts "; echo "</br>"; print_r($umsg_2); * */ ?>
看完上述內(nèi)容,你們對(duì)如何在php中使用redis 處理websocket聊天記錄有進(jìn)一步的了解嗎?如果還想了解更多知識(shí)或者相關(guān)內(nèi)容,請(qǐng)關(guān)注億速云行業(yè)資訊頻道,感謝大家的支持。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。