php实现websocket实时消息推送

admin

php实现websocket实时消息推送

& U* H- U4 [) N; _
7 k( i4 j, H/ G6 ?+ u0 O8 LSocketService.php
2 w; t1 d- C9 `5 U% `/ U

1. <?php
   9 ~1 p5 U7 Z: `  Z2 M7 \0 a5 l- s! b- `
2. /**
   / b* l! f& x, _6 W" q4 P
3. * Created by xwx
     H0 n" S- A4 Q& g  U4 P
4. * Date: 2017/10/18
   6 p8 c0 P; z5 [' E5 u! B
5. * Time: 14:33
   
6. */
   
7. 
   8 z- m7 l4 v; Q9 N3 u
8. class SocketService
   3 h& P' R8 f6 l3 s, m2 P  c
9. {
   0 x9 }& B# {  c, W  y9 X; M7 f
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    9 v2 A7 K- k+ M* t" O1 P3 E
12.     private $_sockets;
    , \' Z, S: H5 F" E! V/ L( I* Z2 f
13.     public function __construct($address = '', $port='')
    & K" |& @2 m5 [/ w/ O9 c6 L- x% e4 g
14.     {
    
15.             if(!empty($address)){
    % t0 V. E& x5 v
16.                 $this->address = $address;
    6 h2 s; m$ [  w, e) A. H
17.             }
    * U! N  N4 Q7 R
18.             if(!empty($port)) {
    5 z- H4 r9 C. T8 D2 k1 a
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    8 ?# f, }9 `% M% b6 j- d
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    $ v# P' x9 E$ d4 f& n8 y  {" e
28.         if($sock < 0)
    0 K( @; F! i9 N: T  v  h; U: t
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    " C' Q3 [3 b" F6 e, F  k
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    " {8 }% P  B; q: J% D$ h
37. 
    : g. D9 r& a4 x' d( f/ H* ]
38.     public function run(){
    
39.         $this->service();
    6 C1 _4 O* _# Y+ g
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    3 V9 a( N' C8 ~6 S
42.             $changes = $clients;
    
43.             $write = NULL;
    9 H; O6 H9 c: v$ P, G& K
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    / _- X+ \$ x9 J' ~
46.             foreach ($changes as $key => $_sock){
      t- ]5 }- j  w; x8 `& ?4 ^
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    " n3 q! Q4 g( p3 {* t
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    . O8 P1 F% a. m2 z
50.                     }
    / v1 e+ V: |4 n( S0 o; l
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    / Y2 U+ t7 y( ^+ w
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    - O0 y: l9 @* E' D; v! c7 V
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    4 E/ {/ }& C, m" C: }
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    ' A4 H; z# V' M* f
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    : l: A( q: ?. B" r7 g
62.                     echo "{$key} clinet msg:",$msg,"\n";
    ) @( |$ t  t( A* |' w
63.                     fwrite(STDOUT, 'Please input a argument:');
    3 w( j8 \; R+ E; p  b
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    & d2 u  k7 f  M7 \7 S
67.                 }
    , K) z% m2 [' n! t; x
68.             }
    2 d9 E2 P5 `/ D* e% E, w
69.         }
    8 }( d8 I5 h, J4 M, \
70.     }
    
71. 
    3 S8 i) z+ ^6 q+ F0 j, z
72.     /**
    
73.      * 握手处理
    ' H4 Z, Y* \: y4 [/ Q+ m, t% O
74.      * @param $newClient socket
    4 R6 b: B. {  o" C, ^; o3 |
75.      * @return int  接收到的信息
    
76.      */
    ; Z: r) k  a" j/ J& y1 F. d
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
      @% T5 ^+ ?  C$ N' i6 Y& K6 ]
81.         foreach($lines as $line)
    3 `; h" |4 j& ~6 a- `0 ]
