php实现websocket实时消息推送

admin

php实现websocket实时消息推送


& t% h' z2 N3 `- K) q! ASocketService.php
+ V* c5 y$ ]! f* |4 [

1. <?php
   ! O7 p. c3 P1 B% S1 i& i+ k* B
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   2 }' E% c. k$ E2 j  n
5. * Time: 14:33
   
6. */
   
7. 
   4 i$ b$ D$ s" f4 V7 l( l
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    ( S; a% r& |6 B. c9 `2 }; x
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    - J" `) Z- i9 C
14.     {
    $ z' V8 y! d3 |7 j6 z3 Z
15.             if(!empty($address)){
    $ u7 c" E+ y" m; W" _' `( Y& X
16.                 $this->address = $address;
    
17.             }
    ; B$ ^" R1 y. T( b5 S) Z
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    . m; G+ O/ `8 r
20.             }
    % E6 i5 \' [: \0 S3 T2 @$ t
21.     }
    
22. 
    
23.     public function service(){
    3 |3 b$ R. s! I) Z0 ^+ Z$ M+ Z8 Y
24.         //获取tcp协议号码。
    3 T7 s5 S" l; C& |( Q- i
25.         $tcp = getprotobyname("tcp");
    0 r; q6 x& P6 c* |0 ]5 ~3 q
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    . m& C- ~- p. k8 D" {/ @
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    . E$ Z* m8 c7 |3 x; k0 U: N. Z
31.         }
      k$ M- j6 _. u. J( _; ~. Q$ o
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    ; C6 P! |8 S* _: [! ]4 ~
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    ' U+ `0 L) ?) h+ y1 K- Y3 i: D
36.     }
    4 c4 L4 `- |  U8 p! p! x9 o* O
37. 
    ( v* l' W5 x  _6 m# d% k
38.     public function run(){
    
39.         $this->service();
    ) U1 L$ T/ w; k7 q7 ^
40.         $clients[] = $this->_sockets;
    % u7 e  Y, s+ c- M; T5 t1 P
41.         while (true){
    * Q8 B# |( G' _8 `6 r
42.             $changes = $clients;
    : r0 ?8 M  [9 d1 ]8 S. `, W, k0 V8 V
43.             $write = NULL;
    . W; U# |0 g+ e" a* \1 M8 @
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    9 Q7 U* [+ E9 n9 j6 A
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    $ e1 g9 u1 K7 K) D, z: `
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    $ O8 G/ a( ]; Y* p
54.                     socket_getpeername ($newClient, $ip);
    1 J( i+ x( \0 R" r# G: |* Y
55.                     $clients[$ip] = $newClient;
    - R& n2 g- U7 o9 H6 r9 I+ O2 ?8 K
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    . y- C' p8 H7 q& B  b" W! ^( g, t
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    + A- S% z! A/ v  x
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    
69.         }
    
70.     }
    * }! d* q" T% S# q
71. 
    
72.     /**
    
73.      * 握手处理
    3 m: H0 W7 |+ p* g3 Q1 G0 F
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    " h! u1 p/ C, r, \% h& B
78. 
    
79.         $headers = array();
    3 {6 U5 G" {  U3 p. d0 \
80.         $lines = preg_split("/\r\n/", $line);
    - \& T# P( \) P* I" V6 c; y9 l# m+ u
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    ) s$ X6 F- v3 ~; I( `
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
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" .
    + A6 b0 n& I0 K  G3 R
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    + J+ S! v# V6 w& |
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    8 e+ F0 @! r# ?7 a
98.     }
    
99. 
    
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     " Z& R3 @1 t* N( V
103.      * @return null|string
     2 X) Y4 ?& E( m# }; {4 y8 q
104.      */
     2 A% v5 m. l9 R* e5 z& l
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
       }3 A, x1 M1 k
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     ( K' U) n  s3 v1 _" x+ V
114.         } else  {
     ) z6 {# `9 N  x( P
115.             $masks = substr($buffer, 2, 4);
     % ~" E: ?  C! e& |) u
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     " p0 Y6 O/ Q6 K( o% h6 E" c1 b+ M
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     # s; ~4 S1 U& R0 L$ R
120.         }
     % p" y5 U. z( j: Y+ t( m
121.         return $decoded;
     2 M! B& e+ O: g; l4 E, n9 T7 N
122.     }
     
123. 
     " `1 i5 C) [. M
