重慶分公司,新征程啟航
為企業(yè)提供網(wǎng)站建設(shè)、域名注冊(cè)、服務(wù)器等服務(wù)
為企業(yè)提供網(wǎng)站建設(shè)、域名注冊(cè)、服務(wù)器等服務(wù)
這篇文章將為大家詳細(xì)講解有關(guān)websocket在php中的應(yīng)用,小編覺得挺實(shí)用的,因此分享給大家做個(gè)參考,希望大家閱讀完這篇文章后可以有所收獲。
創(chuàng)新互聯(lián)服務(wù)項(xiàng)目包括江陽(yáng)網(wǎng)站建設(shè)、江陽(yáng)網(wǎng)站制作、江陽(yáng)網(wǎng)頁(yè)制作以及江陽(yáng)網(wǎng)絡(luò)營(yíng)銷策劃等。多年來,我們專注于互聯(lián)網(wǎng)行業(yè),利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等,向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案,江陽(yáng)網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前,我們服務(wù)的客戶以成都為中心已經(jīng)輻射到江陽(yáng)省份的部分城市,未來相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任!
一、WebSocket協(xié)議的簡(jiǎn)介
WebSocket協(xié)議是基于TCP的一種新的網(wǎng)絡(luò)協(xié)議。它實(shí)現(xiàn)了瀏覽器與服務(wù)器全雙工(full-duplex)通信——允許服務(wù)器主動(dòng)發(fā)送信息給客戶端。
WebSocket通信協(xié)議于2011年被IETF定為標(biāo)準(zhǔn)RFC 6455,并被RFC7936所補(bǔ)充規(guī)范。
WebSocket協(xié)議支持(在受控環(huán)境中運(yùn)行不受信任的代碼的)客戶端與(選擇加入該代碼的通信的)遠(yuǎn)程主機(jī)之間進(jìn)行全雙工通信。用于此的安全模型是Web瀏覽器常用的基于原始的安全模式。 協(xié)議包括一個(gè)開放的握手以及隨后的TCP層上的消息幀。 該技術(shù)的目標(biāo)是為基于瀏覽器的、需要和服務(wù)器進(jìn)行雙向通信的(服務(wù)器不能依賴于打開多個(gè)HTTP連接(例如,使用XMLHttpRequest或
二、介紹client與server之間的socket連接原理
1、下面是一個(gè)演示client和server之間建立WebSocket連接時(shí)握手部分
2、client與server建立socket時(shí)握手的會(huì)話內(nèi)容,即request與response
a、client建立WebSocket時(shí)向服務(wù)器端請(qǐng)求的信息
GET /chat HTTP/1.1 Host: server.example.com Upgrade: websocket //告訴服務(wù)器現(xiàn)在發(fā)送的是WebSocket協(xié)議 Connection: Upgrade Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw== //是一個(gè)Base64 encode的值,這個(gè)是瀏覽器隨機(jī)生成的,用于驗(yàn)證服務(wù)器端返回?cái)?shù)據(jù)是否是WebSocket助理 Sec-WebSocket-Protocol: chat, superchat Sec-WebSocket-Version: 13 Origin: http://example.com
b、服務(wù)器獲取到client請(qǐng)求的信息后,根據(jù)WebSocket協(xié)議對(duì)數(shù)據(jù)進(jìn)行處理并返回,其中要對(duì)Sec-WebSocket-Key進(jìn)行加密等操作
HTTP/1.1 101 Switching Protocols Upgrade: websocket //依然是固定的,告訴客戶端即將升級(jí)的是Websocket協(xié)議,而不是mozillasocket,lurnarsocket或者shitsocket Connection: Upgrade Sec-WebSocket-Accept: HSmrc0sMlYUkAGmm5OPpG2HaGWk= //這個(gè)則是經(jīng)過服務(wù)器確認(rèn),并且加密過后的 Sec-WebSocket-Key,也就是client要求建立WebSocket驗(yàn)證的憑證 Sec-WebSocket-Protocol: chat
3、socket建立連接原理圖:
三、PHP中建立socket的過程講解
1、在PHP中,client與server之間建立socket通信,首先在PHP中創(chuàng)建socket并監(jiān)聽端口信息,代碼如下:
//傳相應(yīng)的IP與端口進(jìn)行創(chuàng)建socket操作 function WebSocket($address,$port){ $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);//1表示接受所有的數(shù)據(jù)包 socket_bind($server, $address, $port); socket_listen($server); return $server; }
2、設(shè)計(jì)一個(gè)循環(huán)掛起WebSocket通道,進(jìn)行數(shù)據(jù)的接收、處理和發(fā)送
//對(duì)創(chuàng)建的socket循環(huán)進(jìn)行監(jiān)聽,處理數(shù)據(jù) function run(){ //死循環(huán),直到socket斷開 while(true){ $changes=$this->sockets; $write=NULL; $except=NULL; /* //這個(gè)函數(shù)是同時(shí)接受多個(gè)連接的關(guān)鍵,我的理解它是為了阻塞程序繼續(xù)往下執(zhí)行。 socket_select ($sockets, $write = NULL, $except = NULL, NULL); $sockets可以理解為一個(gè)數(shù)組,這個(gè)數(shù)組中存放的是文件描述符。當(dāng)它有變化(就是有新消息到或者有客戶端連接/斷開)時(shí),socket_select函數(shù)才會(huì)返回,繼續(xù)往下執(zhí)行。 $write是監(jiān)聽是否有客戶端寫數(shù)據(jù),傳入NULL是不關(guān)心是否有寫變化。 $except是$sockets里面要被排除的元素,傳入NULL是”監(jiān)聽”全部。 最后一個(gè)參數(shù)是超時(shí)時(shí)間 如果為0:則立即結(jié)束 如果為n>1: 則最多在n秒后結(jié)束,如遇某一個(gè)連接有新動(dòng)態(tài),則提前返回 如果為null:如遇某一個(gè)連接有新動(dòng)態(tài),則返回 */ socket_select($changes,$write,$except,NULL); foreach($changes as $sock){ //如果有新的client連接進(jìn)來,則 if($sock==$this->master){ //接受一個(gè)socket連接 $client=socket_accept($this->master); //給新連接進(jìn)來的socket一個(gè)唯一的ID $key=uniqid(); $this->sockets[]=$client; //將新連接進(jìn)來的socket存進(jìn)連接池 $this->users[$key]=array( 'socket'=>$client, //記錄新連接進(jìn)來client的socket信息 'shou'=>false //標(biāo)志該socket資源沒有完成握手 ); //否則1.為client斷開socket連接,2.client發(fā)送信息 }else{ $len=0; $buffer=''; //讀取該socket的信息,注意:第二個(gè)參數(shù)是引用傳參即接收數(shù)據(jù),第三個(gè)參數(shù)是接收數(shù)據(jù)的長(zhǎng)度 do{ $l=socket_recv($sock,$buf,1000,0); $len+=$l; $buffer.=$buf; }while($l==1000); //根據(jù)socket在user池里面查找相應(yīng)的$k,即健ID $k=$this->search($sock); //如果接收的信息長(zhǎng)度小于7,則該client的socket為斷開連接 if($len<7){ //給該client的socket進(jìn)行斷開操作,并在$this->sockets和$this->users里面進(jìn)行刪除 $this->send2($k); continue; } //判斷該socket是否已經(jīng)握手 if(!$this->users[$k]['shou']){ //如果沒有握手,則進(jìn)行握手處理 $this->woshou($k,$buffer); }else{ //走到這里就是該client發(fā)送信息了,對(duì)接受到的信息進(jìn)行uncode處理 $buffer = $this->uncode($buffer,$k); if($buffer==false){ continue; } //如果不為空,則進(jìn)行消息推送操作 $this->send($k,$buffer); } } } } }
3、以上服務(wù)器端完成的WebSocket的前期工作后,就等著client連接進(jìn)行,client創(chuàng)建WebSocket很簡(jiǎn)單,代碼如下:
var ws = new WebSocket("ws://IP:端口"); //握手監(jiān)聽函數(shù) ws.onopen=function(){ //狀態(tài)為1證明握手成功,然后把client自定義的名字發(fā)送過去 if(so.readyState==1){ //握手成功后對(duì)服務(wù)器發(fā)送信息 so.send('type=add&ming='+n); } } //錯(cuò)誤返回信息函數(shù) ws.onerror = function(){ console.log("error"); }; //監(jiān)聽服務(wù)器端推送的消息 ws.onmessage = function (msg){ console.log(msg); } //斷開WebSocket連接 ws.onclose = function(){ ws = false; }
四、聊天室實(shí)例代碼
1、PHP部分
run(); //下面是sock類 class Sock{ public $sockets; //socket的連接池,即client連接進(jìn)來的socket標(biāo)志 public $users; //所有client連接進(jìn)來的信息,包括socket、client名字等 public $master; //socket的resource,即前期初始化socket時(shí)返回的socket資源 private $sda=array(); //已接收的數(shù)據(jù) private $slen=array(); //數(shù)據(jù)總長(zhǎng)度 private $sjen=array(); //接收數(shù)據(jù)的長(zhǎng)度 private $ar=array(); //加密key private $n=array(); public function __construct($address, $port){ //創(chuàng)建socket并把保存socket資源在$this->master $this->master=$this->WebSocket($address, $port); //創(chuàng)建socket連接池 $this->sockets=array($this->master); } //對(duì)創(chuàng)建的socket循環(huán)進(jìn)行監(jiān)聽,處理數(shù)據(jù) function run(){ //死循環(huán),直到socket斷開 while(true){ $changes=$this->sockets; $write=NULL; $except=NULL; /* //這個(gè)函數(shù)是同時(shí)接受多個(gè)連接的關(guān)鍵,我的理解它是為了阻塞程序繼續(xù)往下執(zhí)行。 socket_select ($sockets, $write = NULL, $except = NULL, NULL); $sockets可以理解為一個(gè)數(shù)組,這個(gè)數(shù)組中存放的是文件描述符。當(dāng)它有變化(就是有新消息到或者有客戶端連接/斷開)時(shí),socket_select函數(shù)才會(huì)返回,繼續(xù)往下執(zhí)行。 $write是監(jiān)聽是否有客戶端寫數(shù)據(jù),傳入NULL是不關(guān)心是否有寫變化。 $except是$sockets里面要被排除的元素,傳入NULL是”監(jiān)聽”全部。 最后一個(gè)參數(shù)是超時(shí)時(shí)間 如果為0:則立即結(jié)束 如果為n>1: 則最多在n秒后結(jié)束,如遇某一個(gè)連接有新動(dòng)態(tài),則提前返回 如果為null:如遇某一個(gè)連接有新動(dòng)態(tài),則返回 */ socket_select($changes,$write,$except,NULL); foreach($changes as $sock){ //如果有新的client連接進(jìn)來,則 if($sock==$this->master){ //接受一個(gè)socket連接 $client=socket_accept($this->master); //給新連接進(jìn)來的socket一個(gè)唯一的ID $key=uniqid(); $this->sockets[]=$client; //將新連接進(jìn)來的socket存進(jìn)連接池 $this->users[$key]=array( 'socket'=>$client, //記錄新連接進(jìn)來client的socket信息 'shou'=>false //標(biāo)志該socket資源沒有完成握手 ); //否則1.為client斷開socket連接,2.client發(fā)送信息 }else{ $len=0; $buffer=''; //讀取該socket的信息,注意:第二個(gè)參數(shù)是引用傳參即接收數(shù)據(jù),第三個(gè)參數(shù)是接收數(shù)據(jù)的長(zhǎng)度 do{ $l=socket_recv($sock,$buf,1000,0); $len+=$l; $buffer.=$buf; }while($l==1000); //根據(jù)socket在user池里面查找相應(yīng)的$k,即健ID $k=$this->search($sock); //如果接收的信息長(zhǎng)度小于7,則該client的socket為斷開連接 if($len<7){ //給該client的socket進(jìn)行斷開操作,并在$this->sockets和$this->users里面進(jìn)行刪除 $this->send2($k); continue; } //判斷該socket是否已經(jīng)握手 if(!$this->users[$k]['shou']){ //如果沒有握手,則進(jìn)行握手處理 $this->woshou($k,$buffer); }else{ //走到這里就是該client發(fā)送信息了,對(duì)接受到的信息進(jìn)行uncode處理 $buffer = $this->uncode($buffer,$k); if($buffer==false){ continue; } //如果不為空,則進(jìn)行消息推送操作 $this->send($k,$buffer); } } } } } //指定關(guān)閉$k對(duì)應(yīng)的socket function close($k){ //斷開相應(yīng)socket socket_close($this->users[$k]['socket']); //刪除相應(yīng)的user信息 unset($this->users[$k]); //重新定義sockets連接池 $this->sockets=array($this->master); foreach($this->users as $v){ $this->sockets[]=$v['socket']; } //輸出日志 $this->e("key:$k close"); } //根據(jù)sock在users里面查找相應(yīng)的$k function search($sock){ foreach ($this->users as $k=>$v){ if($sock==$v['socket']) return $k; } return false; } //傳相應(yīng)的IP與端口進(jìn)行創(chuàng)建socket操作 function WebSocket($address,$port){ $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);//1表示接受所有的數(shù)據(jù)包 socket_bind($server, $address, $port); socket_listen($server); $this->e('Server Started : '.date('Y-m-d H:i:s')); $this->e('Listening on : '.$address.' port '.$port); return $server; } /* * 函數(shù)說明:對(duì)client的請(qǐng)求進(jìn)行回應(yīng),即握手操作 * @$k clien的socket對(duì)應(yīng)的健,即每個(gè)用戶有唯一$k并對(duì)應(yīng)socket * @$buffer 接收client請(qǐng)求的所有信息 */ function woshou($k,$buffer){ //截取Sec-WebSocket-Key的值并加密,其中$key后面的一部分258EAFA5-E914-47DA-95CA-C5AB0DC85B11字符串應(yīng)該是固定的 $buf = substr($buffer,strpos($buffer,'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)); //按照協(xié)議組合信息進(jìn)行返回 $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"; socket_write($this->users[$k]['socket'],$new_message,strlen($new_message)); //對(duì)已經(jīng)握手的client做標(biāo)志 $this->users[$k]['shou']=true; return true; } //解碼函數(shù) function uncode($str,$key){ $mask = array(); $data = ''; $msg = unpack('H*',$str); $head = substr($msg[1],0,2); if ($head == '81' && !isset($this->slen[$key])) { $len=substr($msg[1],2,2); $len=hexdec($len);//把十六進(jìn)制的轉(zhuǎn)換為十進(jìn)制 if(substr($msg[1],2,2)=='fe'){ $len=substr($msg[1],4,4); $len=hexdec($len); $msg[1]=substr($msg[1],4); }else if(substr($msg[1],2,2)=='ff'){ $len=substr($msg[1],4,16); $len=hexdec($len); $msg[1]=substr($msg[1],16); } $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)); $s = 12; $n=0; }else if($this->slen[$key] > 0){ $len=$this->slen[$key]; $mask=$this->ar[$key]; $n=$this->n[$key]; $s = 0; } $e = strlen($msg[1])-2; for ($i=$s; $i<= $e; $i+= 2) { $data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2))); $n++; } $dlen=strlen($data); if($len > 255 && $len > $dlen+intval($this->sjen[$key])){ $this->ar[$key]=$mask; $this->slen[$key]=$len; $this->sjen[$key]=$dlen+intval($this->sjen[$key]); $this->sda[$key]=$this->sda[$key].$data; $this->n[$key]=$n; return false; }else{ unset($this->ar[$key],$this->slen[$key],$this->sjen[$key],$this->n[$key]); $data=$this->sda[$key].$data; unset($this->sda[$key]); return $data; } } //與uncode相對(duì) function code($msg){ $frame = array(); $frame[0] = '81'; $len = strlen($msg); if($len < 126){ $frame[1] = $len<16?'0'.dechex($len):dechex($len); }else if($len < 65025){ $s=dechex($len); $frame[1]='7e'.str_repeat('0',4-strlen($s)).$s; }else{ $s=dechex($len); $frame[1]='7f'.str_repeat('0',16-strlen($s)).$s; } $frame[2] = $this->ord_hex($msg); $data = implode('',$frame); return pack("H*", $data); } function ord_hex($data) { $msg = ''; $l = strlen($data); for ($i= 0; $i<$l; $i++) { $msg .= dechex(ord($data{$i})); } return $msg; } //用戶加入或client發(fā)送信息 function send($k,$msg){ //將查詢字符串解析到第二個(gè)參數(shù)變量中,以數(shù)組的形式保存如:parse_str("name=Bill&age=60",$arr) parse_str($msg,$g); $ar=array(); if($g['type']=='add'){ //第一次進(jìn)入添加聊天名字,把姓名保存在相應(yīng)的users里面 $this->users[$k]['name']=$g['ming']; $ar['type']='add'; $ar['name']=$g['ming']; $key='all'; }else{ //發(fā)送信息行為,其中$g['key']表示面對(duì)大家還是個(gè)人,是前段傳過來的信息 $ar['nrong']=$g['nr']; $key=$g['key']; } //推送信息 $this->send1($k,$ar,$key); } //對(duì)新加入的client推送已經(jīng)在線的client function getusers(){ $ar=array(); foreach($this->users as $k=>$v){ $ar[]=array('code'=>$k,'name'=>$v['name']); } return $ar; } //$k 發(fā)信息人的socketID $key接受人的 socketID ,根據(jù)這個(gè)socketID可以查找相應(yīng)的client進(jìn)行消息推送,即指定client進(jìn)行發(fā)送 function send1($k,$ar,$key='all'){ $ar['code1']=$key; $ar['code']=$k; $ar['time']=date('m-d H:i:s'); //對(duì)發(fā)送信息進(jìn)行編碼處理 $str = $this->code(json_encode($ar)); //面對(duì)大家即所有在線者發(fā)送信息 if($key=='all'){ $users=$this->users; //如果是add表示新加的client if($ar['type']=='add'){ $ar['type']='madd'; $ar['users']=$this->getusers(); //取出所有在線者,用于顯示在在線用戶列表中 $str1 = $this->code(json_encode($ar)); //單獨(dú)對(duì)新client進(jìn)行編碼處理,數(shù)據(jù)不一樣 //對(duì)新client自己?jiǎn)为?dú)發(fā)送,因?yàn)橛行?shù)據(jù)是不一樣的 socket_write($users[$k]['socket'],$str1,strlen($str1)); //上面已經(jīng)對(duì)client自己?jiǎn)为?dú)發(fā)送的,后面就無(wú)需再次發(fā)送,故unset unset($users[$k]); } //除了新client外,對(duì)其他client進(jìn)行發(fā)送信息。數(shù)據(jù)量大時(shí),就要考慮延時(shí)等問題了 foreach($users as $v){ socket_write($v['socket'],$str,strlen($str)); } }else{ //單獨(dú)對(duì)個(gè)人發(fā)送信息,即雙方聊天 socket_write($this->users[$k]['socket'],$str,strlen($str)); socket_write($this->users[$key]['socket'],$str,strlen($str)); } } //用戶退出向所用client推送信息 function send2($k){ $this->close($k); $ar['type']='rmove'; $ar['nrong']=$k; $this->send1(false,$ar,'all'); } //記錄日志 function e($str){ //$path=dirname(__FILE__).'/log.txt'; $str=$str."\n"; //error_log($str,3,$path); //編碼處理 echo iconv('utf-8','gbk//IGNORE',$str); } } ?>
2、client部分
HTML5 websocket 網(wǎng)頁(yè)聊天室 javascript php 清屏
![]()
關(guān)于websocket在php中的應(yīng)用就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到。