php实现websocket实时消息推送

admin

php实现websocket实时消息推送
7 P6 _# Z5 s! y; P  C

SocketService.php

1. <?php
   
2. /**
   ( p3 @3 F' B1 p) C3 P6 K: N
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   ; ~* J2 S* L9 L$ R* A+ {8 i
6. */
   
7. 
   . l5 f) e3 q$ u! ~# R
8. class SocketService
   / v# H1 Y  q3 e" d; Y* ?
9. {
   
10.     private $address  = '0.0.0.0';
    . c$ q6 q8 K+ T: K  \$ K
11.     private $port = 8083;
    
12.     private $_sockets;
    5 E. p* M( L( s  p: l
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    1 j6 a; K+ u3 o" l+ ^9 Z+ c
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    * {; S4 V6 D% ~$ `9 x. p/ j
20.             }
    9 K0 O" j4 T7 I3 k
21.     }
    7 z8 f# l! c& Y. @
22. 
    + k/ V( f' z0 }0 g* z
23.     public function service(){
    # R9 k& U( G+ \& W6 `1 j! ]2 v
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    0 j# S; U0 o, g- }# `
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    9 z& R- P" A4 ~- {( {
28.         if($sock < 0)
    ' Y$ \; D: Y% ?- w; S  L, \
29.         {
    ( S( u8 p  ~  M$ I9 T" q2 q' E
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    & @) H# o" {5 p5 D" t0 b
31.         }
    2 ^( d; H3 T9 O
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    % K/ j1 N; Z' F! x, ]+ G& @2 s
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    - @" y' J, c: C1 e6 j  N7 l
36.     }
    ) ?. J  A3 Y& n* G9 O- O& B
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    ( D0 _* a& E3 `* P
41.         while (true){
    * f" M2 s! ~4 J& v4 q
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    ' {# n+ P7 i+ d2 Y" Z
45.             socket_select($changes,  $write,  $except, NULL);
    & z1 B* {% }) _$ E; ?6 Q
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");
    2 P5 ?# A8 \# {% d) l! P  L: Y+ R& O
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    1 c, G7 U0 T) i! D
55.                     $clients[$ip] = $newClient;
    1 e+ f$ D( ?" j: i' d3 N' T
56.                     echo  "Client ip:{$ip}   \n";
    & Q7 ~! ]1 ?3 q2 j- H
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    4 f5 w) f; o( t2 V# Q0 @1 [
64.                     $response = trim(fgets(STDIN));
    $ K, [  o5 L  O
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    ' o3 F0 N6 k' a# w
67.                 }
    
68.             }
    
69.         }
    ( K! d  Z; u4 C; a# G6 g. O0 a
70.     }
    % _, g5 @; e+ e# W$ ?7 b
71. 
    
72.     /**
    / K( D) f) i- _1 @
73.      * 握手处理
    / j6 _- y: A' H* A8 r0 h, B
74.      * @param $newClient socket
    % V) i' h0 Y* ]( ]8 x
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    $ \, ?  O% y' L
78. 
      k3 q: l1 q# g0 I5 w
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    - h) x; V  g  {! p5 O0 n3 M
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    2 |8 f0 o4 @+ o7 I4 i" o
88.         }
    3 P. w; ~' {; o- F! P4 y
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    , T) x& P2 b- L" e$ H  c, _
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    ) w. H: G; E! e( ^$ {
93.             "Connection: Upgrade\r\n" .
    
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";
    6 ?' a: D8 p1 c3 S9 ?0 g! M# |
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    " M$ [7 _8 I! r) l5 s! A
98.     }
    # x& ?% o; A* s6 @+ z+ m0 ^
99. 
    
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     9 b) f  f$ Z7 l  o$ [7 m' R- t! Z
105.     public function message($buffer){
     % Z8 l- w* b  V5 p: _
106.         $len = $masks = $data = $decoded = null;
     3 w* V; C4 A5 f$ A* v
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     6 `7 T1 g$ O/ g9 ?! S  c% k/ h, ^
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     & |; C1 v3 j2 H2 X" O
114.         } else  {
       m0 G3 a* r; Y3 a
115.             $masks = substr($buffer, 2, 4);
     $ Y* ?( Q' z4 U0 D2 y  B
116.             $data = substr($buffer, 6);
     
117.         }
     ; c2 x8 M' F* y. v  c- A/ k
118.         for ($index = 0; $index < strlen($data); $index++) {
     3 x. x) u' ]) ^# P" v* f8 I
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     " a1 c1 M3 p7 ~; K& k: u9 g4 r
120.         }
     1 F" L; B6 u$ D9 g: w& f
121.         return $decoded;
     
122.     }
     
123. 
     
124.     /**
     
125.      * 发送数据
       G1 m5 i7 [' w! D
126.      * @param $newClinet 新接入的socket
     ! {( m+ P4 j! I" m0 }( C, K0 q0 Q
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     $ O& C" U- U. k+ |6 G  p; p/ g" o( u" L  x
130.     public function send($newClinet, $msg){
     ; h% c4 M( a9 h- i4 R
131.         $msg = $this->frame($msg);
     + U$ e1 @4 L6 |5 n( c& @& S  r; w3 s
132.         socket_write($newClinet, $msg, strlen($msg));
     - D5 W9 b# I+ F1 G
133.     }
     
134. 
     
135.     public function frame($s) {
     * a6 d7 k* c+ ^" W- G  a# e% ]
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     . b7 T' E% n) Y# _4 W( k
139.         }
       r1 _+ Q, X8 o4 Z/ N) X8 D, f
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     2 S. Q# X" J7 s( L9 C
144.         return $ns;
     
145.     }
     6 P# u0 E1 x. r! V
146. 
     
147.     /**
     ( Y8 j8 P; B( B5 o1 p
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     & ~* `: j; b5 {
153. }
     
154. 
     & S8 {- x- }; K' z
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html
4 z2 V- U, {9 H0 x

1. <!doctype html>
   
2. <html lang="en">
   9 ^0 f+ ]$ x$ ~/ \: g4 K" w8 R
3. <head>
   $ C! y. P4 l0 N/ A. K8 o# r0 F
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   6 Z' _$ S6 l; S0 Z% I
6.   <title>websocket</title>
   
7. </head>
   4 e; i6 z) Q' `# T
8. <body>
   - ]) z1 m1 U9 ]
9. <input id="text" value="">
   ( ?4 n% |2 Y, \" G2 `
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    0 B2 y1 w& q& S- J1 g7 t4 v
12. <div id="msg"></div>
    ! H" m4 x  d1 X
13. <script>
    
14. /**
    6 [6 M1 d  Q, [2 A! ~  B( }+ t8 m
15. 0：未连接
    ) D* }2 y+ a+ O( u. V
16. 1：连接成功，可通讯
    1 k, N/ y' c" P4 R7 S, ^
17. 2：正在关闭
    + I" c2 R% M/ O" v) g( f
18. 3：连接已关闭或无法打开
    3 Z. F1 o1 n& b% z$ I
19. */
    ; H. u1 U/ ?2 S+ u( {+ U
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    6 t7 N1 j) Y$ p- F* x
25.     webSocket.onerror = function (event){
    . R" A. y9 r4 I' A) H8 B. F! R
26.         onError(event);
    
27.     };
    
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    , j( S5 d' ~7 j0 o2 i& e2 R. o' b
31.         onOpen(event);
    . D$ R( @9 p3 c. [- h, r/ y* v% }
32.     };
    / j6 i" n2 N9 @! r) G6 V  ?
33. 
      T+ {8 ?9 I+ c
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    8 }9 c4 V1 @6 B5 ]5 p" a( T; L
36.         onMessage(event);
    
37.     };
    
38. 
    % ]( m; i: O4 c  F% _, S4 o1 o
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    - C/ E: E- M8 M6 H& W, `
42.     }
    
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    ! A* J2 O2 D0 m( l. o
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    
50.     function onOpen(event){
    ! `" Q9 a- h4 @+ I6 U
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    % Z& h% l7 z9 P# T
54.     function onMessage(event){
    
55.         console.log("onMessage");
    1 J" {% K+ U9 q# }; J
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    , A" \4 {8 h0 H% @
57.     };
    & E8 O# p9 t. m4 p" w1 U# H0 f2 O; C
58. 
    # X! X  @! B9 g* M+ V2 p
59.     function onClose(event){
    ) J2 g+ v# \* D. K
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    2 R5 ^7 Q8 w' Q, H
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    - M/ M: s* d8 J( t; B8 ?8 @8 M# X( s
63.     }
    
64. 
    + }" _& f% g' l. q
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    % I, Q  R5 m7 ~1 M  U) X. C
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    2 f. V% T" X" |/ I( @
70. 
    
71. 
    0 Y. ~! [/ Q7 c3 i5 G
72. function start(event){
    6 E. e% b( q2 t  i& \* b; Y
73.         console.log(webSocket);
    $ E5 d$ v, Y- U+ I
74.         var msg = document.getElementById('text').value;
    / G# \/ f6 n5 _+ h
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    ; r, `/ L+ y$ W
82.     function close(event){
    / j4 s8 w& s( A0 ?
83.         webSocket.close();
    / l' G! @( h) B. ?$ B
84.     }
    
85. </script>
    8 Y# Q  I/ x+ u6 m
86. </body>
    . x& J  B3 h% Q, g9 j1 ~
87. </html>

复制代码

2 O5 L% d- W/ c