php实现websocket实时消息推送

admin

php实现websocket实时消息推送

" p4 J; p! g+ B$ R+ \
SocketService.php

1. <?php
   ; g; n, f" i1 U1 M& l/ G9 T6 t
2. /**
   4 Q5 Q& I+ z) F: {! H
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   
7. 
   $ i* ^, ^3 D; o! D0 h8 T, }
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    ) a, L7 r9 n/ u' ^' I! g
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    , {0 b; T+ a  O+ C2 S/ r* W
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    
21.     }
      R. Y; W2 v4 |9 n* y5 ^' O( o7 C+ Y
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    ! @% O! U3 [( B+ j& l5 U/ i8 q
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    # ?  O  Q0 q& T$ q! c8 I. N8 U
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    2 f6 V! n4 J, e& m8 D
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    3 |% s4 E" N0 G# m
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    3 \* Q% I: E. c2 S% w) O: D1 w+ X; b# {
36.     }
    
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    , j* y1 m0 h: p, v
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    ( Q. _: o, b; l
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    $ z4 F( }; Z0 u3 A
50.                     }
    , }' I6 q# }+ V- X% ?6 H5 P
51.                     $line = trim(socket_read($newClient, 1024));
    5 M( Z; U# u/ v# Z1 U2 ?
52.                     $this->handshaking($newClient, $line);
    4 C; C, [8 _6 [" I, N4 _! L
53.                     //获取client ip
    ! ~8 F! R/ `6 t0 R& E* j: p5 C
54.                     socket_getpeername ($newClient, $ip);
    ; D' m3 b! m& n. s+ D) v
55.                     $clients[$ip] = $newClient;
    * T9 v' w/ g# F# E
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    $ p9 K( `2 l8 E2 P
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    / R: \5 v7 m, }3 o
60.                     $msg = $this->message($buffer);
    . y* G" i- s% j* Z/ {' F& @- B
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    + i8 Z" {9 q; I9 N
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    # z. j* b) M4 y! A2 S
67.                 }
    3 U4 ~! }/ K' @
68.             }
    
69.         }
    
70.     }
    # J, @+ y- [0 m% H1 J; ?
71. 
    
72.     /**
    
73.      * 握手处理
    , ^3 }9 h1 s! E( @
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    6 h! c$ j3 G- i% M; V6 O
76.      */
    6 o3 n/ Y4 m* w$ x/ I( G. j  T
77.     public function handshaking($newClient, $line){
    , k& _! \, v/ X+ s
78. 
    
79.         $headers = array();
    - A  J! z" {; U. W5 o* R1 x
80.         $lines = preg_split("/\r\n/", $line);
    & [1 g0 w' g3 G. X9 S4 h
81.         foreach($lines as $line)
    ! C& w. q# H- P, x
82.         {
    / A# M1 I4 Q( j/ o( Z
83.             $line = chop($line);
    / i! w$ }& t& ^3 L
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    4 Z& O, I) m' Y$ w1 N" I5 E
85.             {
    ! s( ?4 h+ d* S+ ~' j# ]& x
86.                 $headers[$matches[1]] = $matches[2];
    6 G* O, S' U" X5 d, {$ q
87.             }
    ; H+ I$ b# M+ c' F/ B$ E6 K0 @
88.         }
    - b1 Z2 N" p4 J: s2 J' `0 L; m9 t: `
89.         $secKey = $headers['Sec-WebSocket-Key'];
    % y% \) o0 N- |) g. U
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    2 y: t, s: F/ C# U
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    9 ?* C& ~; W# a  W' k6 z% c
94.             "WebSocket-Origin: $this->address\r\n" .
    + E) o' ^7 e- k5 p) e
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.     }
    
99. 
    ; h7 N+ S: s/ }8 P/ D# e
100.     /**
     
101.      * 解析接收数据
     % t4 X0 W  K  l# o
102.      * @param $buffer
     
103.      * @return null|string
     5 R7 {7 p2 G1 U& E5 ^
104.      */
     
105.     public function message($buffer){
     2 G+ ?1 u3 A9 m4 z  k' l1 T6 E' h
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     3 ^+ C/ |( z( a. t4 D: @# k
108.         if ($len === 126)  {
     + q% A8 h% E% @4 |% }4 Z- ^$ g0 z
109.             $masks = substr($buffer, 4, 4);
     4 n, f5 r' o8 E! j+ e! E3 }2 X3 g- e4 [
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     0 m; b. ]0 Y0 p4 s9 e
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     7 t6 d! D- y/ |
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     1 \6 R+ ^% |# ?; J  G' ~$ W
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     2 H3 @9 W) b  v. E1 J
120.         }
     5 \/ r5 f! l. v
