php实现websocket实时消息推送

admin

php实现websocket实时消息推送
0 O3 t% \( R: t1 @
, O$ p5 `% x5 J/ _$ d
SocketService.php

1. <?php
   
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   6 O* Q8 q. i  Z. \* \
6. */
   
7. 
   3 X' c$ ^  v( y: }( u( Q
8. class SocketService
   
9. {
   6 a; L6 D4 d" a
10.     private $address  = '0.0.0.0';
    . ^# _8 `8 a6 d2 R# M& @( f
11.     private $port = 8083;
    " {0 T9 M0 y7 G5 b- O& Q
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    7 m! m5 ^5 i7 A, L5 ~
14.     {
    4 M* s( D' m0 E. g, N
15.             if(!empty($address)){
    " L6 e2 Y7 y+ @
16.                 $this->address = $address;
    - t$ x1 |8 Z: o- ^/ Z
17.             }
    6 q; H0 ~" f8 q3 l3 V
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
      U, j1 {$ q' Z, C' \% y  C
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    # E$ N% b* C$ |/ Z/ O
25.         $tcp = getprotobyname("tcp");
    , K8 d6 g5 [. W6 A2 q# \" {
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    3 g3 f1 a8 N* x# g
29.         {
    $ \" D, x# `9 q& S/ ~8 {
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    + y4 K& m" h9 g+ D4 L# I. v& w
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    7 U) N1 l( L8 y
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    ' s" e3 ~% H$ o+ I, ]2 W
38.     public function run(){
    4 L/ J9 P1 ?2 R0 r* k
39.         $this->service();
      a9 v" V7 H/ H: M
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    ; |) @! @5 }. g* M; N( l
42.             $changes = $clients;
    + ~; a0 K4 b2 K  P7 r. `
43.             $write = NULL;
    6 g9 z! j3 j8 b( ~4 n/ M
44.             $except = NULL;
    5 `0 o0 V3 i# u5 t  [9 T4 m
45.             socket_select($changes,  $write,  $except, NULL);
    1 d& l% D+ y- @2 h$ }! R' W
46.             foreach ($changes as $key => $_sock){
    + x3 B  \( L& p7 a3 f
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    ! L9 U1 {# {; E1 T
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    % k- n! }% l4 q" q7 l2 t
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    8 ~" Q; y. o( E2 ~6 I( N1 p- W* S
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    8 L' Z  C9 T& q" U& u
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    8 v4 R- [9 E5 M5 ^
61.                     //在这里业务代码
    & c/ I# H7 r+ ?9 o/ }
62.                     echo "{$key} clinet msg:",$msg,"\n";
    : g4 M* X/ L6 I5 }6 s
63.                     fwrite(STDOUT, 'Please input a argument:');
    * x" n! X- T- S/ s  s
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    2 R" v" I2 @1 q3 q6 ?7 W
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    # m! o0 F' u: t: v2 t7 J. E
68.             }
    
69.         }
    3 y& G1 e( u4 f4 D8 D' X$ D4 n
70.     }
    
71. 
    
72.     /**
    8 B3 Q% e1 @  \& l
73.      * 握手处理
    : v  H" Z  ?! J" w) T& ~% ?
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    + k% ]: I% H9 [
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    9 G# q" \0 Z- e* K/ o0 L: A
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    " O( n* |; p5 R6 a# X4 H
83.             $line = chop($line);
    1 ?9 }" E1 H. M& E
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    ) `5 I6 c6 ~7 l) ^3 \5 H# z
86.                 $headers[$matches[1]] = $matches[2];
    4 u& _# r1 u( t" g1 X
87.             }
    
88.         }
    & g4 x! b$ g3 h: {8 O& \7 T
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" .
    
92.             "Upgrade: websocket\r\n" .
    ' k" f. x1 k% D) u
93.             "Connection: Upgrade\r\n" .
    
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));
    8 H5 i3 z  J0 Z, U( Z% \
98.     }
    
99. 
    
100.     /**
     5 k: w4 R2 V# o6 y2 Y9 Y
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     & \& a( h/ C1 @0 P$ Y
104.      */
     : E8 ?: r) S( w' [' v9 f
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     3 n0 M3 I$ T8 `
107.         $len = ord($buffer[1]) & 127;
     " ^# Z2 I% L% Z& Q! P; S7 R/ v/ v) H$ N
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     , w- }& ^! Z; r; C# t/ S8 W8 y
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     : A! E# H0 B  \. Q  U
113.             $data = substr($buffer, 14);
     $ Y1 Z: e) {& D7 q% E" m" _+ x/ C
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     $ n5 S# N6 v- }4 r7 Z/ G
116.             $data = substr($buffer, 6);
     6 p0 B8 b* O/ S+ B  S
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     3 q0 c- N/ _) t8 V0 V
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     ) O/ j) b" `- t$ r
120.         }
     
121.         return $decoded;
     ' V+ ^' g' e0 v* q! p  L
122.     }
     
123. 
     
124.     /**
     6 K) _. s4 s( P1 `1 Y' r5 T
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     6 B1 h; y" m2 T  w* m2 r$ ~. [  }8 v
128.      * @return int|string
     ' j) I0 P/ d& o! C
129.      */
     ; \& j2 t# N0 w( G# i
130.     public function send($newClinet, $msg){
     ) S, Z5 k0 t/ y1 D5 v4 I* `
131.         $msg = $this->frame($msg);
     ! M$ |, x' F( C( c5 i
132.         socket_write($newClinet, $msg, strlen($msg));
     & z, u' ?- H- E9 z/ P4 I0 Y3 n
133.     }
     1 r( {. @- j( [5 p2 s/ B) d' m
134. 
     7 n1 F! ~" [, F6 t. w& n0 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];
     % O0 j4 f7 d0 \3 n
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     1 g" y8 X  }; f; g
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     ( y" U! H* e1 e* [
143.         }
     8 A  t6 V2 D6 d: x9 f* I) j
144.         return $ns;
     ; B) W# P/ l/ n$ `% c4 x
145.     }
     ; y8 ]5 y) S, H9 H8 A2 a
