使用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. ?>

复制代码

8. <li>=======websocket======</li> <li>

复制代码

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. }

复制代码