php实现websocket实时消息推送

admin

php实现websocket实时消息推送

$ E$ p* j. ?* d0 _7 Y
8 \# `: c5 _9 b, O" dSocketService.php
0 X$ Q! s; G/ m6 U' S! W" n' c, P

1. <?php
   
2. /**
   
3. * Created by xwx
   " E* z4 `/ c( [( i8 S5 w
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   
7. 
   * |/ V) S1 |$ ]/ y, o! S- U) _
8. class SocketService
   
9. {
   ) R6 j7 S4 a2 w7 W9 @) `1 e
10.     private $address  = '0.0.0.0';
    " |! m6 X9 a+ [1 O1 h
11.     private $port = 8083;
    
12.     private $_sockets;
    4 P* @- F6 O- y( H2 C+ \& m* o7 o
13.     public function __construct($address = '', $port='')
    9 f; t  c$ a9 b8 \: Y
14.     {
    + V  S  L  e& z. E1 B. }; I1 m
15.             if(!empty($address)){
    / G% P1 S! A; t
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
      q! Y* R6 J+ N$ D: m
21.     }
    
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    % E- A8 I& F' O- K
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    . r! n/ Y4 |7 x' b
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    
29.         {
    - |; Z& X5 P& |' {8 I/ E
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    - s  j9 x  \  _2 D* A
31.         }
    2 m  d6 |7 ^% e" S! O) L* ?
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    5 @" ?& }: ^$ }$ W
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    & @! A6 ?8 p* H; l7 g) w8 ~1 G. o6 W5 i
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    1 E- G2 S4 @0 a' F4 r( l5 X, a  n) C
42.             $changes = $clients;
    
43.             $write = NULL;
    . o& X' l/ k/ ]+ q+ q- ]$ s0 O
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    6 ^0 f4 T& q( _+ h" M9 x& E
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
      O- S$ z- w5 B8 S" S+ _
50.                     }
    3 I# q1 ?& _" I6 g! e. |) ~
51.                     $line = trim(socket_read($newClient, 1024));
    , G* }/ L6 C! W$ H- X
52.                     $this->handshaking($newClient, $line);
    & f" b: X3 Y/ y7 Q" g& K. F
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    - V, i" e/ {+ c3 ]* m% I  {
55.                     $clients[$ip] = $newClient;
    6 n8 F4 h, V4 ]
56.                     echo  "Client ip:{$ip}   \n";
    5 s, P! Q( h" L) A, _
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    1 g* K) }2 U7 l3 T# L0 P( U
59.                     socket_recv($_sock, $buffer,  2048, 0);
    2 D/ P- v7 d3 I" @" C4 t$ q* Z
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    ; O; q; a9 f6 }4 l( ]0 e; @
62.                     echo "{$key} clinet msg:",$msg,"\n";
    , E4 S5 ^( F6 l& f: B4 ^
63.                     fwrite(STDOUT, 'Please input a argument:');
    ; P( `1 b( ], }" [' Z* u! l7 `
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    + F+ r' Z  y0 _% A0 \) w/ S
66.                     echo "{$key} response to Client:".$response,"\n";
      a6 y: X8 c& J
67.                 }
      n) a7 N4 o: o9 B! b2 l
68.             }
    
69.         }
    
70.     }
    
71. 
    $ u- ?" b8 u: L; D2 F. S3 G5 O) j
72.     /**
    9 _$ Y! t( a- B% T4 J
73.      * 握手处理
    2 V  h$ k' Z# t: |
74.      * @param $newClient socket
    ' U# ^7 X: v5 N" S
75.      * @return int  接收到的信息
    
76.      */
    4 u0 g3 Y4 u% S" v3 y
77.     public function handshaking($newClient, $line){
    
78. 
    3 I6 r; T, g8 ~" G8 u- W
79.         $headers = array();
    ! o7 S, B7 H8 Z8 Z  p) `
80.         $lines = preg_split("/\r\n/", $line);
    " v( i% `' t$ C4 H: E
81.         foreach($lines as $line)
    3 s0 z7 P) m+ r- U7 t: A/ \
82.         {
    6 Z/ ]4 F% J. N. I
83.             $line = chop($line);
    7 Q8 q: |" M2 a. @" i$ p
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    1 i) L/ u9 Q7 ^) y6 }! Y* y: C. a6 ]
87.             }
    : y3 s6 |+ ^/ j$ X, C, k; {
88.         }
    : j! [* _9 M9 I+ B% Z
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" .
    0 B) h- [3 b; Z- @
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".
    - @( ]* W7 i+ B, U
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    * m* s+ P0 c- x' V
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    - I" V/ g5 K  n& E0 t8 e1 J8 t/ N
98.     }
    
99. 
    " v. \/ R3 g2 @) r: n+ u, @
100.     /**
     4 A# e, h: x- h4 p' y& Y6 ?4 }4 ]
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     ' O! G/ y4 ?* o, w8 h+ D$ m
104.      */
     
