php实现websocket实时消息推送

admin

php实现websocket实时消息推送
- P& y2 g) J( Z3 ?3 b6 O
( V2 h7 d! E' l, G1 B5 Y
2 D, h2 y( ^7 Z! W- b# sSocketService.php

1. <?php
   
2. /**
   ! X' @$ y* J0 J* [
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   * V8 L: ?( H$ ^2 _7 U1 F% k" a
6. */
   
7. 
   0 _  z) u) ?4 l9 p5 a$ G
8. class SocketService
   
9. {
   ) c# c) B: [, x8 J4 D' D
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    ; ]( T* F# _( f( @) y) P6 A
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    + O2 E! R" {5 G5 s" ^! C
16.                 $this->address = $address;
    ; [) E) f# k9 w8 ~
17.             }
    $ ^! Z1 I: B% `# J
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    8 ^+ {6 g  p# }2 c* ^' `6 ?1 b
20.             }
    
21.     }
    * K2 b% R* S4 I% r7 Q
22. 
    6 p# R# D" n% b2 X( ~- B: K
23.     public function service(){
    . x9 w/ h" T: L: A. w
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    ( H" L7 X% X1 ]8 U: j+ `
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    ' K' ?* h3 v0 X9 R9 l
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    4 O# z# `! e( A3 A% `5 Q
32.         socket_bind($sock, $this->address, $this->port);
      P: `/ Y( P. j- ?- ?
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    / X/ b. j3 V+ e* S1 O- X& N, Q4 ~( B
36.     }
    " P, z1 ~- ]7 O% D' X
37. 
      g% i6 u- C1 p4 h( R
38.     public function run(){
    
39.         $this->service();
      U$ x  D6 \% E
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    8 d6 ?9 i. {( A, L3 U  R, ^
42.             $changes = $clients;
    ( ^- Q: l) n' [$ Y
43.             $write = NULL;
    $ v, L4 Q0 [8 z% _! P
44.             $except = NULL;
    % y: R& b3 |8 p+ p" A3 m
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    , ^5 W/ v9 c+ q% \% m" g" u
48.                     if(($newClient = socket_accept($_sock))  === false){
    7 O. E0 x0 Q: o
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    ' b# G+ y* F: ^
55.                     $clients[$ip] = $newClient;
    2 p* z. `! B- f9 R' N
56.                     echo  "Client ip:{$ip}   \n";
    " N9 R; N2 Y/ C4 z4 t: {
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    & q$ E; f  a8 |; v+ l/ H. j
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    4 v+ i" i: L! u+ I* D  J2 s/ c
62.                     echo "{$key} clinet msg:",$msg,"\n";
    + m9 s- M5 s( q! U$ u" U5 ]
63.                     fwrite(STDOUT, 'Please input a argument:');
      k, M& _8 C# s' K& j
64.                     $response = trim(fgets(STDIN));
    $ a% c, B! S; F: [3 B# C/ t- A
65.                     $this->send($_sock, $response);
    8 z9 c9 q- u# o
66.                     echo "{$key} response to Client:".$response,"\n";
    : H& @- [8 Y- B1 V5 f1 m# l% u
67.                 }
    4 K0 ~2 G2 w5 x3 g: V7 g
68.             }
    
69.         }
    
70.     }
    / w$ [- z1 u& c' V0 l. j% a9 l5 ?
71. 
    
72.     /**
    ( [" A2 G6 X% a4 Z( U
73.      * 握手处理
    
74.      * @param $newClient socket
    - m( U0 W) E0 `% _
75.      * @return int  接收到的信息
    , {, w  A3 L% h: J% `
76.      */
    1 {- L6 x0 ~; Z: j; `! h  a! R- p
77.     public function handshaking($newClient, $line){
    
78. 
    + L7 p2 w. C! Q/ G% ~# g6 l
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    3 j0 h% m- H0 ?
82.         {
    
83.             $line = chop($line);
    . q! o  \5 r6 i; Q
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    . {$ }, O, @0 U# }4 U* z* B$ ^) q
87.             }
    
88.         }
    
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" .
    " R% ^9 i; ~* A/ j) V8 L' T
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    * t# t9 ^" ^) G2 o
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));
    : b' m. d, c; |( I0 i$ i, v
98.     }
      U/ e4 l3 A& U# w2 s9 n! q; b5 ?
99. 
    + O6 E, r$ U) F# L
100.     /**
     " n6 K: _. @" ~6 e* a% D# o9 K
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
       c$ n4 k; z! F( R8 W! I6 R
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     # X7 y! z% P' `
110.             $data = substr($buffer, 8);
     ' E5 W! E6 m' j
111.         } else if ($len === 127)  {
     4 O2 }- g6 ^: l7 j
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     - ~+ s1 C5 ~1 [8 B0 H( y5 p  h0 a
114.         } else  {
     9 v. g/ e* }! n6 q6 e8 ?
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     $ d7 i0 k; e5 k" `$ H) Z" D
117.         }
     ' v0 Q/ Y2 `5 y
118.         for ($index = 0; $index < strlen($data); $index++) {
     8 P1 f7 W+ s2 T1 T3 Z* z
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     2 z% X! a  f% N$ m
120.         }
     % x7 M: e/ w- T/ D7 Z1 t6 l4 p
121.         return $decoded;
     
122.     }
     4 U0 n$ X/ f/ }/ G$ w
123. 
     7 C/ `2 R/ E$ `+ s/ K6 n& j  e
