php实现websocket实时消息推送

admin

php实现websocket实时消息推送
6 L8 L2 Z7 K; n" w7 a

SocketService.php

1. <?php
   
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   . m* a% i7 g8 p
6. */
   
7. 
   $ r6 p- h. A# S; g5 S5 v
8. class SocketService
   0 n* d8 D( ]& ~
9. {
   
10.     private $address  = '0.0.0.0';
    / |1 w5 W% i  K: o" ]: n0 Y7 H
11.     private $port = 8083;
    
12.     private $_sockets;
    - ]  D' L* \" K& H% _8 x* Z
13.     public function __construct($address = '', $port='')
    
14.     {
    - {! \. Z0 J* m7 B
15.             if(!empty($address)){
    7 H+ @( Z0 n  H. k7 S  y
16.                 $this->address = $address;
    
17.             }
    8 F! }7 d$ q8 |
18.             if(!empty($port)) {
    & Q0 C1 o9 f& l
19.                 $this->port = $port;
    
20.             }
    5 I9 Y* {/ R  G' d
21.     }
    
22. 
    1 o- b5 ]" r9 i0 a1 Q5 I
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    ' m1 d4 \! X% h
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    $ O& Y" v9 {, s
28.         if($sock < 0)
    5 p% `, D6 s  g
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    ( ~; z2 c& @$ I  U4 l- N) o
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    # f5 e6 J) v7 [$ ^) d
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    0 _) B7 O) N- V' J4 u" K
41.         while (true){
    
42.             $changes = $clients;
    : V; H, q; j# U, Z; s* _6 `# i+ T: H
43.             $write = NULL;
    
44.             $except = NULL;
    & E/ n; }: [1 O9 A  w, o. I0 |
45.             socket_select($changes,  $write,  $except, NULL);
    ' D/ _! @4 y/ [" p
46.             foreach ($changes as $key => $_sock){
    / K& Z7 ?+ s# h# t, D9 g
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    5 A7 }9 k' _1 g% j
48.                     if(($newClient = socket_accept($_sock))  === false){
    . I$ W+ q, Z% _! _* S2 l
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    0 Y/ U/ R2 `5 j" Z6 x6 ?1 ?
50.                     }
    - u, L  W3 d1 E6 \
51.                     $line = trim(socket_read($newClient, 1024));
    . y1 J5 f- p) f/ u
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    ' A# y& W1 C+ @; g% G: b9 |
55.                     $clients[$ip] = $newClient;
    3 L4 y8 }# w. ?9 h8 O
56.                     echo  "Client ip:{$ip}   \n";
    3 e3 I  ?$ _$ @! j
57.                     echo "Client msg:{$line} \n";
    6 P. y- O& o5 z; V/ P/ }
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    * ~' [( o' l" V3 J
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    ) }6 _* y) ]9 L. ]2 v' v6 P% }- r
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    + p, F2 s( P, R! L
64.                     $response = trim(fgets(STDIN));
    ' P! C1 k9 z2 e. r8 W9 u2 G" e/ J
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    3 N) X2 G0 x+ b
68.             }
    
69.         }
    / L* p7 S! @6 n+ d
70.     }
    7 X2 B$ D/ L2 D
71. 
    8 x5 B. g. h; M; M1 w- i2 {# v" A
72.     /**
    
73.      * 握手处理
    + h$ L- }. x+ G) B: `: c/ b
74.      * @param $newClient socket
    2 U! i1 _* f, r- c+ H7 W) E7 X
75.      * @return int  接收到的信息
    
76.      */
    ' w0 {/ k( `: O* l/ V
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    0 ]. Y2 @" L5 `
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    ; ^7 N1 `  x3 s) o8 o$ b5 ]* L
82.         {
    % \* `& O9 l$ `3 p
83.             $line = chop($line);
    7 B7 m2 {+ A& y
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    ) a6 [" g* e  [: [7 e
85.             {
    3 l' h+ I. @0 [
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    ; a) W9 O  O  o/ e: M+ O* r
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    6 {6 f5 A- s; r$ E: e
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    4 S6 y. X- E' [( e0 v& x
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    0 L( A% J4 U# t8 y$ }
99. 
    
100.     /**
     
101.      * 解析接收数据
     # m4 ?( r! A& t  o  \# R1 M
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     7 |/ m. a, q$ h9 A1 z& Z" c) _
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     + [2 n" N: s& V
109.             $masks = substr($buffer, 4, 4);
     ' H/ O+ p5 L. i
110.             $data = substr($buffer, 8);
     + m, J  e0 m/ r9 z, u
111.         } else if ($len === 127)  {
     ' K9 G5 e& A  H5 z2 f) l  u( P
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     # o% I) {" l+ {* n! L6 Z* Y% Y! m; }
114.         } else  {
     2 \8 n  s9 r/ Q  [5 g
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     - {: _* x: \! A: o& B4 x( c
118.         for ($index = 0; $index < strlen($data); $index++) {
     % I! }  X5 X* @/ |3 ]) T4 Y
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     6 J! Q9 ^2 @  ?. b: W, T
120.         }
     5 `* i# t% ~7 H7 K2 W& c2 E
121.         return $decoded;
     
122.     }
     
123. 
     
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     5 C/ \; w" l% J3 y
127.      * @param $msg   要发送的数据
     ' `( k$ T; Y) K
