php原生websocket-創(chuàng)新互聯(lián)

class websocket {     public $log;     public $event;     public $signets;     public $users;     public $master;     public $obj;     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->obj = $config['obj'];         $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']) {//沒有握手進行握手                         $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;         }//沒有這個標(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(array($this->obj, $this->event), $this, $type, $event);     }     function log($t)     {//控制臺輸出         if ($this->log) {             $t = $t . "\r\n";             fwrite(STDOUT, $t);         }     } }

server.php

成都創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于網(wǎng)站設(shè)計、網(wǎng)站建設(shè)、甕安網(wǎng)絡(luò)推廣、成都小程序開發(fā)、甕安網(wǎng)絡(luò)營銷、甕安企業(yè)策劃、甕安品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運營等，從售前售中售后，我們都將竭誠為您服務(wù)，您的肯定，是我們大的嘉獎；成都創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供甕安建站搭建服務(wù)，24小時服務(wù)熱線：028-86922220，官方網(wǎng)址：muchs.cn<?php include('websocket.class.php');   $config=array(   'address'=>'192.168.1.12',   '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('客戶進入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)前時間:'.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); } ?>

在終端 php server.php

index.html

<!doctype html> <html> <head> <meta charset="utf-8"> <title>websocket_TEST</title> </head> <body> <a href="index2.html">index2</a> <textarea class="log" > </textarea> <input type="button" value="連接" onClick="link()">  <input type="button" value="斷開" onClick="dis()"> <input type="text" id="text2"> <input type="button" value="發(fā)送" onClick="send2()"> <script src="http://jt.hiooy.com/hsshop/js/jquery.js?v=59"></script> <script> function link(){   var url='ws://192.168.1.12: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>

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

當(dāng)前題目：php原生websocket-創(chuàng)新互聯(lián)
網(wǎng)址分享：http://muchs.cn/article22/deiecc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供移動網(wǎng)站建設(shè)、小程序開發(fā)、全網(wǎng)營銷推廣、Google、軟件開發(fā)、網(wǎng)站設(shè)計

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

商城網(wǎng)站建設(shè)