82.         {
    
83.             $line = chop($line);
    , c  h1 s  [3 K+ \. a* Q8 g
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    4 B" f* j2 r% i8 W$ A3 J) f; _
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    5 B; [* u: k( H% b0 Y- @" M
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    + W' w8 l. e1 @, }0 `
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    # |$ x! O$ X  K3 \+ Y' C
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    . h7 U6 x: `4 B% B+ c! V
94.             "WebSocket-Origin: $this->address\r\n" .
    / W5 W" R9 H! M4 ~  Y
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    4 U" a& V$ o! o, R7 g4 i
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    5 @) s6 {0 r7 }2 \; q- \
98.     }
    ! y3 |' a' T6 O( x; U7 ?
99. 
    + S5 e% c8 c! z" [6 x4 F* N2 L3 E* v
100.     /**
     # B1 u; x& j7 f3 q
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     - b" u& v/ x/ r0 m
104.      */
     
105.     public function message($buffer){
     ) D# N" l. @- P8 h
106.         $len = $masks = $data = $decoded = null;
     + s" w( b& P$ g- I
107.         $len = ord($buffer[1]) & 127;
     9 l5 d) Q) X8 X  v2 p5 O; N# }
108.         if ($len === 126)  {
     ' K0 n7 P7 M" ]. }+ |1 y6 A
109.             $masks = substr($buffer, 4, 4);
     8 y7 ?3 j5 r6 q% W* U
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     ; b" j9 x$ H# r  y# ]# X$ {! L) M
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     " I, ^) _  L1 w% q3 v
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     . k! S4 B+ E# ?" W: e( `
120.         }
     
121.         return $decoded;
     
122.     }
     ) H* R2 [; o" M; Z' R
123. 
     
124.     /**
     . s, |1 ~" d' b+ `, e( c4 g
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     / ^$ t" [* ]' _- f. u0 n  s6 N) e
127.      * @param $msg   要发送的数据
     ! c9 h+ {: l# V" [
128.      * @return int|string
     9 `# y4 q; ]$ N. D: f; @# W
129.      */
     / V! Q4 L8 m9 D0 b8 o0 t/ g
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     / N/ b7 u/ k$ a' p0 |1 g* M  \
135.     public function frame($s) {
     ! t' D* Y2 i, u2 A9 U
136.         $a = str_split($s, 125);
     ( r1 x9 i$ `1 K
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     2 D4 j9 c7 d( N" k
139.         }
     , @  z0 o& }) C& I, z
140.         $ns = "";
     7 r6 T6 w5 x, Y% o$ h# D7 {2 h+ m
141.         foreach ($a as $o) {
     0 S3 k: X( K$ I4 N
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
       O" P; @7 @- M4 E8 i
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     ! @- _. l( ^( Z
152.     }
     
153. }
     % h/ g; r* T7 [4 N3 x
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   
3. <head>
   
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   + y: A% G; J0 h
6.   <title>websocket</title>
   
7. </head>
   4 h& L4 u; m' f
8. <body>
   7 T+ @) I$ M; H6 J* d" n
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    2 A0 t* G$ D/ F9 w8 E4 J
11. <input type="submit" value="close" onclick="close()">
    0 @1 J+ T+ U, V  v
12. <div id="msg"></div>
      a- N. A' i, h
13. <script>
    
14. /**
    
15. 0：未连接
    4 G* L$ }; ^- [. G) f: ?
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    ' W$ d- E0 h- S6 w8 W: g7 q. z5 j! i
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    , r. d0 U. n, e6 a: R+ H4 c- P3 u
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    5 d. ^" L3 f8 h6 K* [* F
25.     webSocket.onerror = function (event){
    4 l! `; Q! S5 r7 I1 w7 A2 t" _
26.         onError(event);
    3 m3 s8 O8 O, _) g5 k
27.     };
    2 F/ a+ m( z8 Z1 k
28. 
    
29.     // 打开websocket
    ( k+ n1 ]' D9 |; _3 t
30.     webSocket.onopen = function (event){
    ! C! h) u# I' t
31.         onOpen(event);
    0 O: g; O: L0 _* B+ a0 @: x" P1 ?
32.     };
    2 T- i9 X1 ], c( c
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    % o+ @; y( V+ G* b1 C
36.         onMessage(event);
    9 i: m5 d0 `, J9 S6 O
37.     };
    ( K5 ^4 d" X0 M# H
38. 
    $ c# V) _5 ?. n+ n: A8 D, {
39. 
    
40.     webSocket.onclose = function (event){
    . E- O, k7 p! ]7 W
41.         onClose(event);
    
42.     }
    
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    0 r, U9 R5 \! x' Z. f* s  R
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    9 r9 k& \. e* y) C8 V; P
48.     };
    
49. 
    $ T7 a$ H2 Y9 |
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    1 O; r3 w" V4 e& K
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
      G$ k# B1 j8 Z. [* I6 ^
53.     };
    ! B6 ^9 B) |9 F3 f0 K# l
54.     function onMessage(event){
    + I: V* j, L) D0 d& m
55.         console.log("onMessage");
    7 |& }! i5 H8 @/ V9 \8 \
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
      V: Z# r+ S: e7 p  b: v/ f
57.     };
    1 [  H' s2 ]4 a  t& S
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    # r* x* N) b' E6 F2 Y
61.         console.log("close:"+sockState());
    & S# n2 l5 A$ U. e* e) h  s4 e
62.         webSocket.close();
    4 j4 [; p2 B+ f4 D( ~& f* W
63.     }
    " Z0 s0 a1 i* A, \9 v+ B
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    5 g9 k# V/ z5 u
68.     }
    
69. 
    
70. 
    6 [8 e9 O) G! w9 w/ N# _- ^/ H
71. 
    * y3 T2 M) F% Y( W
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    + J  Y- K$ O. F" J9 s
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    ) `. l8 K) w1 t. c1 [3 S/ C
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    1 C% I: K' {5 o
80.     };
    ) A; Q! @9 E/ p3 g( ^
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    3 ?, _% o1 s* w7 ?# s# K' p) R9 c
85. </script>
    7 K* E, }% e0 ^' c
86. </body>
    6 p8 J/ a3 P' \/ e+ q3 S) E1 a5 }6 p
87. </html>

复制代码

2 X$ _7 D; c" r" z. E- b1 _9 u
# B! E' D; r0 C2 N$ X1 Y