php实现websocket实时消息推送

admin

php实现websocket实时消息推送


, @+ z+ J0 t- W. t$ J7 j  YSocketService.php
& ]/ }& K9 j% Y0 z$ f

1. <?php
   
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   + ]5 V$ r& A# d0 w. K3 y" }
5. * Time: 14:33
   % t7 I$ v# l3 V. |& T
6. */
     Q* d9 L: a# j3 ?! C- T
7. 
   ) j" a: V0 B$ Z0 ]2 O
8. class SocketService
   2 F; t  W& N- B+ B5 G
9. {
   8 Z( Z, |0 g$ ^1 v: s
10.     private $address  = '0.0.0.0';
    . |. [  m& ~; g& Y7 C: c  M
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    , l. z9 m- `0 n0 n& t- }9 ~3 Q
14.     {
    8 D+ d2 F8 e$ \* n
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    1 A! S; w: u1 ]- O& g0 H
17.             }
    . L/ ^8 {7 n6 y' d8 M2 k) r: E; ]
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    0 j, _# Z" R% ^! w* P
21.     }
    
22. 
    % b! T4 h7 O7 [7 i7 a- l  V7 R
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    : ~5 a1 D3 J( V
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    $ I2 O# N! B) \' i' e
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    ; H' m4 B# p! [$ W# q
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    1 S. G' a( k! ?, g, x
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    
38.     public function run(){
    
39.         $this->service();
    6 Y* c' u0 q( J: N
40.         $clients[] = $this->_sockets;
    - p" w+ L+ n; S
41.         while (true){
    5 Z6 K8 ^+ |; A, q3 u/ t2 D
42.             $changes = $clients;
    
43.             $write = NULL;
    ( e% h+ b9 ~( W7 u. w
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    / x' b( K9 u: S
46.             foreach ($changes as $key => $_sock){
    $ [: b- A2 f  @2 T4 B- J/ i
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    / a+ ?, e$ ~: h3 v$ Z5 J) e# {+ t
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    ! u; h* B: b" w/ I- B4 ]# N
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    ) m" W1 s8 W9 D4 ~* @9 w) i6 Y% P
55.                     $clients[$ip] = $newClient;
    ( x9 W$ u2 K' [) }- A- ]5 D, `
56.                     echo  "Client ip:{$ip}   \n";
    2 B9 ?9 w+ m" E: I3 ^( y4 r
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    ! D# E, ?' f7 B7 |/ M( J+ E- R" U
60.                     $msg = $this->message($buffer);
    9 \2 L: ~1 f+ ~2 y  S2 e( e
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    9 M$ p! s7 p# C/ J6 R
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    1 ?* T8 }( q6 x  U- _
68.             }
    ! a" T, D/ u8 f0 F
69.         }
    5 F7 n: s9 c9 T( v, h+ A' h$ A
70.     }
    
71. 
    $ I8 K$ P; [" S' A  Y9 {
72.     /**
    
73.      * 握手处理
    8 m% f$ o" f' q7 o# s' W
74.      * @param $newClient socket
    , J$ n% D; R5 e: {6 C5 g; S; X* A
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    ) n, U9 \* h3 N: C
78. 
    + I$ H# k1 `( ~! Z/ R3 d3 C/ Y
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    8 n9 C$ k' A/ N3 ^6 I! [% u: K9 \/ o
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    - P; }0 a7 D! A% n5 \$ k
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    . z8 [8 v1 n0 g, P0 k4 M% @) n
85.             {
    ! T+ n$ h6 W9 S
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    1 R1 d9 h6 \6 P1 Y0 i7 y; R
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
      z" _( V2 ~8 p9 A
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    , R; N4 n0 J. U7 j" I
93.             "Connection: Upgrade\r\n" .
    ' ~% u$ I& |5 s6 M+ B$ u
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));
    4 W% w% T7 Y9 Y. O5 F
98.     }
    
99. 
    " v; e/ S/ k9 J
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     : p5 A* c- {7 F- d: D0 {- e
103.      * @return null|string
     
104.      */
     * u( B. i  J0 z) v$ E8 T# d( q
105.     public function message($buffer){
     & }3 v7 G6 Z$ w% S# A2 L  R
106.         $len = $masks = $data = $decoded = null;
     " Y4 p, _# p0 q
107.         $len = ord($buffer[1]) & 127;
     ; q9 L; K: z' t- V" z. `7 k3 ^
108.         if ($len === 126)  {
     3 B, C7 h- a: d9 k* t, l2 r
109.             $masks = substr($buffer, 4, 4);
     ! a! _5 G1 |, K, X9 J" C
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     * n) L) X; C8 h% K( f' T1 l8 P' f
112.             $masks = substr($buffer, 10, 4);
     2 {% l. x7 B( c* y$ L
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     7 e. o1 {5 i  U0 H* j( F
117.         }
     ( v5 b/ ]1 A7 K/ ^5 c' G
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     ( q5 m% I, q* z0 g. e
121.         return $decoded;
     : C2 [5 C: d/ e( e9 ]$ G8 R" C
122.     }
     
123. 
     % w7 s7 N. L. p) ]2 T) E
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     % _" P6 U1 q. W
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     8 M8 @: N! L! X/ P' b+ `" @0 S
129.      */
     
130.     public function send($newClinet, $msg){
     , h* V$ K, G4 F2 X
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     ' U! w9 d6 D8 H) r5 Z- k0 i3 B& o
134. 
     
135.     public function frame($s) {
     . P  d; ^; G  K/ j7 e/ K; D
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     9 x' w# N0 p9 h! p2 `! t+ B
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     4 V# }; g& p( h4 N: P2 Y$ l
139.         }
     * m, o5 r% S5 M) S1 g: o% |
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     
145.     }
     
146. 
     8 q' ~( b8 \# ?# U/ t" ?7 B  s
147.     /**
     9 J$ [$ V" x" n
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     7 q" ]) k  \: R1 O
151.         return socket_close($this->_sockets);
     + w' ?/ v2 d3 {5 ]6 d+ q
152.     }
     
153. }
     0 U2 j; L+ C* e7 j' c$ i: U
154. 
     ! i+ K9 Z3 _7 B1 n  n" j
155. $sock = new SocketService();
     
156. $sock->run();
     4 H2 U+ c1 E7 X7 u% }0 u
157. 
     

复制代码

web.html
, K, L" p8 g; A* O' v

1. <!doctype html>
   + D. k$ S" V0 T' s0 C7 @0 y. u& q
2. <html lang="en">
   5 x8 j$ A- D3 q% T$ W4 f
3. <head>
   
4.   <meta charset="UTF-8">
   : H! d, X5 e3 r) u! r! a
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   1 J5 f* k1 r7 W' i1 S
7. </head>
   
8. <body>
   ) \5 t! @" Y: `$ M7 U
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    , z% f' C* \/ L; `
12. <div id="msg"></div>
    
13. <script>
    2 [; e; p" r" r- C- @9 h
14. /**
      U, A5 l/ {& V! q  Q$ g5 W2 X
15. 0：未连接
    , o! V- k# v* G2 o0 `! \+ k
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    
19. */
    1 Q2 L* F9 ^- n
20. 
    # x7 N) A: Q$ }& d# s
21.     //创建一个webSocket 实例
    ; p  K4 T5 }% R) w8 W
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    ; U% B3 d4 A3 e
24. 
    & P4 E+ x  X$ T$ Y" o/ Y& z
25.     webSocket.onerror = function (event){
    4 {3 l$ v9 c7 `1 @+ F# P3 X: ^
26.         onError(event);
      Z6 D# H5 S& x: n' U; [6 P
27.     };
    
28. 
    % R' [% e8 Q) ^# i0 J: e8 F/ q+ }
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    
33. 
    
34.     //监听消息
    # C5 V$ @. x  G  l
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
      C+ T# J6 G" u+ K# W
37.     };
    7 c$ E  x" x& p4 j$ i( I2 d
38. 
    
39. 
    ' L- V4 B5 ?- G5 b: m0 N
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    7 {0 G; L7 P( _% T4 h
42.     }
    / V: g9 Y) |5 ~" C
43. 
    , x9 L) w4 ]% |5 |
44.     //关闭监听websocket
    2 P& V' f* v7 H
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    # e' F$ u5 C- X' [5 [; }, b
47.         console.log("error"+event.data);
    
48.     };
    ( u8 |; B! G$ E1 J' ^  T' i* Z% \
49. 
    + z. D1 j; S0 S! X# \% J
50.     function onOpen(event){
    + b4 J$ X' b* v& H
51.         console.log("open:"+sockState());
      e: p2 ?$ [2 C, V2 a
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    ; z3 {. t6 f3 H' q  R- l
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    * z7 b- w. T+ K% r1 Y
58. 
    
59.     function onClose(event){
    6 t  u: s5 g* w# @. Z
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    5 \& x, U% e( Y) N1 H: S
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    
65.     function sockState(){
    . p" U" o) B  a! [
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    ! g+ P! E: N  V9 G8 S4 Z# h7 l2 w
68.     }
    0 ^# l2 i0 r0 Y* I
69. 
    % g/ R+ p; N' [5 _( y) K; t0 E* Z" G
70. 
    " Q; \* p) `8 J
71. 
    
72. function start(event){
    3 B# D8 ~- E. T7 K2 s6 ?3 ?, A" S
73.         console.log(webSocket);
    ! h9 v6 d$ ?: i1 }) F% L$ {
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    . n2 i& X0 m/ z* x
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    ! N( S  l' M# z+ @$ P! q
83.         webSocket.close();
    ! e3 x. R7 n7 g1 x: A
84.     }
    
85. </script>
    
86. </body>
    
87. </html>

复制代码

5 Y" `$ Y2 e) S! c, I3 z

9 {# u, f1 D. d  P