121.         return $decoded;
     
122.     }
     
123. 
     # v2 F: l# t. H5 ~
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     7 @3 t# g! P% [  {& `2 k
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     ; L% {* O6 x( e$ q
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     " U; x. J. m+ D" b4 f
133.     }
     
134. 
     * _8 E6 J6 I4 [  K9 C! s2 k
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     $ F! A- p4 A+ c: X% {" x. l" j8 \# H
140.         $ns = "";
     - y5 T  G9 r# W# J! Y8 z3 t; O
141.         foreach ($a as $o) {
     . F1 K* I6 P/ F4 ^7 ^  y) K
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     6 I+ W; D2 J) ], u) u& D4 R
143.         }
     # W: Q1 d! W. V7 o  F/ Y: G
144.         return $ns;
       B2 t, Z, ]! g  G& Y( N
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     
154. 
     ; ?1 y3 h6 X. M
155. $sock = new SocketService();
     
156. $sock->run();
     % n4 h/ K# s2 }+ {6 J" F5 ?. d/ w
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   ( @9 ^: v1 s% C) ^  d+ w
3. <head>
   ' l- }% ~4 s7 @) g0 X; h
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>
     [8 H6 M# Q, P% j1 q- x9 d  N* E+ z
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    ' R$ o/ E, |3 t
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    2 ~+ R4 v5 |" [) x7 }* A
19. */
    8 G% _; V+ j0 G
20. 
    / l) C* u" P) m, v- V, g# f
21.     //创建一个webSocket 实例
    3 [- g# f; P, i7 g, E! t4 V- Y
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    ( ~8 M- a6 q1 f' A- U
23. 
    / i5 M+ w. N( x1 V" ~
24. 
    9 ]. m: s8 ?6 e2 y8 A: V; T
25.     webSocket.onerror = function (event){
    9 D: J& u. u# p5 t7 m9 |% U) ?
26.         onError(event);
    5 _3 D8 M  v, }$ F  ]9 g6 J7 V0 w' G
27.     };
    
28. 
    
29.     // 打开websocket
    / J" K# r2 Z$ z4 _  b& Q/ h4 i
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    5 \/ x$ B$ H/ q3 q( w
32.     };
    $ x4 c$ `. T: `% l+ Q8 @4 G' X% {, X
33. 
    
34.     //监听消息
    0 j! M( r8 H! r6 [" p) A
35.     webSocket.onmessage = function (event){
    9 c( L3 s4 m8 C7 ~% d
36.         onMessage(event);
    ! F  {, L$ V) y
37.     };
    
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    ' @; j5 T* y" Z- C7 ~7 q, p: S
43. 
    
44.     //关闭监听websocket
    1 @7 e* Y- }, a" {$ V" _3 T# H' E  W
45.     function onError(event){
    3 |, S1 H2 _* [* s0 l: L1 k
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    / X; v- m* E6 w0 m4 R
47.         console.log("error"+event.data);
    
48.     };
    ; Q+ O+ _7 D0 M1 M* e
49. 
    ! W. ^3 j2 N1 u/ m7 r  c3 e8 F) v
50.     function onOpen(event){
    ! v+ [6 d3 Y4 k, X
51.         console.log("open:"+sockState());
    2 d7 h; @5 ~& @- L6 x
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    $ ?# a; y- z5 k+ c; R8 q
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    1 e; g' A2 L& n' D& v; f
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    : c+ H, J* P- W# f) q9 q! g( `0 R
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    1 r7 ]! H6 O  Q
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    ) U" i  n8 Z4 M: E& O* @
67.             return status[webSocket.readyState];
      U% F4 e: l) A. H2 U9 r
68.     }
    
69. 
    3 e* N/ `% a7 {/ U1 Q. o  ~
70. 
    
71. 
    
72. function start(event){
    $ W! C3 L* O( O' d% `( c& |) `
73.         console.log(webSocket);
    . S1 X4 V) ]+ _0 M6 A' I$ d
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    5 x% i$ I4 O& f1 D  j/ v
76.         console.log("send:"+sockState());
    5 s  O0 X8 @6 ]
77.         console.log("msg="+msg);
    . @) X2 b5 ]6 L6 s
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    ; C6 I( N/ u8 I0 z
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    
85. </script>
    ' G# p' A. }" s7 a1 O& t
86. </body>
    - P8 J) Z: `* @4 p( b# A
87. </html>

复制代码

0 A+ w! V9 v( O5 j