php实现websocket实时消息推送

admin

php实现websocket实时消息推送


SocketService.php

1. <?php
   8 }7 w  ]0 C# L% z" ~' W
2. /**
   ' o8 T" B5 T9 P" L0 p+ v
3. * Created by xwx
   & d! f/ Y, q8 X. o; O; s: i& V
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   
7. 
   9 w. v6 L+ P0 C0 s# m4 ~6 V
8. class SocketService
   - l" m2 M2 ]" o) r
9. {
   3 w! `% F6 G9 q9 A+ e+ c* m& N
10.     private $address  = '0.0.0.0';
    $ h. }% z2 i$ o4 o3 m9 ?" H
11.     private $port = 8083;
    ) ]; H3 V, q. K& n
12.     private $_sockets;
    8 h& v3 m$ k- ]
13.     public function __construct($address = '', $port='')
    , N% S' L1 [2 E7 b; |8 I# f9 F
14.     {
    - S; \4 `+ E6 G* p, _' O" b0 U
15.             if(!empty($address)){
    ; t, q% Q! d' i" f& ~
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    1 v2 H/ X+ `& S' x. N( a: `4 m
19.                 $this->port = $port;
    
20.             }
    
21.     }
    9 m. Q6 w; u4 i+ |
22. 
    1 N9 @  y$ M1 ]- n( n6 w
23.     public function service(){
    , i7 b. y. i3 L) @
24.         //获取tcp协议号码。
    $ f$ O, q/ ?8 J- B9 a
25.         $tcp = getprotobyname("tcp");
    9 }' ]) t8 `% M, l" h
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    ! U/ B: y. O3 g4 v
28.         if($sock < 0)
    # }9 ?! s, E6 s6 D6 S8 G/ ]
29.         {
    ! n" }, z7 l2 e! C& ?+ d3 ]4 W
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    & p0 W2 P+ O) N. U/ T8 L: z
31.         }
    + `+ A/ ^& F: w) p! g
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    3 w% V4 T8 b; e* N4 N$ q2 e+ V1 Q# U, C
35.         $this->_sockets = $sock;
    
36.     }
    % s" @0 s- w5 n" w' S
37. 
    ( \) T' L/ z; d8 ?
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    & R! [  c# L' x, H2 C, `+ ~- [
42.             $changes = $clients;
    8 E3 n! F/ P" f% Q  f4 e
43.             $write = NULL;
    
44.             $except = NULL;
    ( h, l# y$ s' O, G* v2 v6 G
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    9 f# \: ?+ X) L: s9 C
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));
    ! N9 B4 \4 x' M! [
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    / ?2 {3 D1 B6 c, u3 _
55.                     $clients[$ip] = $newClient;
    4 ?  M& ^2 \  M+ z2 K5 e$ x# A
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    0 L9 a4 Q, I1 y5 P
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    ; _7 ^% p8 X3 {) `
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    . y1 V2 |: y8 x" q* f
65.                     $this->send($_sock, $response);
    ) W! U+ K1 M. s) D( n! g# v0 F9 u
66.                     echo "{$key} response to Client:".$response,"\n";
    : H  u( a0 ^! ^( K
67.                 }
    
68.             }
    
69.         }
    
70.     }
    # B2 k) v$ y/ n! U4 T
71. 
    
72.     /**
    ; h4 Q+ N% I/ q6 e, \4 T7 v
73.      * 握手处理
    
74.      * @param $newClient socket
    3 \: Y$ g2 o# c: A: X) o
75.      * @return int  接收到的信息
    
76.      */
    " k( @, `) L6 Z6 V( t
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    / \  B9 g, W1 X! V. p% @$ o
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
      P; ~6 c9 S  H, T! }, p( i6 L2 B
82.         {
    : L3 ]0 x5 }4 C  ?
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    1 q0 w+ l" q- }& G! O+ q* _
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
      p' {. O3 _4 \5 q2 \
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    " ~0 H; k. [& i$ i$ }9 V8 P
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    6 T" z3 ^9 P6 D4 j# r2 _
92.             "Upgrade: websocket\r\n" .
    & T7 h. p# V+ i6 ?
93.             "Connection: Upgrade\r\n" .
    , w- K$ f4 l( a
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));
    
