php实现websocket实时消息推送

admin

php实现websocket实时消息推送
$ w1 F9 T9 N; `9 c, v8 l0 _
$ o- R) m% {" b. F2 F1 w* m$ W
" R# P0 Z# @; H, N9 aSocketService.php
- {" g, ]3 T; F2 V  r

1. <?php
   4 j5 `* S  T0 H% V6 Z
2. /**
   7 n3 O- c; H& S2 M, ^0 m& c& W6 i
3. * Created by xwx
   0 f& z! j0 `9 r) L7 F
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   & z( q* k/ k5 e2 U$ H5 S5 c0 [# i
7. 
   
8. class SocketService
   
9. {
   ) \' J$ z! V3 U. ~
10.     private $address  = '0.0.0.0';
    " |% w3 m7 l% z! W
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    , o: v1 g" H) ~0 k/ A! R- y
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    / d$ N8 P+ l8 S
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    
29.         {
    $ \+ \5 M: [* V" l2 r0 a
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    : |0 P0 `- O% s+ }1 f
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    8 d1 G2 p' W; `- F- @
36.     }
    
37. 
    
38.     public function run(){
    / l) O5 c  n6 y8 y8 x: q( Z
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    1 B3 O* l7 _! F  }: Q9 d. }
42.             $changes = $clients;
    % y# b3 ~. I; d/ h& w7 o) e
43.             $write = NULL;
    " {" l. q8 h. r* e. W% ?
44.             $except = NULL;
    7 i9 j0 u2 X7 O, F) ~
45.             socket_select($changes,  $write,  $except, NULL);
    : z$ j- \( h( i6 ~  g! S% w8 a2 p8 f
46.             foreach ($changes as $key => $_sock){
    2 V: R7 Z# I* h. I2 R
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    & d( Q. Z- }4 ]$ `7 P2 [
51.                     $line = trim(socket_read($newClient, 1024));
    / X- O4 ~1 x7 U0 I
52.                     $this->handshaking($newClient, $line);
    : I* A: Q5 _; N, z
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    ( N+ a* `6 L" N! d8 C
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    ' c; D) ]' a: k( d/ d
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    " I' H6 n6 \* A- h. q# G
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    9 [3 O2 |$ m' L) }4 e" l; `
68.             }
    
69.         }
    
70.     }
    
71. 
    3 ]# T1 C0 j) t1 W
72.     /**
    & J- d% p, W: Y$ N
73.      * 握手处理
    ! ~# S7 [: G# G1 p- h/ r# ~
74.      * @param $newClient socket
    ; o2 P0 f; V: j4 c( Y% W# w* P. e
75.      * @return int  接收到的信息
    + a  Y$ k, C/ a6 m
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    3 w$ E4 N, I8 y% h7 \  e$ s+ j
80.         $lines = preg_split("/\r\n/", $line);
    # }$ \  g# h) k, y$ L  i+ l& m
81.         foreach($lines as $line)
    
82.         {
    3 I" S" C- U6 O/ c( g+ d
83.             $line = chop($line);
      s& D* B. u/ h; x, H$ B1 w
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    1 z% v. b/ n" q$ w
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    1 D) J  V8 [3 L6 V3 t
88.         }
      Q, Q& h  w# o6 w  @
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    ' w/ R( J& o2 s
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    " L3 G) k$ g+ p6 U1 o/ u
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    / T) ]( T( i6 z* C
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    * S$ p5 K/ i! ^! m
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    & m" D& a. l& _  Y% X3 L
98.     }
    ( T0 |. e& l" I$ d, e' S
99. 
    
100.     /**
     9 }" G& {9 r& }( C
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     ; E' `+ U( I6 }  z4 X
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     . L# @% \9 O- h! ~8 I* C
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     ! w% W& W. \" c9 v0 x
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     9 K) ^9 y6 R  d1 r. ~/ T9 k
118.         for ($index = 0; $index < strlen($data); $index++) {
     , Z: u* h, l/ W
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     % \0 ], `; M# T* L+ ]
121.         return $decoded;
     
122.     }
     - i* N8 s* H+ G6 }2 i
123. 
     
124.     /**
     
125.      * 发送数据
     - j; l7 n4 d* h2 Z7 [
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     ! t' n& u6 x, y0 f0 g, e6 c" X0 ?0 g
128.      * @return int|string
     3 P6 c& d8 N# ?% Z  U% M
129.      */
     
