php实现websocket实时消息推送

admin

php实现websocket实时消息推送

$ g" \8 D1 t0 ?% d
) U9 f1 c3 M3 uSocketService.php
7 R7 [9 M9 H1 l8 R8 H6 d

1. <?php
   
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   - T% B6 r" {9 x6 F1 T% ]
6. */
   # y) y" X2 x+ {. N% B2 U3 V
7. 
   9 O9 J+ M% R1 f2 _
8. class SocketService
   7 A' M: M+ A: M; Y( L
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    7 p/ {! M7 f1 Z; O1 @/ T1 X7 Y8 ^
14.     {
    ) E/ F! Z& w) B% m8 ^
15.             if(!empty($address)){
    2 o9 k3 K4 P: E& b: x" S8 p' G
16.                 $this->address = $address;
    8 h) t: a2 X9 C9 u' t
17.             }
    
18.             if(!empty($port)) {
    ( Z+ }+ g, [* r0 m2 ~
19.                 $this->port = $port;
    
20.             }
    " A! x; H9 j( w' k: P1 P
21.     }
    # ^; L9 W# \: f, r4 x" e
22. 
    
23.     public function service(){
    9 W9 e; U8 {4 k) q, f2 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);
    " v* a) t) U5 p; Y; e
28.         if($sock < 0)
    ) ?6 K# f( Z9 W. C
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    ) Y7 D$ a+ H& \; N; e
32.         socket_bind($sock, $this->address, $this->port);
    5 s; K3 X- R4 p0 e+ U$ [% [, R
33.         socket_listen($sock, $this->port);
    5 v! R* w: I' \! Q7 z* O
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    ' m( q. S3 o2 J3 L9 o1 v7 T+ u
38.     public function run(){
    
39.         $this->service();
    3 ?2 E9 I( P6 `: t
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    + B  i* }$ Q) j/ v0 o0 m' t0 Y. }/ a! O
44.             $except = NULL;
    # T, i& }/ [9 X
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    ; n6 n- w2 V* g7 H+ A/ M4 k0 y  V
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    ( e2 i' T9 Q3 H9 t; ]5 r" u" i
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    . [2 d5 Y4 X4 D
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    # S/ F: m% H  L3 p
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    + b. C+ ?; k9 [
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    ' Z) c) ~8 J( \' `2 t6 j
58.                 } else {
    " b- g4 u8 C4 F( o4 E( J3 ]  D
59.                     socket_recv($_sock, $buffer,  2048, 0);
    ! d. v: x8 r& s( n" U) l
60.                     $msg = $this->message($buffer);
    ! ^# S+ z: B$ H9 B8 R* g: @
61.                     //在这里业务代码
    # Q1 p6 Y, F; ~! R; r2 }, m  ?% I( O
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    " ?; Q  [+ M+ s5 _3 x: }
65.                     $this->send($_sock, $response);
    3 M1 e2 w1 K0 H6 e, M8 k( X, z9 d
66.                     echo "{$key} response to Client:".$response,"\n";
    / {$ g! U+ G  H4 Q- f6 X4 r$ K
67.                 }
    
68.             }
    
69.         }
    2 h) t* ?9 o1 [
70.     }
    
71. 
    
72.     /**
    9 P: r; H- d9 L. O
73.      * 握手处理
    
74.      * @param $newClient socket
    " g$ m! |/ C4 D) C1 O& `8 u' H
75.      * @return int  接收到的信息
    5 K3 ~! R" Y# _% n; D) ?+ u
76.      */
    % \$ A2 d) m/ s1 `( \7 c
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    5 m# H& Z* d. J" C  V
82.         {
    5 O. k# X* j, o+ q: Q
83.             $line = chop($line);
    & e$ l. _% M+ j5 a; q' N* m( s* F
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    & g7 J" c& H8 U* ]# S) L0 ]
87.             }
    ( V3 n( ^6 G1 `7 s- f( K1 o
88.         }
    9 h( d0 l" {4 ^0 V1 b
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    * K+ ~% X2 Q3 r* a
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    5 |8 K* O) C2 m7 r7 c7 Y- K5 x
93.             "Connection: Upgrade\r\n" .
    9 p- K. }" r0 j# `. K0 \0 B$ l
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    $ S1 k: X9 F( ]) T6 S
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    % z6 A' b1 l6 a8 F' C9 r, {
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    
100.     /**
     
101.      * 解析接收数据
     8 m! J; @5 C# B$ d; ?
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     + A- T, f+ f5 o. A! O) `
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     + ?% @5 w0 e4 f& }/ [# }7 l
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     & b3 \9 ?1 h' k; t1 b4 B
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     2 ^4 W; x% e% N
121.         return $decoded;
     
122.     }
     
123. 
     
124.     /**
     : }7 u. p4 K3 ~2 O& d: ]
125.      * 发送数据
     0 t! L& S( ]7 G# r* p, ]
126.      * @param $newClinet 新接入的socket
     1 z* y+ u* [! {% n. J
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     2 O9 C' B3 d  `$ K' Y) G
129.      */
     ! [& @1 A, I, X/ b, F' m
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     2 R/ C$ Z3 X6 b" m6 g# Q! O3 e. ^& U
132.         socket_write($newClinet, $msg, strlen($msg));
     ( N8 [9 E8 P3 ?& h7 _4 |( c4 r
133.     }
       N0 q2 }- z4 [  J3 s7 s; w
134. 
     0 c9 q; J  `0 D; Z5 n
135.     public function frame($s) {
     5 I0 Z1 r2 C4 L
136.         $a = str_split($s, 125);
     ( Z/ Q# c4 J9 X1 Q) D/ b
137.         if (count($a) == 1) {
     + [& y0 _( ?4 S5 Y* U# ~. M: U
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     & P0 R3 G* l2 n$ ?
139.         }
     
140.         $ns = "";
     & F) c: o1 Q; y4 N
141.         foreach ($a as $o) {
     8 j3 q- n1 \0 A/ a0 k+ e
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     
145.     }
     8 x  G  S) r( B: v" f
146. 
     0 H4 C+ @& v7 q4 C$ l
147.     /**
     / h- Q- G5 X! T# E0 V1 r
148.      * 关闭socket
     1 S. L. S* A" }" p
149.      */
       a: a1 Y% I3 }" W$ }; R" u# }
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     4 O7 S6 F9 W  V* G$ \# _) @
152.     }
     $ O5 b" J* h1 v7 q) B; |0 `5 Q0 P0 F
153. }
     
154. 
     ; p0 l; }+ v4 J0 l. p
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     & H1 t! T5 Y" V3 t6 K% M" L' K' w

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   
3. <head>
   ' {7 {# N7 R9 V3 ^: m
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   + m6 y, O0 D) @2 P9 @$ @% }  D7 ]0 N
6.   <title>websocket</title>
   . e! Z$ k/ |* Z
