EN中文
开发者社区 > 程序

使用php创建WebSocket服务

发表于2017-08-01
评论0 2.1k浏览
本篇文章给大家介绍如何使用php创建WebSocket服务，如果对使用php创建WebSocket服务的可以看一看，或许能帮到你们。

执行方法:
首先先修改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. ?>
复制代码
复制代码
  2. /*
  3. 创建类websocket($config);
  4. $config结构:
  5. $config=array(
  6. 'address'=>'192.168.0.200',//绑定地址
  7. 'port'=>'8000',//绑定端口
  8. 'event'=>'WSevent',//回调函数的函数名
  9. 'log'=>true,//命令行显示记录
  10. );
  12. 回调函数返回数据格式
  13. function WSevent($type,$event)
  15. $type字符串 事件类型有以下三种
  16. in 客户端进入
  17. out 客户端断开
  18. msg 客户端消息到达
  19. 均为小写
  21. $event 数组
  22. $event['k']内置用户列表的userid;
  23. $event['sign']客户标示
  24. $event['msg']收到的消息 $type='msg'时才有该信息
  26. 方法:
  27. run()运行
  28. search(标示)遍历取得该标示的id
  29. close(标示)断开连接
  30. write(标示,信息)推送信息
  31. idwrite(id,信息)推送信息
  33. 属性:
  34. $users 客户列表
  35. 结构:
  36. $users=array(
  37. [用户id]=>array('socket'=>[标示],'hand'=[是否握手-布尔值]),
  38. [用户id]=>arr.....
  39. )
  40. */
  42. class websocket{
  43. public $log;
  44. public $event;
  45. public $signets;
  46. public $users;
  47. public $master;
  48. public function __construct($config){
  49. if (substr(php_sapi_name(), 0, 3) !== 'cli') {
  50. die("请通过命令行模式运行!");
  51. }
  52. error_reporting(E_ALL);
  53. set_time_limit(0);
  54. ob_implicit_flush();
  55. $this->event = $config['event'];
  56. $this->log = $config['log'];
  57. $this->master=$this->WebSocket($config['address'], $config['port']);
  58. $this->sockets=array('s'=>$this->master);
  59. }
  60. function WebSocket($address,$port){
  61. $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
  62. socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);
  63. socket_bind($server, $address, $port);
  64. socket_listen($server);
  65. $this->log('开始监听: '.$address.' : '.$port);
  66. return $server;
  67. }
  68. function run(){
  69. while(true){
  70. $changes=$this->sockets;
  71. @socket_select($changes,$write=NULL,$except=NULL,NULL);
  72. foreach($changes as $sign){
  73. if($sign==$this->master){
  74. $client=socket_accept($this->master);
  75. $this->sockets[]=$client;
  76. $user = array(
  77. 'socket'=>$client,
  78. 'hand'=>false,
  79. );
  80. $this->users[] = $user;
  81. $k=$this->search($client);
  82. $eventreturn = array('k'=>$k,'sign'=>$sign);
  83. $this->eventoutput('in',$eventreturn);
  84. }else{
  85. $len=socket_recv($sign,$buffer,2048,0);
  86. $k=$this->search($sign);
  87. $user=$this->users[$k];
  88. if($len<7){
  89. $this->close($sign);
  90. $eventreturn = array('k'=>$k,'sign'=>$sign);
  91. $this->eventoutput('out',$eventreturn);
  92. continue;
  93. }
  94. if(!$this->users[$k]['hand']){//没有握手进行握手
  95. $this->handshake($k,$buffer);
  96. }else{
  97. $buffer = $this->uncode($buffer);
  98. $eventreturn = array('k'=>$k,'sign'=>$sign,'msg'=>$buffer);
  99. $this->eventoutput('msg',$eventreturn);
  100. }
  101. }
  102. }
  103. }
  104. }
  105. function search($sign){//通过标示遍历获取id
  106. foreach ($this->users as $k=>$v){
  107. if($sign==$v['socket'])
  108. return $k;
  109. }
  110. return false;
  111. }
  112. function close($sign){//通过标示断开连接
  113. $k=array_search($sign, $this->sockets);
  114. socket_close($sign);
  115. unset($this->sockets[$k]);
  116. unset($this->users[$k]);
  117. }
  118. function handshake($k,$buffer){
  119. $buf = substr($buffer,strpos($buffer,'Sec-WebSocket-Key:') 18);
  120. $key = trim(substr($buf,0,strpos($buf,"\r\n")));
  121. $new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true));
  122. $new_message = "HTTP/1.1 101 Switching Protocols\r\n";
  123. $new_message .= "Upgrade: websocket\r\n";
  124. $new_message .= "Sec-WebSocket-Version: 13\r\n";
  125. $new_message .= "Connection: Upgrade\r\n";
  126. $new_message .= "Sec-WebSocket-Accept: " . $new_key . "\r\n\r\n";
  127. socket_write($this->users[$k]['socket'],$new_message,strlen($new_message));
  128. $this->users[$k]['hand']=true;
  129. return true;
  130. }
  131. function uncode($str){
  132. $mask = array();
  133. $data = '';
  134. $msg = unpack('H*',$str);
  135. $head = substr($msg[1],0,2);
  136. if (hexdec($head小贝) === 8) {
  137. $data = false;
  138. }else if (hexdec($head小贝) === 1){
  139. $mask[] = hexdec(substr($msg[1],4,2));
  140. $mask[] = hexdec(substr($msg[1],6,2));
  141. $mask[] = hexdec(substr($msg[1],8,2));
  142. $mask[] = hexdec(substr($msg[1],10,2));
  143. $s = 12;
  144. $e = strlen($msg[1])-2;
  145. $n = 0;
  146. for ($i=$s; $i<= $e; $i = 2) {
  147. $data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2)));
  148. $n ;
  149. }
  150. }
  151. return $data;
  152. }
  153. function code($msg){
  154. $msg = preg_replace(array('/\r$/','/\n$/','/\r\n$/',), '', $msg);
  155. $frame = array();
  156. $frame[0] = '81';
  157. $len = strlen($msg);
  158. $frame[1] = $len<16?'0'.dechex($len):dechex($len);
  159. $frame[2] = $this->ord_hex($msg);
  160. $data = implode('',$frame);
  161. return pack("H*", $data);
  162. }
  163. function ord_hex($data) {
  164. $msg = '';
  165. $l = strlen($data);
  166. for ($i= 0; $i<$l; $i ) {
  167. $msg .= dechex(ord($data{$i}));
  168. }
  169. return $msg;
  170. }
  172. function idwrite($id,$t){//通过id推送信息
  173. if(!$this->users[$id]['socket']){return false;}//没有这个标示
  174. $t=$this->code($t);
  175. return socket_write($this->users[$id]['socket'],$t,strlen($t));
  176. }
  177. function write($k,$t){//通过标示推送信息
  178. $t=$this->code($t);
  179. return socket_write($k,$t,strlen($t));
  180. }
  181. function eventoutput($type,$event){//事件回调
  182. call_user_func($this->event,$type,$event);
  183. }
  184. function log($t){//控制台输出
  185. if($this->log){
  186. $t=$t."\r\n";
  187. fwrite(STDOUT, iconv('utf-8','gbk//IGNORE',$t));
  188. }
  189. }
  190. }

如社区发表内容存在侵权行为，您可以点击这里查看侵权投诉指引

标签：

ListArrayJSONjQueryIPTCP/IP