php实现websocket实时消息推送

admin

php实现websocket实时消息推送
% i5 _8 P$ \1 z1 Y. V! q$ q
6 ?' O/ P+ V' x0 |6 l5 n' N% @
SocketService.php

1. <?php
   - e' Q$ G8 s& J1 B) \' X8 b$ K$ a
2. /**
   ( W( D6 i/ M5 U) Q  \
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   9 E$ a; @& j  ~; ~- E: T+ y
7. 
   
8. class SocketService
   ( W# k# R8 o9 U% J( U+ y4 P0 s
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    : W. k0 g# _5 n( x0 m
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    ! X  `5 J6 d/ `2 }3 I0 z* E2 w+ h8 Z
14.     {
    ) `% j2 U; B- \  A6 {6 p
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    : ]& m' z3 W) ]. l* _6 y
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    0 a7 c% s- r7 m4 j$ [8 j1 Z
20.             }
    
21.     }
    . q3 S% U  F1 f# h: Z- o( f5 _
22. 
    
23.     public function service(){
      z) U. Q4 C* X) J
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    ! h" J9 E  X( S5 X0 Y. a7 B, z# F
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    " A( K5 }2 f9 @; I
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
      V4 m5 m. h8 n* k' e
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);
    : h9 [6 [4 {6 E) D( M
33.         socket_listen($sock, $this->port);
    6 S" H6 T% D! Q8 M7 R
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    ( n2 _2 `; p% e1 b! c' H! V
36.     }
    
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    ' W$ ]. O0 Z7 S0 w
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    , o+ b) b4 K  `4 j  W
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    3 I9 R; U' |% s) s" o  B
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    % b8 K" z' P/ h4 [7 m
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    . C' u# w. z4 r6 O& r
53.                     //获取client ip
    . T8 }. O# |& z
54.                     socket_getpeername ($newClient, $ip);
    4 V$ |' u) p( {) n  G. @
55.                     $clients[$ip] = $newClient;
    2 ?: D0 n% L/ R( h5 n6 ?
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    ; X. d$ Y, @* k3 m, u( v+ _
58.                 } else {
    ( d* V2 `1 a$ s2 o
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    5 K0 s' e' x# ]: E
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    * [! r6 ]+ j8 a5 H4 M( g
65.                     $this->send($_sock, $response);
    7 I  B  a9 R9 p! @/ Q3 L
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
      t9 ?+ Q2 W" |# a1 `
69.         }
    / _( w# q7 h8 `+ P/ i' X
70.     }
    
71. 
    
72.     /**
    * @0 a/ U& l# s& l1 q
73.      * 握手处理
    
74.      * @param $newClient socket
    0 q0 L5 i+ c8 F3 w
75.      * @return int  接收到的信息
    3 s+ }6 E# i) B( Q4 @
76.      */
    2 x3 P2 A2 I, D2 Z6 X
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    2 ?3 ]! a( b' u7 F
81.         foreach($lines as $line)
    
82.         {
    , e! f/ G: z8 ^4 G/ E5 J1 r
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    / g9 A  s) j1 P7 E
87.             }
    5 P# C& H- V: [7 {# o! Q
88.         }
    ! L( w4 Q8 U4 c* I/ O
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    , o+ R& q) k" x! A" y3 R
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    $ R2 ^' L0 t% V" z6 J
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";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    1 F, i- z# S- r8 b# N
98.     }
    8 ?% }+ e1 W/ c1 P4 m
