php实现websocket实时消息推送

admin

php实现websocket实时消息推送
5 G+ M* e' Q+ }+ C/ {

SocketService.php
! l% z" a1 q& D$ Z; }0 a1 `3 b5 B2 @

1. <?php
   8 D. Q( Z! q; c9 p7 }
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   . J3 C: a5 q; l
5. * Time: 14:33
   : x1 l! n6 S! {! V/ S3 A% n
6. */
   
7. 
   , q$ ?( k- u& Z2 h' r( x
8. class SocketService
   
9. {
   # }3 ~. [( |/ z
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    - s( a, j" Q+ k: {: L* N: ^6 G1 b# J; f
12.     private $_sockets;
    , O/ u) F; ^" P+ {5 K+ Q" g
13.     public function __construct($address = '', $port='')
    
14.     {
    0 T9 z* [; y. i1 v4 T" q
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    . f4 f' _" z/ u# I5 ]0 S
23.     public function service(){
    9 {, l4 P( O0 p6 K6 ]& K5 {
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);
    
28.         if($sock < 0)
    , ?$ g2 s+ g6 e5 I) b
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);
    
34.         echo "listen on $this->address $this->port ... \n";
    4 x6 v* m/ h+ W; N& P# g
35.         $this->_sockets = $sock;
    
36.     }
    0 H. t4 V' M$ E: A) n
37. 
    0 S- u1 v+ N. b8 ^
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    / ^6 [( A# E& l4 `- _
41.         while (true){
    . v& D/ J9 I3 H
42.             $changes = $clients;
    8 p6 T  s) V# s! e" x
43.             $write = NULL;
    1 a, o3 s- I  \5 x' ^" Q
44.             $except = NULL;
    0 N+ h0 `) I1 ]3 [+ z& ^
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    - G2 S& Q$ y& Q0 b* t
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    - @+ n0 _- J5 ~/ L" B, v6 J: }
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    6 a' n) _: U! B
53.                     //获取client ip
    + z3 k- }: E- l
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    ; E* ~: o. s( y6 ]
58.                 } else {
    ( k9 K5 ~$ p: j' b- D' S$ [
59.                     socket_recv($_sock, $buffer,  2048, 0);
    ( p+ s0 r6 W' s" l
60.                     $msg = $this->message($buffer);
    % y# K( {+ K4 I8 ^
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    * ?% B2 o& J! n4 j* l. M
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    ' I3 T1 R, j( r- F
66.                     echo "{$key} response to Client:".$response,"\n";
    2 H( w: g  G( S. T3 O$ H# O
67.                 }
    
68.             }
    ! @; @) _& J  n2 N. n* T4 y
69.         }
    
70.     }
    1 A4 E: Y3 Y& e8 y/ e5 R- _: u
71. 
    
72.     /**
    
73.      * 握手处理
    * A7 u8 @8 g) c& P7 v
74.      * @param $newClient socket
    - ]1 x" A5 b. [7 D5 v  ~
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    4 R* X3 J: V/ F1 ~& R# u( C% V
78. 
    + A# |* l  V6 t
79.         $headers = array();
    ' W7 o1 D5 U9 K  P0 a
80.         $lines = preg_split("/\r\n/", $line);
    & O/ `- j& y$ Y
81.         foreach($lines as $line)
    7 ~9 J: d2 q$ n9 I7 K
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    - @0 l9 f0 u% v* u, }" L
85.             {
    . G3 h% d% |" p& A/ L! k
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    5 L5 a0 b- }- V1 L0 K) u' G8 s
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    + q" }5 d+ N1 {8 R- b) v
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    ) m7 h  c9 ^, h; b7 \. ~( q$ k
93.             "Connection: Upgrade\r\n" .
    / L8 R, w% @% a; t# T4 U
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));
    ; N& w+ n9 i# Y. M! N' F
98.     }
    - q& n! V, n! i( f7 d  v$ N1 R4 M
99. 
    4 ?( K. Z: o( m4 J' [
100.     /**
     0 c  x8 R. |) ?! F2 w8 X
101.      * 解析接收数据
     5 D( l1 z" z; C# v+ c; x
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     3 u. O, R! K6 f0 R# p
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     $ V1 u, m8 p# c. I0 V
109.             $masks = substr($buffer, 4, 4);
     ( `0 P  y0 y0 A3 c1 y
110.             $data = substr($buffer, 8);
     3 p1 F6 l7 L8 x0 G) c; i
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     & U7 L6 T/ p$ d( |+ B
114.         } else  {
     . }1 [3 B- X" d
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     . o! C& ]: c8 V( q4 H! L
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     0 k- i# _0 k; d& ]& l
120.         }
     ; W0 q& D8 ^% i
121.         return $decoded;
     
122.     }
     / }. M# S" k2 x- V8 L& F
123. 
     + J1 W) d5 w$ ]! b; D- s
124.     /**
     
125.      * 发送数据
     7 N/ i# |! K* ?% ~( [1 M
126.      * @param $newClinet 新接入的socket
     7 w8 L( X1 ]+ c; h( p
127.      * @param $msg   要发送的数据
     % H$ b- f- Q$ \; G) r9 h
128.      * @return int|string
     $ Z, y8 r; a/ ^
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     - v: Q5 E1 d. M9 }! V7 S( e( F# w7 N
132.         socket_write($newClinet, $msg, strlen($msg));
     6 Y+ b# f; d* w) k
133.     }
     
134. 
     + {5 e9 u& W$ L3 X' @% w
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     ( A; X8 Y4 h  I1 p2 J8 D
137.         if (count($a) == 1) {
     : N& N) n% K& w3 h* Q1 C
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     ! \3 C7 g0 X9 Q" U
141.         foreach ($a as $o) {
     9 v% q8 ?3 [, N
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     * s! a/ T" I0 J0 k" ^9 o3 H
143.         }
     - D9 Y# B, d5 Q5 N( E" n
144.         return $ns;
     
145.     }
     
146. 
     6 Q1 i& H$ _, G3 Z& \
147.     /**
     . h* i, H) x- S( M
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     " }6 [+ C$ @. y5 I1 _! R0 @3 R/ o$ }
152.     }
     
153. }
     
154. 
     . ]% J0 c% p9 l; m& @
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
     H3 [: }4 Y0 @# I
2. <html lang="en">
   
3. <head>
   
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   
7. </head>
   + k9 W1 D! ^- b4 \7 q( @
8. <body>
   6 k( G, Q5 ~/ E; [  [
9. <input id="text" value="">
   4 M6 b  p5 k" p6 ?1 ~
10. <input type="submit" value="send" onclick="start()">
    + v* r8 \' u; \0 x3 M" S8 s! }
11. <input type="submit" value="close" onclick="close()">
    8 t& Z  e" Y' Z6 P$ C
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    / M3 `! B7 J/ S/ {
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    + O, o2 r, B" H* A# E+ |" @0 O" s
18. 3：连接已关闭或无法打开
    + B2 x+ b! |9 @8 i  V, V6 y
19. */
    
20. 
    + n* k8 q$ x& E# d/ H
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    5 ^) b- k7 n" Y' H, E
25.     webSocket.onerror = function (event){
    : ~, C( [8 {/ B# @& n" u
26.         onError(event);
    
27.     };
    / \% y0 s; t8 `) [) ~6 J
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    - k/ A! |! @) N6 a1 L- S( C% O
32.     };
    - P0 x6 B* R) C% e
33. 
    1 v5 }4 N2 Y* I4 M
34.     //监听消息
    ' v* v9 [" s" q2 S  p$ N) \1 e
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    & l% V: L; j- [6 t: W3 J$ R! ?5 X
38. 
    
39. 
    4 j+ P) Q9 w& U# ^) |  N  A6 Z" n
40.     webSocket.onclose = function (event){
    ( L1 b# s! {- B
41.         onClose(event);
    
42.     }
    
43. 
    
44.     //关闭监听websocket
    % ~, c; X/ X8 m% o4 q, b
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    - I( W; g4 N! K; a
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    3 c% A% \9 e' g( S4 |
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    # I% V1 s) S, a8 i3 X' a
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    9 t0 |+ \8 }. C. C% H! l& c
58. 
    
59.     function onClose(event){
      O% N  F2 p! v$ G7 q
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    # p0 L. }9 x" v, b: v9 U$ N, i# `
65.     function sockState(){
    2 W! K" m$ N5 ^* E& L- T) _
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    : b5 Z: E8 E# c$ ]0 F
68.     }
    7 y4 H$ H$ J7 ^
69. 
    ) Y& L% V9 W" p3 n; c5 N
70. 
    
71. 
    ( p! {! T+ J& C9 G
72. function start(event){
    
73.         console.log(webSocket);
    8 H/ i' U6 r8 T5 o* a6 e
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);
    , v8 k- k7 y# Z  ]7 p6 v
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    ' z9 a5 w0 P0 B3 u2 b
80.     };
    4 F# K) X( A  v2 \; f9 m) t
81. 
    $ @3 n  X! T3 M5 B4 v
82.     function close(event){
    + O- {+ ~# o7 k5 G
83.         webSocket.close();
    
84.     }
    & S/ O+ t# e; p/ `. r
85. </script>
    & `$ X# t$ e  K' t: o6 m5 e
86. </body>
    , M5 N/ F7 o4 z+ d" K, ]! [
87. </html>

复制代码

1 D9 A( r8 t8 h3 m