PHP實(shí)現(xiàn)websocket通信的方法示例
更新時(shí)間：2018年08月28日 12:02:58 作者：風(fēng)輕云淡180518
這篇文章主要介紹了PHP實(shí)現(xiàn)websocket通信的方法,結(jié)合實(shí)例形式分析了php基于websocket類的socket通信相關(guān)客戶端與服務(wù)器端操作技巧,需要的朋友可以參考下
本文實(shí)例講述了PHP實(shí)現(xiàn)websocket通信的方法。分享給大家供大家參考，具體如下：
執(zhí)行方法:
首先先修改server.php與index.html的ip
通過命令行執(zhí)行 [php路徑]\php.exe "[文件路徑]\server.php"
然后通過瀏覽器打開index.html
server.php
<?php
include 'websocket.class.php';
$config=array(
'address'=>'192.168.0.200',
'port'=>'8000',
'event'=>'WSevent',//回調(diào)函數(shù)的函數(shù)名
'log'=>true,
);
$websocket = new websocket($config);
$websocket->run();
function WSevent($type,$event){
global $websocket;
if('in'==$type){
$websocket->log('客戶進(jìn)入id:'.$event['k']);
}elseif('out'==$type){
$websocket->log('客戶退出id:'.$event['k']);
}elseif('msg'==$type){
$websocket->log($event['k'].'消息:'.$event['msg']);
roboot($event['sign'],$event['msg']);
}
}
function roboot($sign,$t){
global $websocket;
switch ($t)
{
case 'hello':
$show='hello,GIt @ OSC';
break;
case 'name':
$show='Robot';
break;
case 'time':
$show='當(dāng)前時(shí)間:'.date('Y-m-d H:i:s');
break;
case '再見':
$show='( ^_^ )/~~拜拜';
$websocket->write($sign,'Robot:'.$show);
$websocket->close($sign);
return;
break;
case '天王蓋地虎':
$array = array('小雞燉蘑菇','寶塔震河妖','粒粒皆辛苦');
$show = $array[rand(0,2)];
break;
default:
$show='( ⊙o⊙?)不懂,你可以嘗試說:hello,name,time,再見,天王蓋地虎.';
}
$websocket->write($sign,'Robot:'.$show);
}
?>
index.html
<!doctype html>
<html>
<head>
<meta charset="utf-8">
<title>websocket_TEST</title>
</head>
<body>
<textarea class="log" style="width: 100%; height: 500px;">
=======websocket======
</textarea>
<input type="button" value="連接" onClick="link()">
<input type="button" value="斷開" onClick="dis()">
<input type="text" id="text">
<input type="button" value="發(fā)送" onClick="send()">
<script src="http://libs.baidu.com/jquery/2.0.0/jquery.min.js"></script>
<script>
function link(){
var url='ws://192.168.0.200:8000';
socket=new WebSocket(url);
socket.onopen=function(){log('連接成功')}
socket.onmessage=function(msg){log('獲得消息:'+msg.data);console.log(msg);}
socket.onclose=function(){log('斷開連接')}
}
function dis(){
socket.close();
socket=null;
}
function log(var1){
$('.log').append(var1+"\r\n");
}
function send(){
socket.send($('#text').attr('value'));
}
function send2(){
var json = JSON.stringify({'type':'php','msg':$('#text2').attr('value')})
socket.send(json);
}
</script>
</body>
</html>
websocket.class.php
<?php
/*
創(chuàng)建類websocket($config);
$config結(jié)構(gòu):
$config=array(
'address'=>'192.168.0.200',//綁定地址
'port'=>'8000',//綁定端口
'event'=>'WSevent',//回調(diào)函數(shù)的函數(shù)名
'log'=>true,//命令行顯示記錄
);
回調(diào)函數(shù)返回?cái)?shù)據(jù)格式
function WSevent($type,$event)
$type字符串 事件類型有以下三種
in 客戶端進(jìn)入
out 客戶端斷開
msg 客戶端消息到達(dá)
均為小寫
$event 數(shù)組
$event['k']內(nèi)置用戶列表的userid;
$event['sign']客戶標(biāo)示
$event['msg']收到的消息 $type='msg'時(shí)才有該信息
方法:
run()運(yùn)行
search(標(biāo)示)遍歷取得該標(biāo)示的id
close(標(biāo)示)斷開連接
write(標(biāo)示,信息)推送信息
idwrite(id,信息)推送信息
屬性:
$users 客戶列表
結(jié)構(gòu):
$users=array(
[用戶id]=>array('socket'=>[標(biāo)示],'hand'=[是否握手-布爾值]),
[用戶id]=>arr.....
)
*/
class websocket{
public $log;
public $event;
public $signets;
public $users;
public $master;
public function __construct($config){
if (substr(php_sapi_name(), 0, 3) !== 'cli') {
die("請(qǐng)通過命令行模式運(yùn)行!");
}
error_reporting(E_ALL);
set_time_limit(0);
ob_implicit_flush();
$this->event = $config['event'];
$this->log = $config['log'];
$this->master=$this->WebSocket($config['address'], $config['port']);
$this->sockets=array('s'=>$this->master);
}
function WebSocket($address,$port){
$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($server, $address, $port);
socket_listen($server);
$this->log('開始監(jiān)聽: '.$address.' : '.$port);
return $server;
}
function run(){
while(true){
$changes=$this->sockets;
@socket_select($changes,$write=NULL,$except=NULL,NULL);
foreach($changes as $sign){
if($sign==$this->master){
$client=socket_accept($this->master);
$this->sockets[]=$client;
$user = array(
'socket'=>$client,
'hand'=>false,
);
$this->users[] = $user;
$k=$this->search($client);
$eventreturn = array('k'=>$k,'sign'=>$sign);
$this->eventoutput('in',$eventreturn);
}else{
$len=socket_recv($sign,$buffer,2048,0);
$k=$this->search($sign);
$user=$this->users[$k];
if($len<7){
$this->close($sign);
$eventreturn = array('k'=>$k,'sign'=>$sign);
$this->eventoutput('out',$eventreturn);
continue;
}
if(!$this->users[$k]['hand']){//沒有握手進(jìn)行握手
$this->handshake($k,$buffer);
}else{
$buffer = $this->uncode($buffer);
$eventreturn = array('k'=>$k,'sign'=>$sign,'msg'=>$buffer);
$this->eventoutput('msg',$eventreturn);
}
}
}
}
}
function search($sign){//通過標(biāo)示遍歷獲取id
foreach ($this->users as $k=>$v){
if($sign==$v['socket'])
return $k;
}
return false;
}
function close($sign){//通過標(biāo)示斷開連接
$k=array_search($sign, $this->sockets);
socket_close($sign);
unset($this->sockets[$k]);
unset($this->users[$k]);
}
function handshake($k,$buffer){
$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));
$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));
$this->users[$k]['hand']=true;
return true;
}
function uncode($str){
$mask = array();
$data = '';
$msg = unpack('H*',$str);
$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));
$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++;
}
}
return $data;
}
function code($msg){
$msg = preg_replace(array('/\r$/','/\n$/','/\r\n$/',), '', $msg);
$frame = array();
$frame[0] = '81';
$len = strlen($msg);
$frame[1] = $len<16?'0'.dechex($len):dechex($len);
$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;
}
function idwrite($id,$t){//通過id推送信息
if(!$this->users[$id]['socket']){return false;}//沒有這個(gè)標(biāo)示
$t=$this->code($t);
return socket_write($this->users[$id]['socket'],$t,strlen($t));
}
function write($k,$t){//通過標(biāo)示推送信息
$t=$this->code($t);
return socket_write($k,$t,strlen($t));
}
function eventoutput($type,$event){//事件回調(diào)
call_user_func($this->event,$type,$event);
}
function log($t){//控制臺(tái)輸出
if($this->log){
$t=$t."\r\n";
fwrite(STDOUT, iconv('utf-8','gbk//IGNORE',$t));
}
}
}
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《php socket用法總結(jié)》、《php字符串(string)用法總結(jié)》、《PHP數(shù)學(xué)運(yùn)算技巧總結(jié)》、《php面向?qū)ο蟪绦蛟O(shè)計(jì)入門教程》、《PHP數(shù)組(Array)操作技巧大全》、《PHP數(shù)據(jù)結(jié)構(gòu)與算法教程》、《php程序設(shè)計(jì)算法總結(jié)》及《PHP網(wǎng)絡(luò)編程技巧總結(jié)》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
相關(guān)文章
通過php動(dòng)態(tài)傳數(shù)據(jù)到highcharts
本文主要介紹了通過php動(dòng)態(tài)傳數(shù)據(jù)到highcharts的相關(guān)知識(shí)。具有很好的參考價(jià)值。下面跟著小編一起來看下吧2017-04-04
今天看thinkphp演示文檔看到這個(gè)ubb的代碼感覺還可以。2011-11-11
PHP內(nèi)存溢出指的是在PHP應(yīng)用程序中,分配給腳本執(zhí)行的內(nèi)存超出了PHP配置文件中設(shè)置的限制,當(dāng)腳本嘗試使用比可用內(nèi)存更多的內(nèi)存時(shí),就會(huì)發(fā)生內(nèi)存溢出錯(cuò)誤,本文給大家介紹了PHP內(nèi)存溢出的原因及解決方法,需要的朋友可以參考下2023-12-12
php !function_exists("T7FC56270E7A70FA81A5935B72EACBE29
今天在百度知道上面有個(gè)朋友問php代碼解密的問題，看了代碼不是常見幾種比較感興趣，特意搜索了下，發(fā)現(xiàn)下面的方法，解決了，具體的看最后的說明。2011-01-01
本文主要介紹了如何減少Hyper框架的掃描時(shí)間，對(duì)PHP協(xié)程框架感興趣的同學(xué)，可以參考下。2021-05-05
PHP版微信第三方實(shí)現(xiàn)一鍵登錄及獲取用戶信息的方法
這篇文章主要介紹了PHP版微信第三方實(shí)現(xiàn)一鍵登錄及獲取用戶信息的方法,較為詳細(xì)的分析了微信第三方登陸的相關(guān)注意事項(xiàng)與實(shí)現(xiàn)技巧,需要的朋友可以參考下2016-10-10
談?wù)凱HP連接Access數(shù)據(jù)庫(kù)的注意事項(xiàng)
有的時(shí)候需要用php連接access數(shù)據(jù)庫(kù)，結(jié)果整了半天Access數(shù)據(jù)庫(kù)就是連接不上，查找很多資料，以下是些個(gè)人經(jīng)驗(yàn)，希望能給需要連接access 數(shù)據(jù)的人帶來幫助。2016-08-08
php判斷某個(gè)方法是否存在函數(shù)function_exists (),method_exists()與is_callabl
這篇文章主要介紹了php判斷某個(gè)方法是否存在函數(shù)function_exists (),method_exists()與is_callable()區(qū)別與用法,結(jié)合實(shí)例形式分析了php function_exists (),method_exists()與is_callable()基本功能、用法、區(qū)別與操作注意事項(xiàng),需要的朋友可以參考下2020-04-04
htmlspecialchars()函數(shù)的過濾效果始終不如strip_tags()函數(shù)的過濾效果好，下面有個(gè)不錯(cuò)的方法，感興趣的朋友可以參考下，希望對(duì)大家有所幫助2014-01-01
phpmyadmin的#1251問題...2006-11-11