php实现websocket实时消息推送

admin

php实现websocket实时消息推送
3 L2 A4 Z% D% A6 c
$ D: S4 _" f) X. k3 k& x' p% ~8 h
0 Q1 i* F" a3 s- t" S) d8 }SocketService.php

1. <?php
   0 Q* g3 C" N  _3 k: K
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   2 c# j" @/ D- O! Q, C
5. * Time: 14:33
   4 X9 \, K$ Q5 J$ J8 h: W/ R4 B) v5 h
6. */
   
7. 
   0 i1 E& U4 t% E5 y3 q1 N
8. class SocketService
   1 H; ]' b" y/ Z5 ~3 w$ d5 I
9. {
   . ~3 A  }) Y/ K7 V, Z
10.     private $address  = '0.0.0.0';
    5 @9 P! |3 G' \+ t
11.     private $port = 8083;
    
12.     private $_sockets;
      G0 B+ h/ q4 S/ l1 q8 W0 c
13.     public function __construct($address = '', $port='')
    , Y7 Z* h5 ]8 u. y# M; u7 ~+ T
14.     {
    : B, U  _2 `1 A
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    # X' k8 c) B/ }
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    & z& \% F2 _; c
21.     }
    $ K' o' \0 `( ^( j
22. 
    9 |( P$ J9 l8 Y4 d% C2 \  P
23.     public function service(){
    
24.         //获取tcp协议号码。
    + D7 ]. E- P* o& y% Q
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    ; W- y0 p' S0 q! f
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    0 ?% T$ s  U& f4 s# M& _
28.         if($sock < 0)
    1 w; ^( Z: [2 \" o6 B/ N
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    & ^' R6 P4 v" t8 o+ |
31.         }
    $ U+ @& @+ y- l
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    6 g; w7 A% {8 h, E
36.     }
    3 i! K; l( j7 ]9 O1 Q
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    9 d9 R. h9 s. G! y+ w" e
41.         while (true){
    ) U/ M8 D* A. Z6 F7 V1 X$ c" k5 v
42.             $changes = $clients;
    
43.             $write = NULL;
    2 R9 j6 t( ]. Y0 G
44.             $except = NULL;
    ( k" j/ M* T. Q! Q" }- N6 |( `5 [
45.             socket_select($changes,  $write,  $except, NULL);
    7 X$ n. e; R; u- `
46.             foreach ($changes as $key => $_sock){
    4 q) m5 L! Z5 L  |4 h& H1 u
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    1 [2 P/ }5 J# m* N
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
      }9 L8 t) M% J8 F- G
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    ; y2 k, o, `" B+ o
57.                     echo "Client msg:{$line} \n";
    1 h% [- t3 ^+ H, Y+ B2 l- x8 x
58.                 } else {
      x* x  z9 c$ \1 I
59.                     socket_recv($_sock, $buffer,  2048, 0);
    ) S7 I) n" p9 m; F- i1 H) i7 v
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    8 W. U" W' O/ X2 N( ]* _9 d
62.                     echo "{$key} clinet msg:",$msg,"\n";
    $ K: N; b0 r- G" \  {6 ~
63.                     fwrite(STDOUT, 'Please input a argument:');
    ) ?! }' G; y  Q2 D
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    2 O2 r$ z4 j. Z
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    ( ?! y$ r* }0 B; D+ N
69.         }
    
70.     }
    
71. 
    
72.     /**
    
73.      * 握手处理
    # {0 q' T4 P+ t/ W# ^
74.      * @param $newClient socket
    ) D. N. L0 P7 m
75.      * @return int  接收到的信息
    % b  q3 Y8 K! t  H: D+ P
76.      */
    6 Q7 ^4 G* q7 A1 \) ]  ]. f9 Q
77.     public function handshaking($newClient, $line){
    8 t$ @) J1 f5 S. W7 A& I
78. 
    # z' @  r! r# E. R
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    # }4 t( e2 ?5 z; [/ L" h, u
83.             $line = chop($line);
    ) J0 j/ {& Q. Z  U- R) Z
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    $ Z6 `2 U  J3 G
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    * _4 Q2 }/ `  k- H0 w
87.             }
    ( F6 Q" V( T/ _8 J2 T9 U* J
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    4 L6 {. L' ?* W' W- a8 O
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" .
    
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    . x" S4 O& p. S
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    8 o- R  [4 `! c6 N1 i7 p6 C
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    , ?$ H+ B: \$ ^6 r1 X, g
99. 
    
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     9 o4 I# R  I- x0 L& F1 g* H  n
103.      * @return null|string
     6 L6 m; s* p7 z; i
104.      */
     ( w7 T0 [5 Q; s& [
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     - n% G: X! F- y+ B
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     6 k0 n. e" D  Q2 r* T
110.             $data = substr($buffer, 8);
       B8 J0 ~' K: ^+ L5 `
111.         } else if ($len === 127)  {
     + I$ ~; D0 K: \' c6 A) u9 ~% D
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     , p7 W7 s6 I4 j3 R, U; Y0 _
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     " W& h0 h  e1 c, s7 \( y
118.         for ($index = 0; $index < strlen($data); $index++) {
     3 L  o6 I) X  l% r
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     , `7 ~" l) Z* J! m
120.         }
     . [. D3 R. S2 w0 c7 H3 F, t6 W/ }; q
121.         return $decoded;
     
122.     }
     
123. 
     # h3 k$ \# d2 L0 S! ]9 _6 r
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     1 b' B& _9 M8 N9 q: R6 [
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     2 X8 l* b& J# [; r
133.     }
     
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     % O; U( V/ ~  ]
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     ' t4 p( j6 C, t$ C1 o- n, g
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     ' j/ F4 W8 r0 \" R2 G& ?  S( \
145.     }
     
146. 
     + J3 i. U& T( T) H
147.     /**
     , ]. U# I: \0 T$ A* k( Z0 G
148.      * 关闭socket
     5 V6 D/ w' k; _+ G5 M! g
149.      */
     
150.     public function close(){
     * m: u+ @0 A- C3 i7 A, D
151.         return socket_close($this->_sockets);
     
152.     }
     & e8 K; G) T/ B' w
153. }
     
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     # P+ j& t4 y' r3 ]/ X, |

复制代码

web.html
7 ?/ K+ C/ b: j# Z) D

1. <!doctype html>
   
2. <html lang="en">
   0 R( P: R2 s& _" A: b1 y" U
3. <head>
   
4.   <meta charset="UTF-8">
   ' ~6 _: ]. t2 D5 p
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   : x* I, R( C! ~. c( G% ?; h9 l
9. <input id="text" value="">
   8 ^$ n6 a" I/ h: h* t
10. <input type="submit" value="send" onclick="start()">
    9 H) @# Q3 S% J& x
11. <input type="submit" value="close" onclick="close()">
    4 b6 J. }( C' R6 E# I
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
      K/ d0 P, K2 Z& L
16. 1：连接成功，可通讯
    9 H& k$ _. ~3 ~- ~$ X
17. 2：正在关闭
    % g6 n) u$ a! c% d0 C$ V
18. 3：连接已关闭或无法打开
    
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    % z4 P; q: @6 J$ U
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    % t7 z) l6 M) Y6 z
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    - D! C" ]" O9 b; L
27.     };
    6 b* q) y& X8 |0 T4 |
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    . q) _1 `# d/ \6 x( }- @# C
31.         onOpen(event);
    
32.     };
    ' @% U& l. h2 H) W
33. 
    ) l1 K" q  g: z2 P6 _
34.     //监听消息
    6 T) L, G# i. K: y( v7 k
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    : ?& S1 q$ [% c  G8 @
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    3 d) O  e  `) F
41.         onClose(event);
    % b9 h& o3 B% L* B
42.     }
    9 U, }$ b% m7 g% p# T
43. 
    ' V" v) C' m$ T' y
44.     //关闭监听websocket
    
45.     function onError(event){
    ) H# I5 Z1 U2 c* L" p( ]  r" Q# n
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    " K' Y3 d- v: x4 ?
47.         console.log("error"+event.data);
    
48.     };
    4 `+ n9 W6 G( F. K( w
49. 
    : Y( X' l- w, ^/ N0 f
50.     function onOpen(event){
    5 o  J% M2 {. z8 q
51.         console.log("open:"+sockState());
    , ^1 S/ {/ p! h$ s
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    * a" E' {8 C' W6 r
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    + e8 E1 A1 j  Z8 |1 ?
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ! V4 i4 w/ u( X# u1 u9 J2 J5 R
61.         console.log("close:"+sockState());
    ( P6 v. U7 A- k  D: p
62.         webSocket.close();
    
63.     }
    $ V/ L, C* k0 X6 p+ d& D" p
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    , e6 x4 i3 D$ c; X
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    : B$ v8 B' h, _
70. 
    
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
      h0 {. n+ k2 K) k
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    ; W; T9 o: Z: f# [/ W: q
83.         webSocket.close();
    
84.     }
    6 h" j% f8 t" m
85. </script>
    
86. </body>
    / s! G4 P, b2 X& Q! `. h
87. </html>

复制代码

" F8 E) k0 B! P- W, z! ~
+ Y/ a" q" J& o1 B/ \4 h, W