欢迎各位兄弟 发布技术文章

这里的技术是共享的

You are here

浅谈php中使用websocket 有大用


php  swool_websocket_server

image.png

服务器端代码:  index.php


image.png

启动服务

image.png

检查端口

image.png


http error 400  因为需要通过我们对应的 websocket

image.png


前台的websocket index.html

image.png

image.png


浏览器

image.png


服务器端

image.png







浅谈php中使用websocket            

在PHP中,开发者需要考虑的东西比较多,从socket的连接、建立、绑定、监听等都需要开发者自己去操作完成,对于初学者来说,难度方面也挺大的,所以本文的思路如下:

1、socket协议的简介

2、介绍client与server之间的连接原理

3、PHP中建立socket的过程讲解

4、用一个聊天室作为实例详细讲解在PHP中如何使用socket

一、socket协议的简介                    

  WebSocket是什么,有什么优点                    

  WebSocket是一个持久化的协议,这是相对于http非持久化来说的。

  举个简单的例子,http1.0的生命周期是以request作为界定的,也就是一个request,一个response,对于http来说,本次client与server的会话到此结束;而在http1.1中,稍微有所改进,即添加了keep-alive,也就是在一个http连接中可以进行多个request请求和多个response接受操作。然而在实时通信中,并没有多大的作用,http只能由client发起请求,server才能返回信息,即server不能主动向client推送信息,无法满足实时通信的要求。而WebSocket可以进行持久化连接,即client只需进行一次握手,成功后即可持续进行数据通信,值得关注的是WebSocket实现client与server之间全双工通信,即server端有数据更新时可以主动推送给client端。

二、介绍client与server之间的socket连接原理                    

1、下面是一个演示client和server之间建立WebSocket连接时握手部分                    

                      

 

2、client与server建立socket时握手的会话内容,即request与response                    

  a、client建立WebSocket时向服务器端请求的信息                    

  GET /chat HTTP/1.1
  Host: server.example.com
  Upgrade: websocket //告诉服务器现在发送的是WebSocket协议
  Connection: Upgrade
  Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw== //是一个Base64 encode的值,这个是浏览器随机生成的,用于验证服务器端返回数据是否是WebSocket助理
  Sec-WebSocket-Protocol: chat, superchat
  Sec-WebSocket-Version: 13
  Origin: http://example.com

  b、服务器获取到client请求的信息后,根据WebSocket协议对数据进行处理并返回,其中要对Sec-WebSocket-Key进行加密等操作                    

  HTTP/1.1 101 Switching Protocols
  Upgrade: websocket //依然是固定的,告诉客户端即将升级的是Websocket协议,而不是mozillasocket,lurnarsocket或者shitsocket
  Connection: Upgrade
  Sec-WebSocket-Accept: HSmrc0sMlYUkAGmm5OPpG2HaGWk= //这个则是经过服务器确认,并且加密过后的 Sec-WebSocket-Key,也就是client要求建立WebSocket验证的凭证
  Sec-WebSocket-Protocol: chat

 

3、socket建立连接原理图:                    

                      

 

 

三、PHP中建立socket的过程讲解                    

1、在PHP中,client与server之间建立socket通信,首先在PHP中创建socket并监听端口信息,代码如下:                    

1
2
3
4
5
6
7
8
//传相应的IP与端口进行创建socket操作                                                    
function WebSocket($address,$port){                                                    
    $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);                                                    
    socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);//1表示接受所有的数据包                                                    
    socket_bind($server$address$port);                                                    
    socket_listen($server);                                                    
    return $server;                                                    
}                                                    

2、设计一个循环挂起WebSocket通道,进行数据的接收、处理和发送                    

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
//对创建的socket循环进行监听,处理数据                                                    
function run(){                                                    
    //死循环,直到socket断开                                                    
    while(true){                                                    
        $changes=$this->sockets;                                                    
        $write=NULL;                                                    
        $except=NULL;                                                    
         
        /*                                                    
        //这个函数是同时接受多个连接的关键,我的理解它是为了阻塞程序继续往下执行。                                                    
        socket_select ($sockets, $write = NULL, $except = NULL, NULL);                                                    
 
        $sockets可以理解为一个数组,这个数组中存放的是文件描述符。当它有变化(就是有新消息到或者有客户端连接/断开)时,socket_select函数才会返回,继续往下执行。                                                    
        $write是监听是否有客户端写数据,传入NULL是不关心是否有写变化。                                                    
        $except是$sockets里面要被排除的元素,传入NULL是”监听”全部。                                                    
        最后一个参数是超时时间                                                    
        如果为0:则立即结束                                                    
        如果为n>1: 则最多在n秒后结束,如遇某一个连接有新动态,则提前返回                                                    
        如果为null:如遇某一个连接有新动态,则返回                                                    
        */                                                    
        socket_select($changes,$write,$except,NULL);                                                    
        foreach($changes as $sock){                                                    
             
            //如果有新的client连接进来,则                                                    
            if($sock==$this->master){                                                    
 
                //接受一个socket连接                                                    
                $client=socket_accept($this->master);                                                    
 
                //给新连接进来的socket一个唯一的ID                                                    
                $key=uniqid();                                                    
                $this->sockets[]=$client;  //将新连接进来的socket存进连接池                                                    
                $this->users[$key]=array(                                                    
                    'socket'=>$client,  //记录新连接进来client的socket信息                                                    
                    'shou'=>false       //标志该socket资源没有完成握手                                                    
                );                                                    
            //否则1.为client断开socket连接,2.client发送信息                                                    
            }else{                                                    
                $len=0;                                                    
                $buffer='';                                                    
                //读取该socket的信息,注意:第二个参数是引用传参即接收数据,第三个参数是接收数据的长度                                                    
                do{                                                    
                    $l=socket_recv($sock,$buf,1000,0);                                                    
                    $len+=$l;                                                    
                    $buffer.=$buf;                                                    
                }while($l==1000);                                                    
 
                //根据socket在user池里面查找相应的$k,即健ID                                                    
                $k=$this->search($sock);                                                    
 
                //如果接收的信息长度小于7,则该client的socket为断开连接                                                    
                if($len<7){                                                    
                    //给该client的socket进行断开操作,并在$this->sockets和$this->users里面进行删除                                                    
                    $this->send2($k);                                                    
                    continue;                                                    
                }                                                    
                //判断该socket是否已经握手                                                    
                if(!$this->users[$k]['shou']){                                                    
                    //如果没有握手,则进行握手处理                                                    
                    $this->woshou($k,$buffer);                                                    
                }else{                                                    
                    //走到这里就是该client发送信息了,对接受到的信息进行uncode处理                                                    
                    $buffer $this->uncode($buffer,$k);                                                    
                    if($buffer==false){                                                    
                        continue;                                                    
                    }                                                    
                    //如果不为空,则进行消息推送操作                                                    
                    $this->send($k,$buffer);                                                    
                }                                                    
            }                                                    
        }                                                    
         
    }                                                    
     
}                                                    

