php实现websocket实时消息推送

admin

php实现websocket实时消息推送

5 a+ G- R- ^" M" }: f! w+ @
2 @! c; S- s3 ^  uSocketService.php

1. <?php
     ~& L$ c8 ~7 k; g
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   
7. 
   
8. class SocketService
   / Z/ p7 `# R  f. `" e2 X2 Q( X
9. {
   8 m+ P3 A  G7 }- N+ ]8 m
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    - `! @% F4 k3 w2 ?# [+ R5 R
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    0 E1 C5 L3 y$ t) m* Z
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    ; G0 f- S9 ^9 y% S, J: h3 D' z
18.             if(!empty($port)) {
    / [/ p- [, @9 ?: ~+ t
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    - U/ z7 y# }/ R' v/ E0 I
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
      X- p2 ]. A% f; L1 J
28.         if($sock < 0)
    
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);
    & w' {. N6 {3 G! D
34.         echo "listen on $this->address $this->port ... \n";
    % J$ r. r+ z) q6 H. H, k
35.         $this->_sockets = $sock;
    & D2 O# ^5 b) L  }" c  [
36.     }
    , }) `. j7 E' T* Y0 e/ E5 V' c
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    # q0 e( z2 m- [) M# W
42.             $changes = $clients;
    " f0 A- n# b5 \: M1 C" |
43.             $write = NULL;
    
44.             $except = NULL;
    ; W3 q: |, n$ X/ z2 ^' Y6 f) K
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    * G5 u4 ?+ Z5 C1 v8 W! {  ]  Y
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    ' q8 k0 x9 u0 q# A
52.                     $this->handshaking($newClient, $line);
    + D( O/ R( m( K1 V
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    $ `9 J/ B1 |. H. _
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    4 X' Y, W2 J' @! T8 T
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    1 u  p6 h! Y0 o. U1 i
63.                     fwrite(STDOUT, 'Please input a argument:');
    , N& V% L# k; _, _* `6 I
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
      j8 F* g* ~# L2 Z* F
67.                 }
    + ]) D0 }1 U! D! \( w4 ?3 Y
68.             }
    & Z! R# w, J# R/ `6 w
69.         }
    
70.     }
    
71. 
    
72.     /**
    6 e' }9 G% M( ^' s
73.      * 握手处理
    # S3 s8 T8 a. w1 {  M
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    & w3 `5 I! r! T8 i% P( ]
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    4 h; X, Y6 C! b# y0 ]4 w
79.         $headers = array();
    & }! C. w6 @; Z) D) p- G3 h
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    ; s' w% a8 H( @3 t( S
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    7 j- M* T! K( t' ^' S/ S
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    5 ?7 C, C$ J, ~; p5 B* a
92.             "Upgrade: websocket\r\n" .
    3 `* m( U+ Z" P
93.             "Connection: Upgrade\r\n" .
    
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";
    & W5 Y& y: b. s) N9 j
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    2 S7 S9 ~& G+ P- D* c- c5 b
98.     }
    ; F& g) m0 T) V/ D+ S1 e' D! m
99. 
    
100.     /**
     
101.      * 解析接收数据
     3 x: N" X9 v8 S! y- _) @, o
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     7 @( ~8 p6 s7 `7 x( G& l4 a
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     6 v3 G* G. g, T. H- q' y
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     / h6 H7 A  S3 A3 Q. {3 J8 L% t. E1 H
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     $ x0 e5 @, C# O/ D. A9 C
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
       m* H- N' p* ^
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     " v) @& X$ w. x  Z6 s
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     " n4 L, B3 @# l! Y
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     
124.     /**
     
125.      * 发送数据
     . a9 q" y- X+ V/ n7 A! m
126.      * @param $newClinet 新接入的socket
     - p' @& o; N+ O9 g' D$ B
127.      * @param $msg   要发送的数据
     ; U2 Q; D) M8 x& a
128.      * @return int|string
     , c' H" ^8 @4 K  g4 ~* H  F
129.      */
     " y- B. U/ \7 M( w# M
130.     public function send($newClinet, $msg){
     : J; @  x7 j- ~; j- A: P+ M
131.         $msg = $this->frame($msg);
       Q0 T1 F# N0 f! q& g5 ~' q
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     ) V! p" a/ A+ M- a# W" t, X
134. 
     8 v2 {) L* P6 M; x6 U+ T/ }