99. 
    
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     - Y/ g9 y5 w4 ^  J; ^( D2 [  u
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     " l0 d; c( k) e% |4 S
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     * H' g' N8 |+ c7 a
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     ! W% u/ I! Y# X; r* B
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     + e0 u/ }, B" ]; O, ]- ]
118.         for ($index = 0; $index < strlen($data); $index++) {
     2 o: c! c8 q5 d# i( r# c6 @" B- _) f
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     ! W* m% s. D& {5 [; ^. o: b
122.     }
     
123. 
     
124.     /**
     
125.      * 发送数据
     : ?0 f$ ]9 }2 a. I/ n( R8 ^
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     # v, z% O2 \1 K- K: y4 L! Q) [) n  X
128.      * @return int|string
     3 m8 M" f$ \' A+ j- [
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     2 Z( z1 ^' B$ L6 q( o# J  X
132.         socket_write($newClinet, $msg, strlen($msg));
     $ b+ _$ u* B! O' r6 S$ X1 {
133.     }
     
134. 
     9 l, _9 @( f3 d7 }$ l  k$ U
135.     public function frame($s) {
     3 U8 z9 [6 H7 u: L& Q) R
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     " u: M/ s# s/ F& h# s$ f7 _
140.         $ns = "";
     6 c! J! ^7 U6 {3 j- R7 f( ~0 ^
141.         foreach ($a as $o) {
     6 [5 z2 j* x) @$ _6 H
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     - y, ?# M0 U" z) J( T+ u
144.         return $ns;
     
145.     }
     2 U5 _1 B6 ^+ J! r
146. 
     * W, l1 E! }+ F; h1 ?4 U0 _
147.     /**
     
148.      * 关闭socket
     + s+ Q3 Q+ D) a0 H
149.      */
     
150.     public function close(){
     ; i" f$ \: A  S& v  o4 F
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     0 X6 E! l- T$ i: D+ s- B
154. 
     ! E7 `, r! J+ b4 m# I
155. $sock = new SocketService();
     : x) z' k* Y* d1 h& s. m% k4 n; C
156. $sock->run();
     
157. 
     & l) ?: w/ C, ?5 L1 m) O3 V

复制代码

web.html
2 u/ S; h/ g! W8 ?

1. <!doctype html>
   : h7 L$ B4 X) K- W! T
2. <html lang="en">
   
3. <head>
   ) [1 V5 [) c" D& i, T; \1 D9 h3 _, s
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   6 V" G. |- Q+ E0 l6 B
6.   <title>websocket</title>
   5 E- ?3 a1 J) H; n( S% z( J
7. </head>
   . P6 U% l& y0 O6 ^4 x# h
8. <body>
   + s7 u) \: _1 S1 W! ~& x0 z
9. <input id="text" value="">
   8 E7 R1 t' V6 C3 o$ s/ `" T
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    ' p" |! b! }' I7 M3 B# r. m3 ^
12. <div id="msg"></div>
    # S  p5 L1 w. f1 ]: `; ^
13. <script>
    
14. /**
    ( m2 ^- ^* l( T
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    ' _7 M" C- b( {5 X3 W7 @! z' d
19. */
    , c$ c) L( Z6 H% v4 u
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
      @7 ?+ b7 v. {. a
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    7 w1 x( i! O& S3 n9 o
27.     };
    2 y/ f  A7 l1 A" V
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    & I0 z* q9 O4 V8 }/ ^; B
31.         onOpen(event);
    
32.     };
    
33. 
    + N+ h3 t# q: r- i: \8 n. g
34.     //监听消息
    1 R8 Q. o* ~3 ?7 e" M3 r# k
35.     webSocket.onmessage = function (event){
    0 T" H- P4 h& z- Q8 P( E- n
36.         onMessage(event);
    
37.     };
    
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    $ B1 @  p- z6 E0 z
41.         onClose(event);
    + Y" x- y! A0 ]# A/ m
42.     }
    " r8 ^  h2 S' u6 @1 [' A
43. 
    
44.     //关闭监听websocket
    ' Y6 u' r7 o; ?3 E# o+ s
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
      m  D- P. B3 K) r* p4 H
50.     function onOpen(event){
    ) A+ h- j; ^( A1 ]" b
51.         console.log("open:"+sockState());
    0 a- W: |4 X6 m% `( }- q
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    1 f% F) c5 \0 c
58. 
    
59.     function onClose(event){
    + }: d: A6 a" s* P5 F" e
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    5 i9 v; N" l" Y/ R1 m, k% ~8 j
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    8 F5 M& D, G) B$ o( D4 h8 A$ J( k
64. 
    
65.     function sockState(){
    ; {( `. d! \( @4 Y
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    * C$ u4 V8 B: q. N5 d9 [
69. 
    , G  w. d: O: V
70. 
    
71. 
    
72. function start(event){
    . {: e1 d* k; l7 ?7 u# i( d' ^
73.         console.log(webSocket);
    % M) l( X  u( e  z2 `. N
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    $ n2 M9 a* n: E6 Y  ?$ ]' F
80.     };
      b# B* {/ E3 R
81. 
    ) }8 e# ]" ^# i
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    6 h$ u: W2 P  B- j. b
85. </script>
    
86. </body>
    2 F% C& f6 g7 G( l& p
87. </html>

复制代码

: u) Y6 z8 v2 a