130.     public function send($newClinet, $msg){
     / b9 K3 Z/ J1 j8 y
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     + l. m# L! x2 x; H7 C
134. 
     
135.     public function frame($s) {
     7 ^8 S+ [+ u2 j8 R7 j1 c
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     $ A2 r- l1 w3 [. ~9 m3 c! k" P
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     5 [. d4 H' b) g/ R$ B
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     , }% a4 k& l, C0 ~
143.         }
     
144.         return $ns;
     7 R" G7 P' B% g
145.     }
     / o2 g, p: r+ L" M/ i! {7 p
146. 
     
147.     /**
     ) L; m! ~0 \" g- _* \
148.      * 关闭socket
       f: N/ `- i5 h. I! L/ D4 \
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     # c) ^. t" l) b4 B, o
154. 
     
155. $sock = new SocketService();
     . L! u) I6 @" \0 P- a
156. $sock->run();
     # p& ]7 j6 \* {
157. 
     

复制代码

web.html
, B, }& f3 e6 Y* `5 Y3 a

1. <!doctype html>
   2 h5 j# ?7 G" ?+ D7 C% y/ h
2. <html lang="en">
   
3. <head>
   3 t  Z4 D0 c7 `1 y9 W1 g
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
     c# Y' K9 m* |9 {  N
7. </head>
   % |$ I: k9 F) ^5 A7 [% v
8. <body>
   4 l# Y; g$ p3 m' Q
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    . W' \/ j0 M5 C; q
12. <div id="msg"></div>
    4 V' z; c' f. t* k& l, J4 U
13. <script>
    8 I. b* i0 Q+ j- y2 G
14. /**
    
15. 0：未连接
    % Z0 L. _$ ^$ n9 @
16. 1：连接成功，可通讯
    * A5 z3 y3 ~3 r: `. p' M
17. 2：正在关闭
    2 @1 o) f  L' l. Q$ w
18. 3：连接已关闭或无法打开
    
19. */
    & }: f6 a5 g! }- B( k
20. 
    7 \( z" B6 z. k- a0 r
21.     //创建一个webSocket 实例
    , a, T& V3 K8 t, E
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    6 @2 N$ R! j/ |6 g# i8 \
24. 
    
25.     webSocket.onerror = function (event){
    - j" o5 A; i4 |+ X# _0 t% c
26.         onError(event);
    
27.     };
    
28. 
    
29.     // 打开websocket
    ; o+ H' ]7 v. [# f* p" d  q) t
30.     webSocket.onopen = function (event){
    5 Y! V! m& ]9 b
31.         onOpen(event);
    4 B6 X3 Y% P) X
32.     };
    & H# m( D& {( K0 Z  f- B7 ~
33. 
    - I6 @3 p; P( l
34.     //监听消息
    ) [, m5 D3 w4 [) s1 b2 F
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    ) }' Q0 C' P) ]  B) K. A
37.     };
    ) d: ?$ I: p- ^; @
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    2 G$ _2 A$ O; I# u# I1 ~9 F" B
41.         onClose(event);
    
42.     }
    3 x6 |( t; j$ V/ ]2 c$ G5 N  t% o1 s
43. 
    ! l! l1 J% R- G  X
44.     //关闭监听websocket
    - T- p0 Y% _- c( }. s! ~0 e
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    % S( K) Y4 j4 X0 z3 y0 t
47.         console.log("error"+event.data);
    6 }" f% r4 T! e7 M
48.     };
    
49. 
    
50.     function onOpen(event){
    2 H3 W2 ?1 @7 v/ _# N8 u: z: U% r9 a
51.         console.log("open:"+sockState());
    ' o- R/ F1 {% y; Q# a
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    7 }+ `4 g$ C. o: p; l8 b
54.     function onMessage(event){
    7 P6 t% T3 @' j. s
55.         console.log("onMessage");
    ' A3 h# p  B( r
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    / D+ {& L# S- b
57.     };
    
58. 
    ; l0 Q; z+ t# p: n! B; g
59.     function onClose(event){
    . r, z2 q9 K% e  y1 N/ C
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ' H7 I* W6 d2 l' W0 P+ r; O
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    # {! h5 b, H) l" \
63.     }
    6 y6 e, Y/ G/ l! y( {
64. 
    
65.     function sockState(){
    - o% e% {' y( ~, `
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    4 `8 @* Y& y, P$ q+ l
68.     }
    
69. 
    
70. 
    
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    - E0 T" T. M2 J7 O: e9 w
74.         var msg = document.getElementById('text').value;
    + V8 u. h# J& h! S. A5 S
75.         document.getElementById('text').value = '';
    9 J% d% k: [  J1 v* ~, k
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    ( j, q$ m0 ~  {1 u
78.         webSocket.send("msg="+msg);
    4 R: T% G/ K- z8 I  J; X
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    & O: }. Z( D; g4 k) a3 C! y
84.     }
    
85. </script>
    
86. </body>
    4 i; e5 s* N( b# o6 f3 P" T
87. </html>

复制代码

& N) f  j1 r$ E0 m! m& R/ M' S
6 ^" X. c% n/ e- F9 T