websocket.class.php:

<?php header("Content-type: text/html; charset=utf-8"); /* 創(chuàng)建類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($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); }public 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; }public 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']) {//沒有握手進行握手 $this->handshake($k,$buffer); } else { $buffer = $this->uncode($buffer); $eventreturn = array('k' => $k,'sign' => $sign, 'msg' => $buffer); $this->eventoutput('msg', $eventreturn); } } } } }public function search($sign) {//通過標示遍歷獲取idforeach ($this->users as $k => $v) {if($sign == $v['socket']) {return $k;}} return false; } public function close($sign) {//通過標示斷開連接 $k=array_search($sign, $this->sockets); socket_close($sign); unset($this->sockets[$k]); unset($this->users[$k]); } public 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; }public 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; }public 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); }public function ord_hex($data) { $msg = ''; $l = strlen($data); for($i= 0; $i<$l; $i++) { $msg .= dechex(ord($data{$i})); } return $msg; } public function idwrite($id,$t) {//通過id推送信息 if(!$this->users[$id]['socket']){return false;}//沒有這個標示 $t=$this->code($t); return socket_write($this->users[$id]['socket'],$t,strlen($t)); }public function write($k,$t) {//通過標示推送信息 $t=$this->code($t); return socket_write($k,$t,strlen($t)); } public function eventoutput($type,$event) {//事件回調 call_user_func($this->event,$type,$event); }public function log($t) {//控制臺輸出 if($this->log) { $t=$t."\r\n"; fwrite(STDOUT, iconv('utf-8','gbk//IGNORE',$t)); } } }server.php:

<?php header("Content-type: text/html; charset=utf-8"); include 'websocket.class.php'; $config = array( 'address'=>'10.16.77.216', 'port'=>'8008', 'event'=>'WSevent',//回調函數的函數名 'log'=>true, ); $websocket = new websocket($config); $websocket->run(); function WSevent($type, $event){ global $websocket; if ('in' == $type) { $websocket->log('客戶進入id: ' . $event['k']); } else if ('out' == $type) { $websocket->log('客戶退出id: ' . $event['k']); } else if ('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 = '當前時間:' . 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 type="text/javascript" src="jquery-1.7.1.min.js"></script> <script> function link(){ var url='ws://10.16.77.216:8008'; 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').val()); } function send2(){ var json = JSON.stringify({'type':'php','msg':$('#text').val()}) socket.send(json); } </script> </body> </html>運行界面：

總結

以上是生活随笔為你收集整理的websocket 聊天机器人的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。