php实现websocket实时消息推送

admin

php实现websocket实时消息推送


SocketService.php

1. <?php
     r; n3 H2 N- ^
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   $ C3 q( \( b  \* K& j' C: E
6. */
   # ?0 [5 x1 D" u2 K6 n
7. 
   
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    * e2 n" p7 x2 X0 J
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
      t. U: I) I, j# s3 C, ~
14.     {
    $ f- p& s" T! d
15.             if(!empty($address)){
    & d- P" ~( ^! {  V% [
16.                 $this->address = $address;
    % _. ~4 ]6 q' m+ O2 T
17.             }
      h, ?& k' ?" q
18.             if(!empty($port)) {
    , x6 \- k1 }, }3 b" @
19.                 $this->port = $port;
    # l5 W6 F' }; q' a: ~- n8 \& f
20.             }
    ; o8 ?1 O& E; G9 ~5 U9 f
21.     }
    
22. 
    & H2 [0 u7 I# `$ W# s) ?* E. c2 b3 |
23.     public function service(){
    : e( E2 e) a% y
24.         //获取tcp协议号码。
    2 A! P3 \# u9 P  v
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    ' B# ?" O" h8 i% c
28.         if($sock < 0)
    
29.         {
    # ^' L/ Q" r4 E. z
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    + ?% G8 a& k' a
31.         }
    2 C$ J5 M2 N  O- V7 V
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    ) ~  Q, Q$ W. K; `5 s4 a  I' R% l
35.         $this->_sockets = $sock;
    9 X7 s8 x# E8 K1 m9 X9 ^
36.     }
    
37. 
    4 N5 C# I* Z$ j5 {) X! m- ^8 T0 y
38.     public function run(){
    1 Y8 A, N" ]7 m5 b- n
39.         $this->service();
    " `0 Z# I4 H! z. B$ x" e
40.         $clients[] = $this->_sockets;
    $ ?5 z/ v5 G" @6 T* R4 R
41.         while (true){
    + D4 B6 z5 m; b5 @  A4 `" _6 F
42.             $changes = $clients;
    ' q6 b. E* y$ p8 m
43.             $write = NULL;
    
44.             $except = NULL;
    ) ~0 `$ m* D% b: V5 e5 \5 |
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    ( i% {* I; w9 i; t
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    5 D5 R$ j% F3 L+ o# I" X' N; T. D
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    5 u. t  }6 A! ?) F  P: c
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    1 ?% U% |3 [* V) l1 X
52.                     $this->handshaking($newClient, $line);
    $ i8 F" k5 h% V& }! C/ x
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    + H3 R. K  C& J; w1 E
55.                     $clients[$ip] = $newClient;
    8 W' N2 j) ~6 R& z) B" z9 s
56.                     echo  "Client ip:{$ip}   \n";
    - e4 b( W5 N7 G
57.                     echo "Client msg:{$line} \n";
    ! h. s1 p& M! Q2 P8 V
58.                 } else {
    . L6 y2 [5 p. O1 l4 r. q
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    ! v: v2 i  k: j. v3 x! x
63.                     fwrite(STDOUT, 'Please input a argument:');
    4 }- O/ \; t0 x) I5 E$ @
64.                     $response = trim(fgets(STDIN));
    2 }- n3 j6 o; P3 v8 G
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    5 n" f' i7 s: ~3 n
67.                 }
    * A! L2 {1 b  W' E8 p
68.             }
    2 ?& T: Y. f# K! U" {! i8 w
69.         }
    + w* O9 Y8 ~  _. L6 o# s: ]; w
70.     }
    
71. 
    , c7 H0 s: y. b1 ]9 U" G0 g  T! J1 A. e