128.      * @return int|string
     9 C: {# Z8 R& E3 a: _
129.      */
     # y2 j% U7 X8 D) ?' Z
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     2 @- R' ?: h8 e6 R. K, k+ F
133.     }
     + y% H7 _/ @+ ?% F# w2 x# W
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     : Q0 w% Y2 e( S0 q; i. R1 \
137.         if (count($a) == 1) {
     ! [9 [. _! M! W1 v3 a0 M
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     # k; ?! N& W& w. k% n( ~4 y
139.         }
     3 i) c( _7 S* e6 c  Z, [
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     * \3 v% }% {) ^9 P/ b* M. t8 l0 z; k
145.     }
     * u3 `! d, I/ Q/ U2 f8 J
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     ' o" x% s( ]" J: Q5 P# R$ t
150.     public function close(){
     % Y3 X* n4 d1 e$ [
151.         return socket_close($this->_sockets);
     ; o# p$ m) F6 F0 U
152.     }
     
153. }
     * h" h8 Z6 O! U  T" ?9 a" @
154. 
     1 m, F2 O  ^& R# F3 {
155. $sock = new SocketService();
     ' z" Y' ?! a  ^* o( ]; j
156. $sock->run();
     0 T7 r/ ]5 @8 t7 U0 k
157. 
     

复制代码

web.html
: g3 W+ l) s% _+ ^4 v

1. <!doctype html>
   
2. <html lang="en">
   " W$ `5 s- `! Z
3. <head>
   1 ^: J* c" H& H! I$ U. a0 \1 I
4.   <meta charset="UTF-8">
   $ `# F2 S* z* k4 q
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   / g& t! o2 r% ]' P
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   ) u5 l$ w' _$ F) T7 |7 b7 ~! d' p. q
9. <input id="text" value="">
   & f; E! g1 S& n  T; |7 t2 Y
10. <input type="submit" value="send" onclick="start()">
    ' I- I8 ?! u' {
11. <input type="submit" value="close" onclick="close()">
    1 T2 Q# L0 ~* _& m
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
      `; n: u" d- w" Z4 k5 i+ n
17. 2：正在关闭
    . x+ q9 S# N- ^; U! F% a0 X
18. 3：连接已关闭或无法打开
    
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    / Y* n$ U  V' ~" A+ Y8 R
23. 
    
24. 
    7 }8 k* o6 d& t/ |6 q" K
25.     webSocket.onerror = function (event){
    " i" ~$ A0 a6 |" d" X3 \/ P
26.         onError(event);
    1 `! b* a0 g4 e& |+ q
27.     };
    
28. 
    - R  [5 Z3 W# b& l& `; M+ t  b
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    5 y/ b3 X. u' z" o
31.         onOpen(event);
    & m9 e  Y- V% C/ \. K
32.     };
    
33. 
    
34.     //监听消息
    8 j; o2 E2 M! V7 {9 i, Q
35.     webSocket.onmessage = function (event){
    - M) K3 v0 f  }2 H
36.         onMessage(event);
    
37.     };
    , G! p9 G; i- }% U1 }
38. 
    6 o4 V( P8 ]2 F0 _
39. 
    
40.     webSocket.onclose = function (event){
    ( x. d. y) E, ~7 _' w
41.         onClose(event);
    ( I3 C0 p( r3 R0 _
42.     }
    
43. 
    
44.     //关闭监听websocket
    ) q8 ~# w6 v/ }  _8 A9 I' b4 }# Z; [
45.     function onError(event){
    $ T4 _" v' K6 r) M6 l+ ~& ]
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ! P# m- c. a. \5 y" I) l6 R' L
47.         console.log("error"+event.data);
    
48.     };
    2 I/ Q. P  r+ Q) n" W& f" r' I
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    % F1 p% h0 s. u) [, B6 {( i
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    8 Z( Y& t0 A. z. f/ O$ [( @* N
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    : e* U- ]2 m# {
61.         console.log("close:"+sockState());
    + h1 P: b) y0 Q8 ~0 H2 Q3 J' M) s
62.         webSocket.close();
    % a; z6 y! P* f5 ^1 }
63.     }
    3 t4 d' g/ {$ j) d& ~: _
64. 
    2 ~  c5 t/ }. y9 |4 A& L! `
65.     function sockState(){
    - D0 _$ o9 A% P* k3 j# ~
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    / T/ o: t9 O1 z
68.     }
    
69. 
    
70. 
    ; R$ i7 I6 p5 j9 I
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    ' M6 ~  b) _$ r% `) O4 _# K  }
75.         document.getElementById('text').value = '';
    4 l; O; \; Z* a7 R5 R: Y( R
76.         console.log("send:"+sockState());
    & Y' y( o+ b' E3 U7 j4 l9 v
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    8 z5 `5 {$ ~& p( i  ]6 a) @7 ?* l
80.     };
    / A) z* B; S5 Y1 w& R
81. 
    
82.     function close(event){
    9 M4 H+ l' Z2 z
83.         webSocket.close();
    
84.     }
    
85. </script>
    0 s/ U) m0 O' C* R4 K+ ^
86. </body>
    % G# E! t5 A! U
87. </html>

复制代码

3 J* p% p' W8 M6 g- m$ V