135.     public function frame($s) {
     0 w' x, @; P$ @1 l# p9 b
136.         $a = str_split($s, 125);
     + c7 T6 [7 R- G( r: m, }2 L6 i$ s/ U/ P
137.         if (count($a) == 1) {
     ! n* s- a5 U: ^  C2 H# A. E( S
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     ( j& p* k* p8 |* B  q& z
139.         }
     + S6 N5 k: L3 b* }
140.         $ns = "";
     
141.         foreach ($a as $o) {
     3 A  i  l8 I) T( u0 B
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     ) C2 O' }" T8 b0 d; F2 ?) \
143.         }
     
144.         return $ns;
     
145.     }
     
146. 
     
147.     /**
     " }) a- @0 E/ r2 e! p
148.      * 关闭socket
     6 k& z5 s4 j4 {
149.      */
     
150.     public function close(){
     9 q4 ^1 i/ |* Y- p/ @% z
151.         return socket_close($this->_sockets);
     
152.     }
     0 {8 ~8 M5 E2 {6 k5 M. P  M( f
153. }
     1 F* J3 j. u; U( r) r+ I9 r
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
     Q! G9 D4 s, e! f
2. <html lang="en">
   
3. <head>
   * j' I, L# j. @5 v9 D
4.   <meta charset="UTF-8">
   ' Y4 T" r7 a6 ?7 B' _9 t
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   : F1 ?% C, X  b+ @0 N# e  |4 a
6.   <title>websocket</title>
     `2 @) z, E8 ]0 u8 r
7. </head>
   4 f0 f& m5 J2 K4 y5 I( j8 D, u- I
8. <body>
   * @7 d; n' E% I; I9 Z( H
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    # S' ~+ [& \/ ]
14. /**
      F3 K9 E' Z, A8 d) V! ]  d
15. 0：未连接
    3 b  B/ N* A6 \$ M& F0 B9 B4 z: ?1 h
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    , o; Q% [) v& g1 i4 ?
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    ( O% t5 ?6 P: l9 @7 l' M
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    6 l% c  A0 @: [9 \& l; H0 i. V
25.     webSocket.onerror = function (event){
    4 K/ P( o# x( r1 b: ?$ @' G
26.         onError(event);
    & c8 z; S6 @9 y9 W# g+ g( i, f; ]
27.     };
    
28. 
    
29.     // 打开websocket
    # v# K! G7 d" P
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    # G" z& i5 ~: z' _, k
32.     };
    
33. 
    ) \' ~5 Y7 p  N
34.     //监听消息
    1 O# S# Z+ G7 y. k% y1 M
35.     webSocket.onmessage = function (event){
    2 G) ]/ u3 q' }" g) W* v
36.         onMessage(event);
    5 `9 Z- f# j! ?( z
37.     };
    
38. 
    - n$ H" ], {% N7 @) }
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    
43. 
      l3 U; P( K& X
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    1 w, E+ W+ A+ P
48.     };
    
49. 
    
50.     function onOpen(event){
    8 m( p9 @6 y, o' {6 t  o
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    " J  p( [% l4 z- [' e7 W
53.     };
    ) h( ?+ N) O2 M' o8 ]$ v9 a
54.     function onMessage(event){
    
55.         console.log("onMessage");
    $ n8 r" S8 q: K  L( P2 e+ A
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    . a4 P2 y. B  C; {" j2 L+ x' j
57.     };
    
58. 
    ; m6 M! e* P! j8 j# R* Y2 G
59.     function onClose(event){
    1 c+ D6 z' f+ ?! O
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    9 a1 t! }: Y5 q3 Q9 g
61.         console.log("close:"+sockState());
    ) G! G9 `3 ]1 z- W. r( e( @4 X* ~) ~
62.         webSocket.close();
    ( k  H+ }6 K  [' f# F
63.     }
    
64. 
    
65.     function sockState(){
    ; k( f/ j  {9 Z5 G
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    , n: V5 I. b) A  ?: ^. b, q7 j& _
68.     }
    / w: U# b# q9 k  b) j1 Y# W: O, @
69. 
    
70. 
    
71. 
    2 X/ I8 O2 @) _# ]
72. function start(event){
    ( q. W, {+ i% W2 U0 [) A
73.         console.log(webSocket);
    - _6 j3 P+ s$ q/ S
74.         var msg = document.getElementById('text').value;
    1 c5 @# Y2 H0 t" {
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    / H; d- W9 h# Y! V/ S
78.         webSocket.send("msg="+msg);
    ) X) u" G/ k/ U- C; Y+ h
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    3 w9 ^$ p4 C% N. r; n
80.     };
    
81. 
    0 W* [! g3 B5 }0 @9 T% ]
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    8 E  U6 R" _4 Z) V+ y- s
85. </script>
    # t9 C5 k& U: [0 |! E4 ]
86. </body>
    . u2 [8 X5 Y5 p! l, D0 a& H5 R
87. </html>

复制代码

, F& R' q5 o9 `# |8 P; N

7 b$ b6 d$ S! h; s! v! ~) h; S