124.     /**
     8 S* J( Z9 o: j) c. u4 c/ B
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     ) Y$ W  q0 ]# s) O3 o- e7 X# L1 C
127.      * @param $msg   要发送的数据
     ! Z6 l: v9 h9 ~! h- _1 J" K
128.      * @return int|string
     , b. F+ V# Q3 ?2 o. t4 y5 E
129.      */
     " g( @# M+ {9 b$ q* e: p, Z# B
130.     public function send($newClinet, $msg){
     9 l" R" x; I. y, H2 [  f/ Z! }( G
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     - k  L/ n: }4 t
133.     }
     
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     : S# t5 A: F. c2 w9 G. a
137.         if (count($a) == 1) {
     ( ~0 J) E) P; a% l
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     $ O- G$ c8 u5 `$ }
140.         $ns = "";
     2 q5 x. ~+ E8 W
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     0 M/ q9 o* ^8 W
145.     }
     
146. 
     * U% K$ w: K: F( V& Q4 _
147.     /**
     0 |- [. }# F5 {+ Q( \# z3 Q1 s
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     $ O5 e: L. f0 d0 P' W- n
152.     }
     
153. }
     + t8 r* D# p( _* y1 G
154. 
     & u% I- ~  D2 ?# q% ^, v
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     1 l  v1 i4 Z0 ?+ w5 T0 \

复制代码

web.html

1. <!doctype html>
   4 W$ E* x, r9 s5 f
2. <html lang="en">
   0 `# `9 |) C* V  x1 G4 }0 [
3. <head>
   9 ]* D1 n0 K+ D4 t# e4 `
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   4 J4 D+ o& [0 M1 |" X. Z
6.   <title>websocket</title>
   0 ?- x# z& W# H3 |
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    " k& s$ f, o  R5 g; P5 b
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    " }7 |$ }5 Y' I* f) Z, t
18. 3：连接已关闭或无法打开
    
19. */
    1 z8 _0 S9 |# A% ~6 t. z" c; G# A0 N
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    9 d9 r* V: W5 C, s# _( F6 x" W! d
23. 
    % E) y/ m  R" v& G( d/ i
24. 
    
25.     webSocket.onerror = function (event){
    " W5 D- y" E# H3 \  O. l8 r
26.         onError(event);
    , @- B6 r0 ^6 m. T& @* j3 e
27.     };
    
28. 
    
29.     // 打开websocket
    ' ]4 L4 n" W  [
30.     webSocket.onopen = function (event){
    ; Y- A' e, C% k/ I1 ~# e
31.         onOpen(event);
    % o1 D3 @2 c4 ?/ x" k# Z% L4 s1 @
32.     };
    
33. 
    
34.     //监听消息
    * _/ f0 B# Y* u- a
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    & f" [/ H0 S7 V3 S6 C
37.     };
    
38. 
    
39. 
    / j/ E. T( b3 {' u6 q4 H
40.     webSocket.onclose = function (event){
    * V. a# U9 S* j7 ?0 c. }
41.         onClose(event);
    - [! Y: E% J; I% U, D6 b+ y0 q$ O
42.     }
    
43. 
    5 ]+ l' E. n! D
44.     //关闭监听websocket
    
45.     function onError(event){
    6 Z: W2 E; g8 @0 q5 P5 E
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    / r' t4 Y5 N1 h& y5 K
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    ( @4 o# Y+ F; A  Y7 e1 i7 S
50.     function onOpen(event){
    - T. \2 U( c4 q% m
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    # B$ M9 i" i7 M& A' U% g1 l
53.     };
    
54.     function onMessage(event){
    1 N$ d5 Y& J$ ~0 l; Y: ~
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    % E, ^! K, Q0 o0 Z0 v
58. 
    ' G3 g- M, q( N" J  \" O
59.     function onClose(event){
    $ n' I: i/ I* k  k
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    6 [2 \, K% B) @% R
61.         console.log("close:"+sockState());
    $ n, O% Y5 N3 L0 h
62.         webSocket.close();
    
63.     }
    
64. 
    " O: _4 O3 K6 [7 d  l4 X
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    ' f6 x8 M& U5 U5 q% A* O' z0 h. y0 y
67.             return status[webSocket.readyState];
    
68.     }
    % M0 }7 K. z  {" x. A  g; n) w% m" [4 n
69. 
    
70. 
    # q% ]. }. ~8 Z6 K( d" E% [8 g) {
71. 
    ( M; E* M* _% Y  M% o! K* p
72. function start(event){
    : Y, ]/ v* w$ d2 D
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    & r* @  u# ~5 W! f8 b$ v
76.         console.log("send:"+sockState());
    5 E0 i7 C2 ]+ z; i$ y
77.         console.log("msg="+msg);
    5 ^. x1 ~$ H* U! L
78.         webSocket.send("msg="+msg);
    0 l" S. }1 [" x7 G+ z
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    / @- ~& I- Y+ Y. o: T2 I2 l/ Y5 Z
80.     };
    + I( L1 }$ Y# H$ }) X
81. 
    5 B: U# w' L4 @; j2 n7 ^+ T
82.     function close(event){
    # U# k. Q2 M1 I3 a7 a
83.         webSocket.close();
    
84.     }
    / Z- X5 L2 v  e9 `" g
85. </script>
    
86. </body>
    
87. </html>

复制代码

4 Q9 X; H) m2 ]' ]6 Q5 e
; a  X; g3 T& F3 a) ^) W* r9 t
" l5 c2 U$ w4 l6 F& B7 M( F% |0 I: T