98.     }
    % K+ j; b( Q. d. p
99. 
    - ?; t# v9 _( V4 V# B9 w: Y
100.     /**
     . a" [! x" X9 Z- ~
101.      * 解析接收数据
     * A/ h3 A4 F/ ~, q. ^0 V! a8 C3 g! {
102.      * @param $buffer
     + z& \& w/ c) p9 w% D
103.      * @return null|string
     $ ]! t  d1 ~1 h- V: `7 K
104.      */
     3 j, g0 s6 v$ [, y2 v! Y
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     % z+ B+ t7 h: x0 I- X3 Z. q9 d
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     7 e9 [8 c  L3 f# B
110.             $data = substr($buffer, 8);
     7 `- d& _$ C- l0 ?+ A$ l/ A
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     9 y/ q! H3 ?  o$ w) B/ |
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     ) p5 r: v. u3 B+ \  E7 s% ]
116.             $data = substr($buffer, 6);
     
117.         }
     % _, a0 K0 W4 k2 C7 P0 _
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     0 E3 c/ @. R! z& F, Y% E/ Y
120.         }
     & ]$ t0 C, |2 [% C
121.         return $decoded;
     
122.     }
     " _* I5 ^' r2 d" C7 @( U
123. 
     6 P* D3 ?! ^) S  X; i' j
124.     /**
     
125.      * 发送数据
     ; u, b. r4 ]: `1 E3 L' ?
126.      * @param $newClinet 新接入的socket
     - ~5 |! e( B, b' D- b/ L
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     , N8 k7 d, X/ T6 u& `- x
129.      */
     
130.     public function send($newClinet, $msg){
     / v  G$ T) I* Y- x
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     1 F$ t' O: R( }& R" G
133.     }
     . O- Y8 b- D, S! e% ^7 D! `! `
134. 
     5 D/ I3 [! u, ?: b
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     & P0 o  K% M( D/ r$ C4 f
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     ; F2 O- O$ E% j1 V
139.         }
     
140.         $ns = "";
     + |, n: ]: n) y" |
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     & O* K# ^) f" B& p
144.         return $ns;
     
145.     }
     5 ~8 \% [. D* {" W0 ?% R
146. 
     1 J% c  N5 x" C( B
147.     /**
     
148.      * 关闭socket
     ) Q  s% A  w$ ]0 g2 z5 R* W
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     ; H" e; [4 D+ ?' ]
153. }
     
154. 
     : q( N/ @9 I5 _  e
155. $sock = new SocketService();
     + g' U4 |0 |- e- }8 H( P
156. $sock->run();
     
157. 
     - G0 _4 N6 i0 r/ z

复制代码

web.html

1. <!doctype html>
   % e4 D" v8 D$ T, S8 B5 j; T3 F
2. <html lang="en">
   
3. <head>
   4 a) Z8 i# Y% C) l
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>
   
8. <body>
   1 X0 M5 v$ I' J$ ~+ [( b
9. <input id="text" value="">
   , V* ~. K3 y/ x- T) M
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    4 ^3 J7 \% X/ p3 ]2 k
14. /**
    
15. 0：未连接
    ( x5 Q. @' _) e7 o1 s
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    * i; h1 ]( b% n# s6 e7 w3 J
18. 3：连接已关闭或无法打开
    
19. */
    - K/ E* j0 p- e# l9 M$ A+ `# S
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    0 S+ H% K  O8 Z5 b5 y# V" Z
24. 
    , C# Y6 ^1 V* U' ]6 ?  ^
25.     webSocket.onerror = function (event){
    2 M: m; A3 t9 e* X  ^& O
26.         onError(event);
    / e2 S% d' R) b. @
27.     };
    
28. 
    0 C# h5 b* i' r1 i# |' b
29.     // 打开websocket
    ! j, A2 F" v3 p$ x" f2 u( ?
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
      x- U- z: i5 B0 C2 A
32.     };
    ) c6 |2 y* I: v! K+ C
33. 
    
34.     //监听消息
    5 \1 {4 Y3 C; Q" M. e
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    8 ^# q5 p+ P7 J  \' v8 s8 n
37.     };
    8 h; z" z, N# C# G1 [
38. 
    ; B- C; p1 S" Z  T
39. 
    # J. W8 d7 V. ^
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    3 b# w9 H  Z' y0 R! B/ S
43. 
    & Y& Y/ {# U5 G
44.     //关闭监听websocket
    # D$ u- f# U0 W0 {0 N! a- T
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    + {' `" V( ~% U) A
47.         console.log("error"+event.data);
    
48.     };
    0 U/ l! r5 [1 B$ ]5 O( W8 U  ~1 k
49. 
    * |# T: g/ S/ b8 t
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    , P2 ?( G5 E- e" C' o, s1 K1 U  V( B* q
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    / ?! P- y) S( `5 D+ K
57.     };
    6 c( S; W/ y  A) a' o- k; x
58. 
    9 ]( d: i$ V* Q6 j, S: o& ]
59.     function onClose(event){
    : K) G' ^! r% P) I& u
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    $ Y. @3 t4 e+ }2 K: N0 h2 U. b
61.         console.log("close:"+sockState());
    : R# y4 X6 S* x- [. }
62.         webSocket.close();
    % a! @2 u0 d9 z$ b* c  ^% S$ X! T
63.     }
    
64. 
    9 Z5 j7 ]  O& a/ ]" u2 \
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    ! G4 o' ?! U( Y- i3 n! c
67.             return status[webSocket.readyState];
    $ o4 @( o. l- v+ J5 i$ `' u
68.     }
    
69. 
    0 m$ Z: @$ C7 c: t5 S6 L% C3 Q
70. 
    
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    , d6 g8 K, o1 \: S/ S2 d: q* A
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    5 M+ @! q) r' f
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    
85. </script>
    ) C, M+ r+ ]6 B9 l' S
86. </body>
    
87. </html>

复制代码

  m( g2 q+ P$ W2 j) F
% l' `+ O; l% Y! n6 w