php基于websocket搭建簡易聊天室實踐
本文實例講述了php基于websocket搭建簡易聊天室實踐。分享給大家供大家參考。具體如下：
1、前言
公司游戲里面有個簡單的聊天室，了解了之后才知道是node+websocket做的，想想php也來做個簡單的聊天室。于是搜集各種資料看文檔、找實例自己也寫了個簡單的聊天室。
http連接分為短連接和長連接。短連接一般可以用ajax實現(xiàn)，長連接就是websocket。短連接實現(xiàn)起來比較簡單，但是太過于消耗資源。websocket高效不過兼容存在點問題。websocket是html5的資源
2、前端
前端實現(xiàn)websocket很簡單直接
//連接websocket
var ws = new WebSocket("ws://127.0.0.1:8000");
//成功連接websoc的時候
ws.onopen = function(){}
//成功獲取服務(wù)端輸出的消息
ws.onmessage = function(e){}
//連接錯誤的時候
ws.onerror = function(){}
//向服務(wù)端發(fā)送數(shù)據(jù)
ws.send();
3、后臺
websocket的難點主要在后臺
3.1websocket連接過程
websocket 通信圖解 這是一個簡易的客戶端和服務(wù)端的通信圖解，php主要就做的就是接受加密key 并返回 其中完成套接字的創(chuàng)建和握手操作
下圖是一張詳細的服務(wù)端處理websocket的流程圖
3.2 代碼實踐
服務(wù)端做的流程大致是：
- 掛起一個socket套接字進程等待連接
- 有socket連接之后遍歷套接字數(shù)組
- 沒有握手的進行握手操作，如果已經(jīng)握手則接收數(shù)據(jù)解析并寫入緩沖區(qū)進行輸出
下面是示例代碼（我寫的是一個類所以代碼是根據(jù)函數(shù)分段的），文底給出github地址以及自己遇到的一些坑
1、首先是創(chuàng)建套接字
//建立套接字
public function createSocket($address,$port)
{
//創(chuàng)建一個套接字
$socket= socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
//設(shè)置套接字選項
socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
//綁定IP地址和端口
socket_bind($socket,$address,$port);
//監(jiān)聽套接字
socket_listen($socket);
return $socket;
}
2、將套接字放入數(shù)組
public function __construct($address,$port)
{
//建立套接字
$this->soc=$this->createSocket($address,$port);
$this->socs=array($this->soc);
}
3、掛起進程遍歷套接字數(shù)組，主要操作都是在這里面完成的
public function run(){
//掛起進程
while(true){
$arr=$this->socs;
$write=$except=NULL;
//接收套接字數(shù)字 監(jiān)聽他們的狀態(tài)
socket_select($arr,$write,$except, NULL);
//遍歷套接字數(shù)組
foreach($arr as $k=>$v){
//如果是新建立的套接字返回一個有效的 套接字資源
if($this->soc == $v){
$client=socket_accept($this->soc);
if($client <0){
echo "socket_accept() failed";
}else{
// array_push($this->socs,$client);
// unset($this[]);
//將有效的套接字資源放到套接字數(shù)組
$this->socs[]=$client;
}
}else{
//從已連接的socket接收數(shù)據(jù) 返回的是從socket中接收的字節(jié)數(shù)
$byte=socket_recv($v, $buff,20480, 0);
//如果接收的字節(jié)是0
if($byte<7)
continue;
//判斷有沒有握手沒有握手則進行握手,如果握手了 則進行處理
if(!$this->hand[(int)$client]){
//進行握手操作
$this->hands($client,$buff,$v);
}else{
//處理數(shù)據(jù)操作
$mess=$this->decodeData($buff);
//發(fā)送數(shù)據(jù)
$this->send($mess,$v);
}
}
}
}
}
4、進行握手 流程是接收websocket內(nèi)容從Sec-WebSocket-Key:中獲取key并通過加密算法寫入緩沖區(qū)客戶端會進行驗證（自動驗證不需要我們處理）
public function hands($client,$buff,$v)
{
//提取websocket傳的key并進行加密 （這是固定的握手機制獲取Sec-WebSocket-Key:里面的key）
$buf = substr($buff,strpos($buff,'Sec-WebSocket-Key:')+18);
//去除換行空格字符
$key = trim(substr($buf,0,strpos($buf,"\r\n")));
//固定的加密算法
$new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true));
$new_message = "HTTP/1.1 101 Switching Protocols\r\n";
$new_message .= "Upgrade: websocket\r\n";
$new_message .= "Sec-WebSocket-Version: 13\r\n";
$new_message .= "Connection: Upgrade\r\n";
$new_message .= "Sec-WebSocket-Accept: " . $new_key . "\r\n\r\n";
//將套接字寫入緩沖區(qū)
socket_write($v,$new_message,strlen($new_message));
// socket_write(socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
//標記此套接字握手成功
$this->hand[(int)$client]=true;
}
5、解析客戶端的數(shù)據(jù)（我這里沒有進行加密，如果有需要也可以自己加密 ）
//解析數(shù)據(jù)
public function decodeData($buff)
{
//$buff 解析數(shù)據(jù)幀
$mask = array();
$data = '';
$msg = unpack('H*',$buff); //用unpack函數(shù)從二進制將數(shù)據(jù)解碼
$head = substr($msg[1],0,2);
if (hexdec($head{1}) === 8) {
$data = false;
}else if (hexdec($head{1}) === 1){
$mask[] = hexdec(substr($msg[1],4,2));
$mask[] = hexdec(substr($msg[1],6,2));
$mask[] = hexdec(substr($msg[1],8,2));
$mask[] = hexdec(substr($msg[1],10,2));
//遇到的問題 剛連接的時候就發(fā)送數(shù)據(jù) 顯示 state connecting
$s = 12;
$e = strlen($msg[1])-2;
$n = 0;
for ($i=$s; $i<= $e; $i+= 2) {
$data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2)));
$n++;
}
//發(fā)送數(shù)據(jù)到客戶端
//如果長度大于125 將數(shù)據(jù)分塊
$block=str_split($data,125);
$mess=array(
'mess'=>$block[0],
);
return $mess;
}
6、將套接字寫入緩沖區(qū)
//發(fā)送數(shù)據(jù)
public function send($mess,$v)
{
//遍歷套接字數(shù)組 成功握手的 進行數(shù)據(jù)群發(fā)
foreach ($this->socs as $keys => $values) {
//用系統(tǒng)分配的套接字資源id作為用戶昵稱
$mess['name']="Tourist's socket:{$v}";
$str=json_encode($mess);
$writes ="\x81".chr(strlen($str)).$str;
// ob_flush();
// flush();
// sleep(3);
if($this->hand[(int)$values])
socket_write($values,$writes,strlen($writes));
}
}
7、運行方法
github地址git@github.com:rsaLive/websocket.git
①最好在控制臺運行server.php
轉(zhuǎn)到server.php腳本目錄(可以先php -v 看下有沒有配置php如果沒有Linux配置下bash windows 配置下path)
php -f server.php
如果有錯誤會提示
②通過服務(wù)器訪問html文件
8、踩過的坑，打開調(diào)試工作方便查看錯誤
①server.php 掛起的進程中可以打印輸出的，如果出現(xiàn)問題可以在代碼中加入打印來調(diào)試
可以在各個判斷里面做標記在控制臺查看代碼運行在哪個區(qū)間
不過每次修改完代碼之后需要重新運行腳本 php server.php
②如果出現(xiàn)這種錯誤可能是
1、在與服務(wù)器初始套接字的時候發(fā)送數(shù)據(jù) （在第一次與服務(wù)器驗證握手的時候不能發(fā)送內(nèi)容）
2、如果已經(jīng)驗證過了但是客戶端沒有發(fā)送或者發(fā)送的消息為空也會出現(xiàn)這樣的情況
所以要檢驗已連接的套接字的數(shù)據(jù)
③可能瀏覽器不支持或者服務(wù)端沒有開啟socket開始之前最好驗證下
if (window.WebSocket){
console.log("This browser supports WebSocket!");
} else {
console.log("This browser does not support WebSocket.");
}
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
獲取qq在線狀態(tài)官方已有API提供了，我們用另一種方法獲取qq用戶昵稱和在線狀態(tài)，主要是為學(xué)習(xí)PHP。2013-10-10
本文介紹PHP單例模式,文中講解了單例模式的概念、單例模式的特點、使用單例模式的原因及場景及PHP單例模式代碼實例,需要的碼農(nóng)可以參考下2016-12-12
這篇文章主要介紹了Laravel框架源碼解析之模型Model,結(jié)合實例形式分析了Laravel框架模型Model相關(guān)原理、用法及操作注意事項,需要的朋友可以參考下2020-05-05
Yii2中的場景(scenario)和驗證規(guī)則(rule)詳解
Yii2的rule用于對模型屬性進行驗證，scenario用戶定義不同場景下需要驗證的模型，下面這篇文章主要給大家介紹了關(guān)于Yii2中場景(scenario)和驗證規(guī)則(rule)的相關(guān)資料，文中通過示例代碼介紹的非常詳細，需要的朋友可以參考下。2018-01-01
Yii2創(chuàng)建表單(ActiveForm)方法詳解
這篇文章主要介紹了Yii2創(chuàng)建表單(ActiveForm)的方法,結(jié)合實例形式詳細分析了Yii創(chuàng)建表單的詳細步驟及相關(guān)函數(shù)與屬性的使用技巧,需要的朋友可以參考下2016-07-07
這篇文章主要為大家詳細介紹了php簡單實現(xiàn)socket通信的相關(guān)資料,具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-11-11
這篇文章主要給大家分享介紹了5個非常有用的Laravel Blade指令，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
其實原理就是通過php的session判斷，發(fā)帖前后不同的session值進行判斷，需要的朋友可以自由發(fā)揮下2014-02-02
這篇文章主要介紹了PHP中上傳文件打印錯誤，錯誤類型分析 ,需要的朋友可以參考下2019-04-04
這篇文章主要介紹了php微信小程序解包過程實例詳解,本文通過實例代碼給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-03-03