146. 
     " [0 r/ r# |8 c: J. b& ?- s8 ]* \
147.     /**
     
148.      * 关闭socket
     9 G/ h- z* j3 l
149.      */
     
150.     public function close(){
     2 r8 z4 q* _* J
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     $ {  E; e1 D2 b. t' c2 j
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html
* P. m5 l' ?# t

1. <!doctype html>
   6 a1 B, q9 d  y$ I
2. <html lang="en">
   
3. <head>
   
4.   <meta charset="UTF-8">
   . D5 \6 g2 z; U2 I; H& G
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   . a! m8 ?5 o1 J! e, S
6.   <title>websocket</title>
   1 |: C+ G- E6 R* j" L3 f1 z
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   " O2 J) H9 Y7 X/ U
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    6 c- O0 `: G" J! L
12. <div id="msg"></div>
    2 A: T3 z7 @- h* t! l
13. <script>
    $ Q: q8 l: y" @
14. /**
    $ R$ o' B# ]  v( _% F- l. P
15. 0：未连接
    
16. 1：连接成功，可通讯
    $ r) ~) r3 t1 W! ]: |$ q% `
17. 2：正在关闭
    2 v5 Q& {% |  o- P5 w
18. 3：连接已关闭或无法打开
    . b( o) n- w) P
19. */
    3 q, k5 x- j; i; g4 T% p2 b8 }" m( Z
20. 
    
21.     //创建一个webSocket 实例
    - T4 l+ g4 |. P. p* L8 k# ?2 D
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    / D5 V3 r# C  Z+ D7 U/ b7 A; j
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    3 q: M" a! Y' @( C& t+ u1 V
27.     };
    
28. 
    8 g) E$ [- Z1 W, g' G/ j5 p0 j
29.     // 打开websocket
    1 L/ o7 _4 n! q" k( |( l5 T
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    0 K2 X) H9 L- S2 X7 m" l
33. 
    
34.     //监听消息
    9 ]. s' [- {6 K) j
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    ' ~3 H6 b" l# t& Z. }( L+ C
39. 
    2 C1 u7 J. ?9 {1 a
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    3 l4 B) _; Y- @) s. Z
42.     }
    9 L5 v( G& G4 K9 }
43. 
    ' a3 `/ ]& |' d9 G) a& E: n0 g1 h
44.     //关闭监听websocket
    
45.     function onError(event){
    : A7 x- P" ^" u, B4 l/ u  D8 z
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    & P* F9 L/ F' Q9 q- U, ]
47.         console.log("error"+event.data);
    
48.     };
    6 n( A: b; P- r0 C
49. 
    8 x  D  J6 B& `* q. b+ {' J
50.     function onOpen(event){
    ; O; P- L; K1 m8 t! ?
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    " E+ L; W7 D$ Z& i+ `
55.         console.log("onMessage");
    2 I, S: Y" i$ B/ B/ \/ q7 Y3 U
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    % q& D6 B- |2 J, D( ?$ ~4 i
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ! X7 J; c# c1 T
61.         console.log("close:"+sockState());
    7 g' p- n; a* A
62.         webSocket.close();
    
63.     }
    & r1 h* S8 w4 C$ h* j/ s
64. 
    
65.     function sockState(){
    ' k8 T/ e1 }; H- g1 J
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    6 j' j; N; J/ q0 K+ b
68.     }
    1 K; I3 x6 C% D' `3 ?+ e
69. 
    
70. 
    
71. 
    , Q7 Q8 L( A5 ]  l0 S4 h8 b
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);
    & E" M5 I0 e/ m( c9 w
78.         webSocket.send("msg="+msg);
    , x1 p0 e& t; U4 }! I
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    ! k& ~2 I' ]6 I5 b
80.     };
    ) v2 D5 R2 x3 L: S, C& p  x) F5 f9 v
81. 
    
82.     function close(event){
    9 X8 H: s7 x  I( S9 S
83.         webSocket.close();
    
84.     }
    * K' s2 y! G. }; I% L0 z8 d! @
85. </script>
    % z& E( a" U" P# e
86. </body>
    
87. </html>

复制代码

" _  H" }( Y4 r2 G8 S
" H$ |+ k; {0 O& O$ X$ N