recherche

Maison  >  Article  >  développement back-end  >  使用php创建WebSocket服务

使用php创建WebSocket服务

WBOY
WBOYoriginal
2016-07-25 08:50:471795parcourir
执行方法:
首先先修改server.php与index.html的ip
通过命令行执行 [php路径]\php.exe "[文件路径]\server.php"
然后通过浏览器打开index.html
  2. include 'websocket.class.php';
  4. $config=array(
  5. 'address'=>'192.168.0.200',
  6. 'port'=>'8000',
  7. 'event'=>'WSevent',//回调函数的函数名
  8. 'log'=>true,
  9. );
  10. $websocket = new websocket($config);
  11. $websocket->run();
  12. function WSevent($type,$event){
  13. global $websocket;
  14. if('in'==$type){
  15. $websocket->log('客户进入id:'.$event['k']);
  16. }elseif('out'==$type){
  17. $websocket->log('客户退出id:'.$event['k']);
  18. }elseif('msg'==$type){
  19. $websocket->log($event['k'].'消息:'.$event['msg']);
  20. roboot($event['sign'],$event['msg']);
  21. }
  22. }
  24. function roboot($sign,$t){
  25. global $websocket;
  26. switch ($t)
  27. {
  28. case 'hello':
  29. $show='hello,GIt @ OSC';
  30. break;
  31. case 'name':
  32. $show='Robot';
  33. break;
  34. case 'time':
  35. $show='当前时间:'.date('Y-m-d H:i:s');
  36. break;
  37. case '再见':
  38. $show='( ^_^ )/~~拜拜';
  39. $websocket->write($sign,'Robot:'.$show);
  40. $websocket->close($sign);
  41. return;
  42. break;
  43. case '天王盖地虎':
  44. $array = array('小鸡炖蘑菇','宝塔震河妖','粒粒皆辛苦');
  45. $show = $array[rand(0,2)];
  46. break;
  47. default:
  48. $show='( ⊙o⊙?)不懂,你可以尝试说:hello,name,time,再见,天王盖地虎.';
  49. }
  50. $websocket->write($sign,'Robot:'.$show);
  51. }
  52. ?>
复制代码
  5. websocket_TEST
  14. <script><li>function link(){<li> var url='ws://192.168.0.200:8000';<li> socket=new WebSocket(url);<li> socket.onopen=function(){log('连接成功')}<li> socket.onmessage=function(msg){log('获得消息:'+msg.data);console.log(msg);}<li> socket.onclose=function(){log('断开连接')}<li>}<li>function dis(){<li> socket.close();<li> socket=null;<li>}<li>function log(var1){<li> $('.log').append(var1+"\r\n");<li>}<li>function send(){<li> socket.send($('#text').attr('value'));<li>}<li>function send2(){<li> var json = JSON.stringify({'type':'php','msg':$('#text2').attr('value')})<li> socket.send(json);<li>}<li></script>