105.     public function message($buffer){
     ! L0 [5 J2 t/ t
106.         $len = $masks = $data = $decoded = null;
     $ u9 J& E. V4 k0 D- e
107.         $len = ord($buffer[1]) & 127;
     : ~/ g( o' ^5 [/ T
108.         if ($len === 126)  {
     , f$ y+ M9 {1 u
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     7 O9 ^$ }( r) @
113.             $data = substr($buffer, 14);
     
114.         } else  {
     ' _/ q, H" J" f) G4 O% V8 P+ ~
115.             $masks = substr($buffer, 2, 4);
     . Y3 M9 ]7 ?$ o3 B* j! V0 M
116.             $data = substr($buffer, 6);
     
117.         }
     2 Y/ \0 s, P1 a* q6 O+ I
118.         for ($index = 0; $index < strlen($data); $index++) {
     6 a# x6 L# s( D  O5 L2 _. w& s
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     2 P. @. i4 y; _  q
121.         return $decoded;
     
122.     }
     7 ?- c0 l: ?) w  o& O
123. 
     / C/ k! L; ]4 R: C- V& }/ E
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     ) Z* m7 F! j5 A
127.      * @param $msg   要发送的数据
     , M7 J/ H! V$ S8 `8 j
128.      * @return int|string
       K* l- d9 V! a0 {4 U
129.      */
     
130.     public function send($newClinet, $msg){
     0 i( z/ I: b& \
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     6 `2 ?* s+ H, o
135.     public function frame($s) {
       r3 z4 p1 ^* Z" t1 l  y
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     % c: ]0 a" Y5 B/ Y" v0 o' ^
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     & \/ C- B/ `. }) C% U9 J% K3 T$ F5 T1 r
139.         }
     
140.         $ns = "";
     % _& P9 ?/ |: F! x) @( F2 K4 }
141.         foreach ($a as $o) {
     1 k% W* j% ]( O3 J! h
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     ( j3 p* K$ I1 y
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     % F, }8 z$ p7 `6 x
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     * g) X$ f5 u  r% C2 M: \1 s- N
152.     }
     
153. }
     
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     + t: O$ _: F! e2 S% f$ M( n* h2 N
157. 
     + }( R* {; |! I- u5 ]$ g2 N

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   $ K" |6 M8 F" y0 ]" n
3. <head>
   9 t/ J+ Q( g, S& W' u  K* d
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   0 f- B& G& k# N' E1 u
6.   <title>websocket</title>
   / Y7 }( s, |$ U2 ]" |7 L& g5 D
7. </head>
   
8. <body>
   . H. K/ |% ?% C* `8 z
9. <input id="text" value="">
   ! U* X4 @5 y4 u) B1 P1 B3 Q: x* n  ]
10. <input type="submit" value="send" onclick="start()">
    & [7 z, `2 E' H  Q0 a3 z
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
      D" \. R& }- a$ x2 t6 x
15. 0：未连接
    
16. 1：连接成功，可通讯
    # |8 A; L4 X2 K% p5 ^
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    % \) l$ |. L" [5 `+ T( }
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    : L/ f! Q% K' H( A
24. 
    
25.     webSocket.onerror = function (event){
    . r6 c# Q1 L: ~
26.         onError(event);
    
27.     };
    
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    8 w1 H3 _( O3 t5 `) i5 u3 ~& z
33. 
    $ \" k: ?. f( B  h& f
34.     //监听消息
    8 h% ]7 R$ k8 Y, F4 ?+ |$ ~
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    5 Z3 ]/ s& X1 D& M0 f  w& Q
42.     }
    $ ]  u/ R' O* c" w( |  _' C" `
43. 
    
44.     //关闭监听websocket
    & v5 w' h9 I( U) @
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    ( g/ E# Q( o+ W% b& @
48.     };
    1 H6 D" J# C1 a" {- @. d/ Z4 l
49. 
    ! p8 d/ x( _: G
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    & {/ r% d+ j2 K, L
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    " ^6 P6 W- E% H5 y$ a" L3 j) t
54.     function onMessage(event){
    ! s8 y; M; b! \5 C8 E( m
55.         console.log("onMessage");
    1 Q7 c) C( o# l! [
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    ' T: a+ k7 Y! w2 r% v1 m3 R2 q7 m
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    & U% L2 P( ?+ Y; h
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    7 z$ F9 Z& i; Y6 u3 T/ k5 Q& F. ^8 G
69. 
    
70. 
    
71. 
    / s- G4 o( s2 k' K1 ]1 U5 m
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    * v+ H& m( B# ]$ m# s3 p
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    & }) Y8 Q2 {$ `; o0 a
78.         webSocket.send("msg="+msg);
    1 c- O8 s# K7 r1 P* m; J$ a0 b9 N
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    9 F2 H3 z6 l, B# ]. s$ E
85. </script>
    , {2 l& ]2 L! J4 y
86. </body>
    3 x5 ~9 n" e, x  x; t
87. </html>

复制代码

) z" d3 _, L6 ?6 ~  F3 H
2 P3 X( \7 p0 q9 x$ e, D: a
/ c0 g: U; U* Z