124.     /**
     ! v: F7 l+ m" V( \# G+ L
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     % r3 h- q0 n: I1 @& J: a
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     ; s! }' w5 a3 W! A3 W  k
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     ! ~/ [( e' W( j- R
134. 
     9 [, i- [5 g% f( D  j8 _0 I
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     6 C( T" C' D! M
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     ' M( J5 {& f2 S! I( B
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     % d5 \8 J3 h" ?! o
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     3 ]; r2 ~6 F( w) {- B$ N) g# W
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     . c3 k% K2 j/ p! g) P: X
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     - r) w8 Y3 X1 g8 }+ i. c5 T

复制代码

web.html

1. <!doctype html>
   5 }) ^  i9 ]$ k* U9 t/ x
2. <html lang="en">
   
3. <head>
   3 t" e* ~" g. M) M# K
4.   <meta charset="UTF-8">
   8 q; O$ y" ?  `- E; s1 e
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   
7. </head>
   / J- n2 }1 S4 ^( W: {
8. <body>
   
9. <input id="text" value="">
   * C; A6 e' o# h( {
10. <input type="submit" value="send" onclick="start()">
    9 ^: m8 p! P2 S: `4 G& P: l
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    ' j5 p! N2 I7 C+ g% @3 p
17. 2：正在关闭
    $ b: \$ T) x4 X, G6 ]( ^8 k
18. 3：连接已关闭或无法打开
    ! E- `5 ^" `1 _2 }3 F; y9 k
19. */
    ) M- Z7 ]$ B7 k& ]
20. 
    
21.     //创建一个webSocket 实例
    7 k3 N5 K* I7 n' h; s. h
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    / o% ~" V" `% \9 x! O
23. 
    
24. 
    . f- V# s3 W. i8 ~9 |7 [
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    2 V0 F0 M4 P) ~) z
28. 
    
29.     // 打开websocket
    - e( Z9 m* \) d, m1 h9 W$ x
30.     webSocket.onopen = function (event){
    ! {/ M4 [$ P9 y' ]
31.         onOpen(event);
    ( @6 k6 S" b+ P4 b- `3 O
32.     };
    
33. 
    . O- V6 l, p8 X' H5 D( h* Q; Z
34.     //监听消息
    ; S% a3 i6 v5 D  `
35.     webSocket.onmessage = function (event){
    : u0 U, _! i, r" V7 J) [- y
36.         onMessage(event);
    
37.     };
    
38. 
    * e; G( G7 ]1 v. h; w
39. 
    ( d0 I' l" u0 R# l
40.     webSocket.onclose = function (event){
    $ a7 R/ P% u! x1 T/ _
41.         onClose(event);
    2 x' p; |& M2 b1 x, {9 l
42.     }
    
43. 
    
44.     //关闭监听websocket
    1 K4 s: V& X# P' p
45.     function onError(event){
    - l$ c: z2 |/ h* k. B
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    7 e1 ?" N$ v4 Q9 E. @# S1 Y( x! H
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    - I" X9 \, Z* x4 p( S- o& ?
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    ( M+ x8 Q& {& A
54.     function onMessage(event){
    . w3 X& B( `. w; a" I" ~# a: A
55.         console.log("onMessage");
    ) }! i: }+ T  N/ J0 z( P0 |* S
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    / j! u3 T6 H5 h9 c* C& B, X
57.     };
    
58. 
    
59.     function onClose(event){
    # V9 b. _0 w6 n0 v  ~
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
      r# m4 C  z. Q1 R# g4 C3 s" i8 @
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    0 ?. E% F7 ]6 f+ r
63.     }
    
64. 
    
65.     function sockState(){
    : d+ t. q% s, _  T/ w3 Z; _
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    
70. 
    
71. 
    ( L5 Q( R* u. ~5 v
72. function start(event){
    
73.         console.log(webSocket);
    $ t6 E. G5 U+ O1 t: k
74.         var msg = document.getElementById('text').value;
    6 K0 f) E$ J7 j. h, k. X  f' _) }
75.         document.getElementById('text').value = '';
    5 ^' W6 A. `# j2 a( @( k
76.         console.log("send:"+sockState());
    9 B3 E% H( I8 I8 i9 p
77.         console.log("msg="+msg);
      e& N1 }- [0 \% o) \2 s, G: p
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    ) t. [9 x' H( V, L
84.     }
    ( I, T. z% V& i: Q: p! p
85. </script>
    5 |) Q4 O% t" u% Z5 E
86. </body>
    ! _, {- T2 v# P; B
87. </html>

复制代码