7. </head>
   2 E4 g9 Y/ A0 w5 V3 B% l8 E8 u1 G8 }
8. <body>
   . Q% K" J, k7 W: x+ W7 z
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    " d) V% W- Q) E. g2 O& {+ Q
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    / k% k! X# O+ k0 f3 p
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    + w, U0 [: W" C6 g& x
17. 2：正在关闭
    ) Z8 _) U) K) _# e+ O% t- \$ q
18. 3：连接已关闭或无法打开
    8 K( @6 ?: d$ p- b8 B
19. */
    
20. 
    $ \+ z! W0 R; ~: t8 _. z- a+ }- Z8 }. ~  N
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    ! N& T+ {- j7 S' [0 K& ^
25.     webSocket.onerror = function (event){
    # ~1 `$ u. ~  g0 C
26.         onError(event);
    9 J1 h( `+ C1 T! p  z3 L
27.     };
    
28. 
    ( j8 B& M' M! r) D7 ~
29.     // 打开websocket
    $ j- ]" u, A& G
30.     webSocket.onopen = function (event){
    4 Z- M0 h& M: z  C+ q! n
31.         onOpen(event);
    
32.     };
    * l! _# a( a4 d, F" K
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    4 F- H% ^0 p1 U! V7 E( W
36.         onMessage(event);
    
37.     };
    4 }; }% l( N' ~6 Y3 ?) C
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    5 q' ?* N5 ?3 i# d5 F9 z
41.         onClose(event);
    " Q- D3 c! n8 B. j/ t
42.     }
    4 _* a& A( ?# o" W/ L! H
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    : t! r' |8 L8 Y
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    . h0 p: D$ R$ s. C! M0 o
50.     function onOpen(event){
    , `5 T% o3 X+ w1 P& ~8 q0 y
51.         console.log("open:"+sockState());
    1 m) L# n$ e/ Y/ O
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    % M# u" ]1 H- k" o# Q
53.     };
    
54.     function onMessage(event){
    / r* ?& B$ ]& P/ ~: _$ Z8 m, _
55.         console.log("onMessage");
    / ~: O' A) N+ A# g4 a- g6 n  d
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    9 W3 Q$ u" N9 L9 u! Q' S
58. 
    
59.     function onClose(event){
    + L+ b* q2 V- N9 a
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    5 H6 ]6 B% x) _$ o1 P0 z
62.         webSocket.close();
    
63.     }
    
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    2 b$ H' Y! V+ W$ n5 _0 F
68.     }
    6 h" V4 a6 C5 b* }9 d
69. 
    6 f5 I2 S6 j' `, \- S6 a2 n- v
70. 
    - K$ q' n  F4 e$ s$ D0 [3 b, W$ P
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    . s8 M8 L4 q% [# R1 G2 `# x2 F. z
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    $ i# l8 n. _. m* [& r( Z
80.     };
    
81. 
    
82.     function close(event){
    $ ?: k; S: o$ h* N) k6 a2 q
83.         webSocket.close();
    
84.     }
    9 g( i* M5 Q+ B6 X" U/ b
85. </script>
    
86. </body>
    
87. </html>

复制代码

( r# ?# D& v* k$ c1 N2 c$ b

% c. U* E3 r4 j+ J/ E