复制代码
  1. /*
  2. 创建类websocket($config);
  3. $config结构:
  4. $config=array(
  5. 'address'=>'192.168.0.200',//绑定地址
  6. 'port'=>'8000',//绑定端口
  7. 'event'=>'WSevent',//回调函数的函数名
  8. 'log'=>true,//命令行显示记录
  9. );
  11. 回调函数返回数据格式
  12. function WSevent($type,$event)
  14. $type字符串 事件类型有以下三种
  15. in 客户端进入
  16. out 客户端断开
  17. msg 客户端消息到达
  18. 均为小写
  20. $event 数组
  21. $event['k']内置用户列表的userid;
  22. $event['sign']客户标示
  23. $event['msg']收到的消息 $type='msg'时才有该信息
  25. 方法:
  26. run()运行
  27. search(标示)遍历取得该标示的id
  28. close(标示)断开连接
  29. write(标示,信息)推送信息
  30. idwrite(id,信息)推送信息
  32. 属性:
  33. $users 客户列表
  34. 结构:
  35. $users=array(
  36. [用户id]=>array('socket'=>[标示],'hand'=[是否握手-布尔值]),
  37. [用户id]=>arr.....
  38. )
  39. */
  41. class websocket{
  42. public $log;
  43. public $event;
  44. public $signets;
  45. public $users;
  46. public $master;
  47. public function __construct($config){
  48. if (substr(php_sapi_name(), 0, 3) !== 'cli') {
  49. die("请通过命令行模式运行!");
  50. }
  51. error_reporting(E_ALL);
  52. set_time_limit(0);
  53. ob_implicit_flush();
  54. $this->event = $config['event'];
  55. $this->log = $config['log'];
  56. $this->master=$this->WebSocket($config['address'], $config['port']);
  57. $this->sockets=array('s'=>$this->master);
  58. }
  59. function WebSocket($address,$port){
  60. $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
  61. socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);
  62. socket_bind($server, $address, $port);
  63. socket_listen($server);
  64. $this->log('开始监听: '.$address.' : '.$port);
  65. return $server;
  66. }
  67. function run(){
  68. while(true){
  69. $changes=$this->sockets;
  70. @socket_select($changes,$write=NULL,$except=NULL,NULL);
  71. foreach($changes as $sign){
  72. if($sign==$this->master){
  73. $client=socket_accept($this->master);
  74. $this->sockets[]=$client;
  75. $user = array(
  76. 'socket'=>$client,
  77. 'hand'=>false,
  78. );
  79. $this->users[] = $user;
  80. $k=$this->search($client);
  81. $eventreturn = array('k'=>$k,'sign'=>$sign);
  82. $this->eventoutput('in',$eventreturn);
  83. }else{
  84. $len=socket_recv($sign,$buffer,2048,0);
  85. $k=$this->search($sign);
  86. $user=$this->users[$k];
  87. if($len $this->close($sign);
  88. $eventreturn = array('k'=>$k,'sign'=>$sign);
  89. $this->eventoutput('out',$eventreturn);
  90. continue;
  91. }
  92. if(!$this->users[$k]['hand']){//没有握手进行握手
  93. $this->handshake($k,$buffer);
  94. }else{
  95. $buffer = $this->uncode($buffer);
  96. $eventreturn = array('k'=>$k,'sign'=>$sign,'msg'=>$buffer);
  97. $this->eventoutput('msg',$eventreturn);
  98. }
  99. }
  100. }
  101. }
  102. }
  103. function search($sign){//通过标示遍历获取id
  104. foreach ($this->users as $k=>$v){
  105. if($sign==$v['socket'])
  106. return $k;
  107. }
  108. return false;
  109. }
  110. function close($sign){//通过标示断开连接
  111. $k=array_search($sign, $this->sockets);
  112. socket_close($sign);
  113. unset($this->sockets[$k]);
  114. unset($this->users[$k]);
  115. }
  116. function handshake($k,$buffer){
  117. $buf = substr($buffer,strpos($buffer,'Sec-WebSocket-Key:')+18);
  118. $key = trim(substr($buf,0,strpos($buf,"\r\n")));
  119. $new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true));
  120. $new_message = "HTTP/1.1 101 Switching Protocols\r\n";
  121. $new_message .= "Upgrade: websocket\r\n";
  122. $new_message .= "Sec-WebSocket-Version: 13\r\n";
  123. $new_message .= "Connection: Upgrade\r\n";
  124. $new_message .= "Sec-WebSocket-Accept: " . $new_key . "\r\n\r\n";
  125. socket_write($this->users[$k]['socket'],$new_message,strlen($new_message));
  126. $this->users[$k]['hand']=true;
  127. return true;
  128. }
  129. function uncode($str){
  130. $mask = array();
  131. $data = '';
  132. $msg = unpack('H*',$str);
  133. $head = substr($msg[1],0,2);
  134. if (hexdec($head小贝) === 8) {
  135. $data = false;
  136. }else if (hexdec($head小贝) === 1){
  137. $mask[] = hexdec(substr($msg[1],4,2));
  138. $mask[] = hexdec(substr($msg[1],6,2));
  139. $mask[] = hexdec(substr($msg[1],8,2));
  140. $mask[] = hexdec(substr($msg[1],10,2));
  141. $s = 12;
  142. $e = strlen($msg[1])-2;
  143. $n = 0;
  144. for ($i=$s; $i $data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2)));
  145. $n++;
  146. }
  147. }
  148. return $data;
  149. }
  150. function code($msg){
  151. $msg = preg_replace(array('/\r$/','/\n$/','/\r\n$/',), '', $msg);
  152. $frame = array();
  153. $frame[0] = '81';
  154. $len = strlen($msg);
  155. $frame[1] = $len $frame[2] = $this->ord_hex($msg);
  156. $data = implode('',$frame);
  157. return pack("H*", $data);
  158. }
  159. function ord_hex($data) {
  160. $msg = '';
  161. $l = strlen($data);
  162. for ($i= 0; $i $msg .= dechex(ord($data{$i}));
  163. }
  164. return $msg;
  165. }
  167. function idwrite($id,$t){//通过id推送信息
  168. if(!$this->users[$id]['socket']){return false;}//没有这个标示
  169. $t=$this->code($t);
  170. return socket_write($this->users[$id]['socket'],$t,strlen($t));
  171. }
  172. function write($k,$t){//通过标示推送信息
  173. $t=$this->code($t);
  174. return socket_write($k,$t,strlen($t));
  175. }
  176. function eventoutput($type,$event){//事件回调
  177. call_user_func($this->event,$type,$event);
  178. }
  179. function log($t){//控制台输出
  180. if($this->log){
  181. $t=$t."\r\n";
  182. fwrite(STDOUT, iconv('utf-8','gbk//IGNORE',$t));
  183. }
  184. }
  185. }
复制代码


Déclaration：
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Article précédent：程序员的工作环境与效率 Article suivant：MyPHP a simple PHP Framework v0.05

Articles Liés

Voir plus