3、以上服务器端完成的WebSocket的前期工作后,就等着client连接进行,client创建WebSocket很简单,代码如下:                    

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
var ws = new WebSocket("ws://IP:端口");                                                    
//握手监听函数                                                    
ws.onopen=function(){                                                    
     //状态为1证明握手成功,然后把client自定义的名字发送过去                                                    
    if(so.readyState==1){                                                    
         //握手成功后对服务器发送信息                                                    
     so.send('type=add&ming='+n);                                                    
    }                                                    
}                                                    
//错误返回信息函数                                                    
ws.onerror = function(){                                                    
    console.log("error");                                                    
};                                                    
//监听服务器端推送的消息                                                    
ws.onmessage = function (msg){                                                    
    console.log(msg);                                                    
}                                                    
 
//断开WebSocket连接                                                    
ws.onclose = function(){                                                    
    ws = false;                                                    
}                                                    

四、聊天室实例代码                    

1、PHP部分                    

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
<?php                                                    
error_reporting(E_ALL ^ E_NOTICE);                                                    
ob_implicit_flush();                                                    
 
//地址与接口,即创建socket时需要服务器的IP和端口                                                    
$sk=new Sock('127.0.0.1',8000);                                                    
 
//对创建的socket循环进行监听,处理数据                                                    
$sk->run();                                                    
 
//下面是sock类                                                    
class Sock{                                                    
    public $sockets//socket的连接池,即client连接进来的socket标志                                                    
    public $users;   //所有client连接进来的信息,包括socket、client名字等                                                    
    public $master;  //socket的resource,即前期初始化socket时返回的socket资源                                                    
     
    private $sda=array();   //已接收的数据                                                    
    private $slen=array();  //数据总长度                                                    
    private $sjen=array();  //接收数据的长度                                                    
    private $ar=array();    //加密key                                                    
    private $n=array();                                                    
     
    public function __construct($address$port){                                                    
 
        //创建socket并把保存socket资源在$this->master                                                    
        $this->master=$this->WebSocket($address$port);                                                    
 
        //创建socket连接池                                                    
        $this->sockets=array($this->master);                                                    
    }                                                    
     
    //对创建的socket循环进行监听,处理数据                                                    
    function run(){                                                    
        //死循环,直到socket断开                                                    
        while(true){                                                    
            $changes=$this->sockets;                                                    
            $write=NULL;                                                    
            $except=NULL;                                                    
             
            /*                                                    
            //这个函数是同时接受多个连接的关键,我的理解它是为了阻塞程序继续往下执行。                                                    
            socket_select ($sockets, $write = NULL, $except = NULL, NULL);                                                    
 
            $sockets可以理解为一个数组,这个数组中存放的是文件描述符。当它有变化(就是有新消息到或者有客户端连接/断开)时,socket_select函数才会返回,继续往下执行。                                                    
            $write是监听是否有客户端写数据,传入NULL是不关心是否有写变化。                                                    
            $except是$sockets里面要被排除的元素,传入NULL是”监听”全部。                                                    
            最后一个参数是超时时间                                                    
            如果为0:则立即结束                                                    
            如果为n>1: 则最多在n秒后结束,如遇某一个连接有新动态,则提前返回                                                    
            如果为null:如遇某一个连接有新动态,则返回                                                    
            */                                                    
            socket_select($changes,$write,$except,NULL);                                                    
            foreach($changes as $sock){                                                    
                 
                //如果有新的client连接进来,则                                                    
                if($sock==$this->master){                                                    
 
                    //接受一个socket连接                                                    
                    $client=socket_accept($this->master);                                                    
 
                    //给新连接进来的socket一个唯一的ID                                                    
                    $key=uniqid();                                                    
                    $this->sockets[]=$client;  //将新连接进来的socket存进连接池                                                    
                    $this->users[$key]=array(                                                    
                        'socket'=>$client,  //记录新连接进来client的socket信息                                                    
                        'shou'=>false       //标志该socket资源没有完成握手                                                    
                    );                                                    
                //否则1.为client断开socket连接,2.client发送信息                                                    
                }else{                                                    
                    $len=0;                                                    
                    $buffer='';                                                    
                    //读取该socket的信息,注意:第二个参数是引用传参即接收数据,第三个参数是接收数据的长度                                                    
                    do{