使用php建立WebSocket服務

執行方法:
先修改server.php與index.html的ip
透過命令列執行[php路徑]php.exe "[檔案路徑]server.php"
再透過瀏覽器開啟index .html

include 'websocket.class.php';

$config=array(
 'address'=>'192.168.0.200' ,
 'port'=>'8000',
 'event'=>'WSevent',//回呼函數的函數名稱
 'log'=>true,
);
 $websocket = new websocket($config);
$websocket->run();
function WSevent($type,$event){
 global $websocket;
 if('in'= =$type){
 $websocket->log('客戶進入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 @GIt @ OSC';
 break;
 case 'name':
 $show='Robot';
 break;
 case 'time':
 $show='當前時間:' .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);
}
?>

websocket_TEST<li>
<li>
<li><textarea class="log" style="width: 100%; height: 500px;"><li>======= websocket======</li>
<li></textarea></li>
<li>
<input type="button" value="連接" onclick="link()"> </li>
<li><input type="button" value="斷開" onclick="dis()"></li>
<li><input type="text" id="text"></li>
<li>
<input type="button" value="發送" onclick="send()"> </li>
<li><script type="text/javascript" src="https://ajax.googleapis.com/ajax/libs/jquery/1.4.4/jquery.min.js"></script></li>
<li>
<li>function link(){</li>
<li> var url='ws://192.168.0.200:8000';</li>
<li> socket=new WebSocket(url);</li>
<li> socket.openon=function(){ log('連線成功')}</li>
<li> socket.onmessage=function(msg){log('取得訊息:' msg.data);console.log(msg);}</li>
<li> socket.onclose=function() {log('斷開連接')}</li>
<li>}</li>
<li>function dis(){</li>
<li> socket.close();</li>
<li> socket=null;</li>
<li>}</li>
<li>function log(var1) {</li>
<li> $('.log').append(var1 "rn");</li>
<li>}</li>
<li>function send(){</li>
<li> socket.send($('#text').attr(' value'));</li>
<li>}</li>
<li>function send2(){</li>
<li> var json = JSON.stringify({'type':'php','msg':$('#text2').attr( 'value')})</li>
<li> socket.send(json);</li>
<li>}</li>
<li>
<li>
<li>

/*
建立類別websocket($config);
$config結構:
$config=array( ' address'=>'192.168.0.200',//綁定位址
 'port'=>'8000',//綁定連接埠
 'event'=>'WSevent',///回呼函數的函數名
 'log'=>true,//命令列顯示記錄
);

回呼函數回傳資料格式
function WSevent($type,$event)

$type字串事件類型有以下三種
in 用戶端進入
out 用戶端斷開
msg 用戶端訊息到達
皆為小寫

$event 陣列
$event['k']內建使用者清單的userid;
$event['sign']客戶標示
$event['msg']收到的訊息$type='msg'時才有此資訊

方法:
run()運作
search(標示)遍歷取得此標示的id
close(標示)斷開連線
write(推送標示,訊息)訊息
idwrite(id,訊息)推播訊息

屬性:
$users 客戶清單
結構:
$users=array(
[使用者id]=>array ('socket'=>[標示],'hand'=[是否握手-布林值]),
[使用者id]=>arr.....
)
*/

class websocket{
 public $log;
 public $event;
 public $signets;
 public $users;
 public $master;
 public function __construct($configtion __construct($config ){
 if (substr(php_sapi_name(), 0, 3) !== 'cli') {
 die("請透過命令列模式執行!");
 }
 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(SOCA), SOL_TCP);
 socket_set_option($D), SOL_SOCS. , 1);
 socket_bind($server, $address, $port);
 socket_listen($server);
 $this->log('開始監聽: '.$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 $ this->close($sign);
 $eventreturn = array('k'=>$k,'sign'=>$sign);
 $this->eventoutput('out',$eventreturn) ;
 continue;
 }
 if(!$this->users[$k]['hand']){//沒有握手握手
 $this->handshake($k, $buffer);
 }else{
 $buffer = $this->uncode($buffer);
 $eventreturn = array('k'=>$k,'sign'=>$sign, 'msg'=>$buffer);
 $this->eventoutput('msg',$eventreturn);
 }
 }
 }
 }
 }
 function search($sign){//透過標示遍歷取得id
 foreach ($this->users as $k=>$v){
 if($sign==$v['socket'])
 return $k;
 }
 return false;
 }
 function close($sign){//透過標示斷開連接
 $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,"rn")));
 $new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true));
 $new_message = "HTTP/1.1 101 Switching Protocolsrn";
 $new_message .= "Upgrade: websocketrn";
 $new_message .= "Sec-WebSocket-Version: 1🎜> $new_message .= "Sec-WebSocket-Version: 1🎜> $new_message .= "Sec-WebSocket-Version: 1🎜> $new_message .= "Sec-WebSocket-Version: 133"; $new_message .= "Sec-WebSocket-Accept: " . $new_key . "rnrn";
 socket_write($this->users[$k]['socket'],$new_message ,strlen($new_message));