php实现websocket实时消息推送

admin

php实现websocket实时消息推送

; C; U, Z. O. C6 l2 n7 j' v
SocketService.php
' x6 a0 U* y. }+ `! m5 x

1. <?php
   
2. /**
   8 m2 o# {  y3 k: o9 x3 m
3. * Created by xwx
   ) g' Z/ \1 I  N1 i6 D& n
4. * Date: 2017/10/18
   & N' z* w2 V7 _
5. * Time: 14:33
   
6. */
   
7. 
   
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
      u, s- K6 T" Y8 q1 b1 v' g
11.     private $port = 8083;
    2 S2 E, m9 t) {! m& V7 g# X
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    1 t' W) ?. ?' @6 ]# J3 N
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    9 V. i* K, U( d% y$ q
18.             if(!empty($port)) {
    5 R' R7 l/ n0 S& E* w( h
19.                 $this->port = $port;
    
20.             }
    
21.     }
    7 V$ m; ~1 m, Q% j
22. 
    
23.     public function service(){
    , Z* g& i. q/ A9 [, X
24.         //获取tcp协议号码。
      d3 z% J9 U  f
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    " ~: O1 f7 D9 Z' Q' f" q% M' i% c
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    5 z" i2 |( [' |' R- F: e1 s
31.         }
    % ]  J: u% T# N/ V6 Y
32.         socket_bind($sock, $this->address, $this->port);
    1 A5 H5 |( n! ~
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    1 u, |  d! m4 o( [
36.     }
    
37. 
    
38.     public function run(){
    ) h! a: ?% r/ ~
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    " N# [8 N' o8 h1 j0 ~6 H
41.         while (true){
    
42.             $changes = $clients;
    . c9 G6 n7 A- h
43.             $write = NULL;
    . e2 n! W/ K% w: m5 Y8 F
44.             $except = NULL;
    4 w: K; R) {( ^: O
45.             socket_select($changes,  $write,  $except, NULL);
    ! L( n% r* ~7 R- U" z
46.             foreach ($changes as $key => $_sock){
    2 n2 r) G! I# z+ p; m
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    ) K4 N) {+ X! s, I; l  W+ g
50.                     }
    1 d% k* f$ Y  E9 v
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    6 P# e9 E! z8 k2 n, u2 u1 J! {
53.                     //获取client ip
    ) D) N" ^" M8 B/ e+ S
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    0 R; [% r$ ~: @. I
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    - F, e0 S' K* C/ v# B
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    + S1 q8 W0 [# U& t
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    : K# M2 R: p% y; @+ P
66.                     echo "{$key} response to Client:".$response,"\n";
    6 B) z* W! K( Q, {, h. {3 y2 e5 w
67.                 }
    9 |2 V7 y4 m1 I/ `* {5 R6 r
68.             }
    : Z8 P# _- n- W% l; c+ z0 x9 l
69.         }
    ' G, p5 Y; T; H! |" `, p
70.     }
    
71. 
    * E- ~# O( |- F
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    . U9 j& @* S! c  q, X5 @5 U* V
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    6 y4 v! w8 I/ g6 s/ S
79.         $headers = array();
    & o3 M1 Z% f, k/ R
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    / o  f9 k% r7 V. J0 q
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    7 w! I+ S0 K0 u0 S0 d7 c3 c! h0 @7 t
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    4 \* K0 A+ c7 o/ C/ v
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    7 v) z2 ?  t7 w  }( U
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    8 U4 Y! x* R7 h+ v7 [+ I, e0 X
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    , c. e( o1 ]1 o1 _' ]
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    : ^) h/ b* K2 \% o% s
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    " O2 X( k8 v; w2 M; L0 o0 ?
98.     }
    $ e" y4 o- v9 Z( ?% b# ^
99. 
    
100.     /**
     0 u( c* g# g" F& |
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     " L8 L1 l( h( r" G: u
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     ( e$ S: r% A1 W5 U6 X$ J
109.             $masks = substr($buffer, 4, 4);
     " T- m. i; ?- q& L; O
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     ) |8 |! |+ w: L1 [) R5 B; s( P( m5 [
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     " F5 ], x- f( @7 N5 ?6 i8 }7 \
116.             $data = substr($buffer, 6);
     
117.         }
     - W) R$ y) L0 G( @  _
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     2 {- F2 @+ j. ~& q% e+ y% ]: G3 R
120.         }
     ' s3 M" @( R7 `) {0 x
121.         return $decoded;
     9 j' H, ^  Y! w6 m
122.     }
     ) j4 v& n) a4 g4 Q3 P% p" u
123. 
     8 V, R: _% {, V+ k0 |+ m7 t
124.     /**
     ; c: F2 g4 N* b2 [7 A! K
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     8 z( e; j  A1 [1 x# |6 a) X
128.      * @return int|string
     * y" |9 k% B/ X  K1 \, _
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     + |: y8 R* N1 h8 f4 J8 F% O
132.         socket_write($newClinet, $msg, strlen($msg));
       N3 w; d. ?, C; e- I& G
133.     }
     
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
       p4 F* N& b, U; Y
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     ( O* g8 C/ s% G: L
141.         foreach ($a as $o) {
     ( k9 R' s2 W$ |/ n4 u: n! _
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     6 p% g% }" r! }2 q5 [
144.         return $ns;
     
145.     }
     ! K9 r$ R" f$ U* h# k$ }
146. 
     8 N9 V, |4 u$ c
147.     /**
     5 {: I) b* x. w4 E0 w
148.      * 关闭socket
     3 d5 k  k# \+ Q* Q1 I' p
149.      */
     
150.     public function close(){
     & F  {: O3 `  m- @1 J3 n
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     - P1 W# J4 j/ j1 O1 q( x( R$ \
154. 
     
155. $sock = new SocketService();
     8 M2 Y; k1 F% Z$ i5 v, m8 y
156. $sock->run();
     - r4 q- z( u+ Q* ?* O
157. 
     ) P6 C- J0 K6 f) ^7 G* p% J1 N

复制代码

web.html
2 d$ e! ~  Y% ?. J  K, I2 V

1. <!doctype html>
   ! s" f2 c3 l6 @9 K5 g
2. <html lang="en">
   # {2 P& s+ |. o
3. <head>
   
4.   <meta charset="UTF-8">
   : a4 @3 T8 x% Q
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   ; n1 B9 i7 }  W' x
6.   <title>websocket</title>
   & H5 G, F% J, B5 F) g0 z
7. </head>
   * X1 l  P+ z' n9 W$ C- \) z9 T. [
8. <body>
   # O) K# z) u. h  O6 `2 c$ Z4 t
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    * }) X+ u% J/ Y' S8 d% _+ e2 m
11. <input type="submit" value="close" onclick="close()">
    ' [& O/ P8 _  T1 j
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    ! `1 [4 p! y  p) a& H; Q8 ?% Z
15. 0：未连接
    & f/ Q$ L" I+ r: r. X- I( n* k
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    1 q7 }! s  Q7 }8 G
18. 3：连接已关闭或无法打开
    
19. */
    ( d0 d/ G8 s3 e( W6 n0 b
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    $ L6 a! h; u/ e6 J  I8 @
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    , U3 T0 @3 a, X* G1 U9 w: W
28. 
    ( R0 u+ Q& c% x
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    1 i' K8 `' I! ?& k
32.     };
    