72.     /**
    
73.      * 握手处理
    + ~4 m/ [0 x8 R7 s2 H
74.      * @param $newClient socket
    ! o% x; @5 \4 o# J9 ~& H8 C" Z
75.      * @return int  接收到的信息
    : |& V9 |, R" x& r
76.      */
    + A: F: `3 t3 L
77.     public function handshaking($newClient, $line){
    ) R/ F' @/ G( C# A+ t' [1 }
78. 
    4 ?/ p8 b, k2 H5 X$ e4 Z  O4 X  E
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    2 b0 T# v5 ]" k% E2 n/ A  q0 x7 Q
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    ! j; j4 k" t% J% [
89.         $secKey = $headers['Sec-WebSocket-Key'];
    8 q3 G1 C7 Q4 @( @6 v# g5 m7 ~
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    * J9 m/ ?5 V$ p5 u: G
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    ' z- V( T* {( y+ ~' D! \6 E$ e$ J
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    " T2 e4 }6 ~7 Y, k
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    " g3 K7 n$ t* Z6 a: ~9 E, h5 ]
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    " i! t- g, V$ B8 F2 N+ Z
100.     /**
     
101.      * 解析接收数据
     * O8 p: q) K+ j$ n; \+ [  {/ S
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     * L' G/ z0 ^4 q# x9 x  I- ]
105.     public function message($buffer){
     2 ]* y) U5 P/ R
106.         $len = $masks = $data = $decoded = null;
     & P0 B" r3 j( S4 M2 A' k( _
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     5 y8 L# v) U) q$ Q) {' E( c2 d" ~
109.             $masks = substr($buffer, 4, 4);
     & K5 A4 C6 F" _- b& b
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     6 Y+ X. j% @1 N
113.             $data = substr($buffer, 14);
     & _  L2 S$ h9 f' k! H& U7 N2 Q( K, b8 i
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     : c3 j8 m3 u& U* n) E- b
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     + e% C( ~- x' [2 c( r
121.         return $decoded;
     , X4 m) _6 [* D6 F1 ?. I  w
122.     }
     4 y. a1 s- m' I) b
123. 
       I4 G' b) X& M  H
124.     /**
     6 a6 b" w3 u& t/ I! f
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     2 u0 Y" [% n( }
127.      * @param $msg   要发送的数据
     4 L/ S8 u" h. K2 u7 b$ M: s# B
128.      * @return int|string
     ' L, q, d( O0 n( k
129.      */
     5 n& N  Q7 w1 h, [# I& I9 I9 g
130.     public function send($newClinet, $msg){
     ) P6 @( E1 s+ f0 Y
131.         $msg = $this->frame($msg);
     2 o$ }! y% c  Q
132.         socket_write($newClinet, $msg, strlen($msg));
     + Z! K1 J$ Q0 r' W* A; ~: o4 a5 F
133.     }
     2 F8 O4 z  z' C" G( N' {" o& H, }1 z' Z
134. 
     ; G  C7 M  t) H0 M
135.     public function frame($s) {
     7 u3 B  Z, |9 u2 t: m/ Q+ G
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     2 N2 S; \8 I7 E: [4 ?
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     ; s. v! L/ z/ ~# ^" F& E" f* s
145.     }
     
146. 
     
147.     /**
     1 X; }. D9 c4 {4 e) g6 S
148.      * 关闭socket
     ; k# S. p7 v) i& Q" i. Q# }
149.      */
     0 r  W0 l0 h' A. i
150.     public function close(){
     7 @& A: |( q7 S6 J. r( ^$ L
151.         return socket_close($this->_sockets);
     0 I5 |& A0 A0 R$ q9 f6 C$ |
152.     }
     
153. }
     
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html
7 M3 \$ |' h8 l% j

1. <!doctype html>
   
2. <html lang="en">
   6 ], @8 a4 K% K- N  p
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>
   " _* G" k  J) x2 l  \: Z, z
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    + W' T, e  x) s* a2 o
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    ; n2 e7 T. ^* F% I; C( O, K
13. <script>
    
14. /**
    - @7 }9 x( O$ _
15. 0：未连接
    6 k& b" R; W6 D4 V. ]
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    7 q. I; ?: l! Q. |/ b- }  Y7 W: R
19. */
    
20. 
    , m9 r' O) U7 z
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    4 ?: p% c  ~( p3 E- q
23. 
    
24. 
    ( j$ q' A) M) N  \) w2 H+ w
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    6 K$ [- i. z3 Q3 V
27.     };
    ; h0 Y/ k6 Q6 A6 i$ I
28. 
    
29.     // 打开websocket
    , b+ \, Z& R! e+ g+ N; t' \5 X
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    / c: u$ H* U) L& A8 V( k7 K
33. 
    
34.     //监听消息
    % u3 |$ v" E0 A% Q
35.     webSocket.onmessage = function (event){
    & P# A1 A8 a# w/ w
36.         onMessage(event);
      ]( T6 p- L5 r7 ]( `8 O7 k: a
37.     };
    ; d/ ]1 J% U: z- m- H
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    
43. 
    * ?: C9 c- t6 D: k/ v
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    0 M) B. ^4 k( q/ a' @, ]
47.         console.log("error"+event.data);
    
48.     };
    # `5 I& x. {) ~+ ^
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    / v- X" \7 N$ p
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    % @, z$ W/ _6 \4 M& t( f9 ~7 ?7 Q
53.     };
    & E# F3 H4 X3 @0 D" ]
54.     function onMessage(event){
    
55.         console.log("onMessage");
    ( ^6 k- r9 x2 ?% B$ I" g
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    : \7 O8 B; g3 |
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    1 T) O* d: ^- X/ t6 c% \  w# W! Y
65.     function sockState(){
    4 n  {- G3 c' K& R: a
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    ) C4 A" B/ e+ |4 r% ]
67.             return status[webSocket.readyState];
    
68.     }
    0 U6 z* z  @# Z( O
69. 
    , N- |' f3 D9 i/ Z! G
70. 
    " ]  T2 J( k- L1 e  O2 ]. G# Z( B
71. 
    3 R6 @/ L: f% X! ^
72. function start(event){
    ( r# W0 ^) `1 U+ v/ N- A
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    ( n0 C5 q+ B. k1 r7 R7 q: I
75.         document.getElementById('text').value = '';
    0 ]5 a+ l" H. D, a0 K
76.         console.log("send:"+sockState());
    : E- s5 N4 |9 [
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    * S# ^8 ^0 n* l' `' ?
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    " ?4 x7 l# ^: t# r& A+ t& N
80.     };
    * o5 q" \( D: _3 U
81. 
    & s' I9 a& }0 K, W# b
82.     function close(event){
    6 P7 V5 ]' [$ L2 [
83.         webSocket.close();
    ) h, y& w( H2 q- x. M% z2 D
84.     }
    3 P& u9 g( T  e7 B4 M8 q
85. </script>
    ( L! a6 |# G8 W/ M% L8 j' W
86. </body>
    * |" E- Q( C; c$ p* o
87. </html>

复制代码

6 x7 ~" f0 ]& g8 X: H

6 t: s3 a  u0 _2 O( k$ f, N