php实现websocket实时消息推送

admin

php实现websocket实时消息推送

* H& y8 B$ C/ y- L! b% ]  a; Y
SocketService.php

1. <?php
   ( T2 w4 b2 n. ^. j
2. /**
   ' r3 T3 f7 i; s* M" j
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   
7. 
   
8. class SocketService
   , Y1 ]0 B$ O8 X6 K3 j
9. {
   ) i; G  l9 b" L" i
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    / T' x. F9 s& Y5 a4 l% V
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    , @( l. I9 a  Q) w  G1 ]+ p% D
19.                 $this->port = $port;
    # _3 ^6 @9 m" H1 h
20.             }
    2 m/ E. r3 X3 b; P" t6 H
21.     }
    
22. 
    + u9 {' h3 I& U' y
23.     public function service(){
    
24.         //获取tcp协议号码。
    7 S6 t% z9 a" m+ U5 R2 s% Z* I/ m& Q
25.         $tcp = getprotobyname("tcp");
    ; V" {9 }& {9 v, a  n+ z* y
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    : ?2 w# W8 f6 v
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    9 W) e6 X" P. U! v2 W0 T) z, S' M
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    . ~6 D- g# t2 Z- f7 Y
31.         }
    + [9 E% J9 x( t: O+ I/ ?2 J- R! W
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    ' w/ g1 T1 y* {- V
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    2 J4 R4 U5 `! }% n+ w: p8 |
36.     }
    
37. 
    * N# S4 v# m: P- l: B' F$ S
38.     public function run(){
    7 b) I) H5 t+ x  ]3 Z8 N
39.         $this->service();
    * y5 J( S- H- X& \7 ^" i& m$ N+ h& U
40.         $clients[] = $this->_sockets;
    ! h; z0 y2 V, z1 p$ T$ {
41.         while (true){
    1 v4 ]' \6 @1 l, S6 g% A) A
42.             $changes = $clients;
      _6 h- s; p$ b2 p9 G' a# V
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    ! i8 L- ?& Q- _, f* ^
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    # [  y" W/ d3 F
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    ( C  Q% H& g) A- i1 J" E# _
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    - h" a* U" B/ ~$ [
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    5 X9 F9 v  w: u/ L  |' L& F, T
55.                     $clients[$ip] = $newClient;
    : f8 _) H/ Q; N3 r6 `( j
56.                     echo  "Client ip:{$ip}   \n";
    ' i+ V9 ?+ s" M. R) f; O5 |1 V
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    ; b! a3 f5 ]: l5 B$ |% S' u
59.                     socket_recv($_sock, $buffer,  2048, 0);
    % {" k0 d8 g* n5 w
60.                     $msg = $this->message($buffer);
    5 F( }, l/ ^( C  @4 Y- `: ^6 j7 m
61.                     //在这里业务代码
    5 g) ]2 e" n" L+ H3 N: \  H
62.                     echo "{$key} clinet msg:",$msg,"\n";
    # G4 v, H. Y+ `0 A1 u. T
63.                     fwrite(STDOUT, 'Please input a argument:');
    6 m* l! g+ z1 x/ U0 C/ l5 f
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    
69.         }
    
70.     }
    : l2 u; J  k0 M! }, Y
71. 
    ( e5 ~8 h% g: T
72.     /**
      T* u: R3 Y4 t
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
      d1 I# F5 n& t4 K& m0 O" S
76.      */
    8 `7 w+ k, v  Y
77.     public function handshaking($newClient, $line){
    ! K/ _" ?! ~, c9 [
78. 
    - |2 T3 a- u6 W% t0 Q: [& O  \
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    0 {. }4 l7 t- D; Q2 I
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    / }) w1 c5 z5 A! e  H, E
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    ! V& B% s4 k* m, S
88.         }
    8 [: H5 k5 {( F, |
89.         $secKey = $headers['Sec-WebSocket-Key'];
    7 c* T+ r1 i; d# S$ g1 k/ r7 }7 ]
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" .
    ; N& T# t3 S  F8 n
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    6 x) \) V& P  T, M1 Q) p5 P
94.             "WebSocket-Origin: $this->address\r\n" .
    : e! d% L* F3 y" s+ J: |
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));
    
98.     }
    4 m2 ?3 w3 W& C# N0 v' R
99. 
    " S: y7 f# k4 T  Z, H0 u
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     ( k% k; ^* l) a, ?2 l% i5 H& C+ a
103.      * @return null|string
     3 H& ^. b% ^8 I: @
104.      */
     
105.     public function message($buffer){
     " X; x9 }- X- |/ d& [6 W0 K
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     ! Z3 B9 @! E  }8 Y
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     4 J; c5 s# Q( y! H# w; z. I
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     - f* T7 {2 ]# W5 O6 d7 e
114.         } else  {
     / w9 G& r7 @/ D% W
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     8 T6 K. i0 K/ T8 l4 V! d
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     2 n9 v. M6 l4 {  B) k! R8 C; d
121.         return $decoded;
     8 h% ?, o& |! P. A. u# }
122.     }
     
123. 
     9 {5 S* L4 n! x* D/ w: M
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     ; I+ X/ A8 D- H" Q& Y+ P
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     : W) T; K- f  Y
129.      */
     6 j3 j: k9 A. E+ [9 c
130.     public function send($newClinet, $msg){
       p2 g5 y6 C" s
131.         $msg = $this->frame($msg);
     - {3 e8 l9 v6 R: s# ~
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     1 K. u; }# @. F: d+ _
135.     public function frame($s) {
     & E, [( Q* s2 n2 y5 h3 A
136.         $a = str_split($s, 125);
     4 r( z5 E1 N' E7 w$ z3 o0 `
137.         if (count($a) == 1) {
     * ^  x! \6 _& K( _
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     # D3 n; g% }" x6 F+ o
140.         $ns = "";
     
141.         foreach ($a as $o) {
     : Y" E/ e/ I5 a0 \/ r* N
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     , ^( B, ~- c; Q+ w* j( j# j+ [
145.     }
     / E- z1 S% G* u, e, ?! J* ~3 @
146. 
     
147.     /**
     1 Q4 K" W; t7 r# a2 Q
148.      * 关闭socket
     ) Y( e6 `% k0 k7 d
149.      */
       J* v, g1 b7 }
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     ) G2 |  {- I' F" A
153. }
     ; }9 Q$ \! o% f$ e* N# N; \
154. 
     " ]2 J" p% \2 w7 i+ O
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html
* W$ L/ V0 G. G

1. <!doctype html>
   
2. <html lang="en">
   ( S! o$ T' B, I1 {, |6 b( }" x
3. <head>
   5 H$ P- ~3 E2 k* a( o
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>
   
7. </head>
     X) m5 \1 j" j: R3 e! q5 R, @
8. <body>
   - ]1 G! D& h' N4 ^6 @' A
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>
    ( ~1 T9 e7 y1 k& H6 B, s& c
13. <script>
    
14. /**
    # g7 L2 c" N9 J  r
15. 0：未连接
    + b: }3 E# k. j" K5 G: q
16. 1：连接成功，可通讯
    9 h# }: N) b6 g1 B* e0 `: p7 w: ^
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    , S; j) L6 U& j8 c0 ?( d5 |5 {8 c
19. */
    
20. 
    # J) u' ]$ h) l+ I
21.     //创建一个webSocket 实例
    - S8 L# @* [+ e; D8 h
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
      @! f6 Z& j  N! G( d  Z
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    4 P# m+ B+ |% t% i( z& P
26.         onError(event);
    
27.     };
    % Y$ I* Q: R/ J7 m6 [; i% N) r, z
28. 
    9 `% q; l5 x0 S: {4 O& L8 ^3 Y, ?
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    
33. 
    
34.     //监听消息
    " U) f8 i5 O( _& Y9 R
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    8 l5 j  k9 `  @  s1 p& C
39. 
    1 p) B$ o/ B, I8 ?6 C$ h' u
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    ) [8 J; V- M! o7 x6 c( c# R( p
42.     }
    ; m# O& g8 B8 t# V& B
43. 
    5 W4 x: K- d3 b! P
44.     //关闭监听websocket
    
45.     function onError(event){
    7 z& j& `  S$ ?$ J; |, C  M2 o
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    3 a, Z" y. R, X+ K) }2 q
47.         console.log("error"+event.data);
    
48.     };
    ( S. t9 u  Q4 Q+ s% l! m, M& V
49. 
    , I# w6 m; s" T2 g* J3 m
50.     function onOpen(event){
    ' S/ |! W, q9 n& @6 T$ i( |9 c
51.         console.log("open:"+sockState());
    $ O& d6 _5 T& u2 p* Y5 k1 P
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    7 t/ I3 k* k1 |" [8 ]9 U
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    - P, z2 u9 H% B+ i9 |. A. d
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    
65.     function sockState(){
    7 z+ v$ t! f5 o% ?+ Z
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    6 h; L# G, N7 G: \& Y" @
68.     }
    
69. 
    
70. 
    6 O! h* r/ o6 A/ N' g
71. 
    9 a( }  Z3 }( Q4 c
72. function start(event){
    
73.         console.log(webSocket);
    : D; d) L" [. [
74.         var msg = document.getElementById('text').value;
    + Z- r5 i9 I9 T" g; L
75.         document.getElementById('text').value = '';
    ; ]6 p" S; `8 I3 ?3 H
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    1 J$ k; U3 o4 _3 N% H! C) I
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    " D- h' g" Z- g) u
81. 
    
82.     function close(event){
    . q- e( p1 I% V
83.         webSocket.close();
    
84.     }
    + k+ b7 S& Q0 l" A. m% J  P6 U8 P
85. </script>
      P! X) ^' m% G% J( q( ]. M6 s
86. </body>
    ' R3 \6 H" h; z& p, A
87. </html>

复制代码