33. 
    ' _% f! P* i+ G6 F! R
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    / r$ r3 p  |. ?' ?2 C- J
36.         onMessage(event);
    
37.     };
    
38. 
    ) `7 |. J) n7 s4 Q% b& O: I0 F0 ]
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    . m8 t& q; d. o  N4 H# S% A# ?
43. 
    * l" Z7 \- d5 a8 d2 h% ?
44.     //关闭监听websocket
    1 @8 v$ J; m! |! \1 t9 z
45.     function onError(event){
    + x- w! P% u8 J2 m
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    * {! m. n' b  X$ X: }
47.         console.log("error"+event.data);
    7 Y0 }1 p9 L' a7 a- O% t
48.     };
    
49. 
    ( D( C+ d2 X9 c+ _' \
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    ! S# o0 w: T) K- ~5 C
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    $ S* c$ e3 h& I
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    0 n4 [" V0 m# V+ e# i$ [
58. 
    + E4 Z0 ?' X( p0 T  v6 l
59.     function onClose(event){
    4 m$ H1 t$ a, d1 Y, Z6 c. D  e
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ' u3 y" @3 a  H0 H3 [: _3 ?
61.         console.log("close:"+sockState());
    ) y5 G* l' q! Z. \. Q- m" ~
62.         webSocket.close();
    ; G- K' y2 P) ?$ O  }
63.     }
    1 y, p( V1 m; v2 d
64. 
    
65.     function sockState(){
    7 A2 H0 G! |9 L0 l/ S& d8 L
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    & Y, F' j5 t. i: {3 n0 f) d
69. 
    , x1 f- T* [$ S& F; R
70. 
    0 P$ I$ ?0 c4 [0 P2 J: r: z
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    5 j% h0 }4 R$ o5 {/ _
74.         var msg = document.getElementById('text').value;
    - b+ d9 t5 s6 B' {& f" r
75.         document.getElementById('text').value = '';
    0 o: r' o9 X6 h6 [1 C) H) [
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    - [, A; U6 P& a8 ~5 x* C
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    - h. y0 R# a& {/ _( Y( [+ j- t/ T
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    5 Y; G0 x. r- B) W+ V! ~/ i3 F( `
84.     }
    
85. </script>
    
86. </body>
    
87. </html>

复制代码