php实现websocket实时消息推送

admin

php实现websocket实时消息推送

. k! `% S" |+ K3 N7 F; `& L, a" _
SocketService.php

1. <?php
   0 [4 X; e/ h7 Q7 K7 Q& t. s3 C
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   5 C  W- i) i' O/ b) K1 i+ v5 C& ?
5. * Time: 14:33
   
6. */
   
7. 
   
8. class SocketService
   ' Q( z/ M9 w1 B
9. {
     Z# h- B1 G5 P, g1 M, x. L# G! `
10.     private $address  = '0.0.0.0';
    , d- v, Z* E, G- j% m) g( z" p
11.     private $port = 8083;
    
12.     private $_sockets;
    2 Q) \. y7 ?. Y- o/ t. \
13.     public function __construct($address = '', $port='')
    6 o, h7 a& g) ?- G: B" g' p3 i6 I
14.     {
    . x2 n& }- G& }5 x- D- z; y* `; Y0 [
15.             if(!empty($address)){
    8 D8 g7 ^! E1 h& Z3 p& Q
16.                 $this->address = $address;
    4 K9 r- S( @& n' U9 R; M/ W
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    . V+ o; [2 d; q
21.     }
    6 E9 h# v" c& ~# T7 V
22. 
    , c! N! ^* ]8 j$ P
23.     public function service(){
    
24.         //获取tcp协议号码。
    0 g9 ^& P6 G6 O. v9 Z2 @( x. t
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    / K4 [, B  `& P
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    3 o* N/ S# @  I0 s) Y  {( {, e
29.         {
      X; X' R8 |) Z  I6 \$ x
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    % m6 P! o0 o8 A. i3 U$ G5 J
33.         socket_listen($sock, $this->port);
    ! t& U$ k8 z/ v3 }* a/ S
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    
38.     public function run(){
    + L7 v4 F6 l3 `
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    * u9 v; B0 {8 J7 d
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    7 j* z+ {1 [- q, F: f- ?
50.                     }
    $ w+ _1 W! R: N1 T: a  D. @# {
51.                     $line = trim(socket_read($newClient, 1024));
    4 z8 D. S; s* C( ~, i$ H6 D$ w
52.                     $this->handshaking($newClient, $line);
    2 t2 @( m. f/ ?3 L  U9 K: Q. A' p' v
53.                     //获取client ip
    1 m! n1 o* A$ h5 H
54.                     socket_getpeername ($newClient, $ip);
    ( Y  G( L, e" c
55.                     $clients[$ip] = $newClient;
    ; t0 W* O4 D( d' a. N/ [; t
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);
    ! U- D- L( ]) d- J$ N, T
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    + |  U1 k- g# \
65.                     $this->send($_sock, $response);
    5 p# [4 i6 O  c' O
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    $ p: W/ r) q& s- v; w, d$ T8 ]
68.             }
    0 U, m/ `& H4 G8 O4 h" `
69.         }
    2 z& A; f; `- }1 m- J! d
70.     }
    $ y& A& v3 Y5 j/ |
71. 
    2 i# k5 h& i4 U5 f
72.     /**
    * f. c! p1 b/ a: L) n3 {
73.      * 握手处理
    
74.      * @param $newClient socket
    3 i% ~+ d4 \: z+ ?# Q& F
75.      * @return int  接收到的信息
    
76.      */
    5 N' H/ n1 e- Z
77.     public function handshaking($newClient, $line){
    
78. 
    6 @2 H4 g% Z) R# E6 D
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
      m8 g! }# M4 ~4 D2 M/ O( d* k' \
82.         {
    
83.             $line = chop($line);
    6 _; \. L/ k( {2 R& \: n
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    5 W, |, s) A- r
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    % ^- ^( r+ Q- N: K9 L
88.         }
    # M& Q6 v+ x  R4 J5 x2 i
89.         $secKey = $headers['Sec-WebSocket-Key'];
    % k8 _, R: }3 }; g6 x
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    ' G: ~1 x4 J3 \. X
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    ! ^5 |4 ~2 Q- T2 G
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    2 X2 g/ E7 q0 B& G
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
      z& M1 T1 D8 D' g2 m
100.     /**
     ' _2 _' `: O, y) B
101.      * 解析接收数据
     " b/ i( N! f1 [1 b5 Y
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     2 o# X7 P1 e; F7 t1 r4 s3 ^
105.     public function message($buffer){
     2 R8 A: [* ~5 x  B1 z" Q+ D* G
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     ' o2 N, N& J( _' [' L5 L0 K
108.         if ($len === 126)  {
     2 p: k4 m- a* g1 p
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     9 k5 D5 _0 ~( E
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     4 {1 Z; m9 E3 Z# o$ |5 z7 _
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     ' {+ h/ u  r, w' |/ c7 e
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     / f( t9 Q* X* s
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     , |) C. ~7 _/ J, D
121.         return $decoded;
     + y8 r3 X; I. M' z' X1 Y7 @- a
122.     }
     8 f  J2 J9 ^/ Q
123. 
     
124.     /**
     
125.      * 发送数据
     6 b( Q# M2 A6 F6 {/ Q% `, ~
126.      * @param $newClinet 新接入的socket
     2 [7 s% J$ h! a+ h) E3 J) P2 U. X: q
127.      * @param $msg   要发送的数据
     . ^/ l5 y. f9 r( {& R
128.      * @return int|string
     * q# ~/ i; V/ B" D
129.      */
     
130.     public function send($newClinet, $msg){
     7 c! U5 V, R! ?: t- \! [9 p' D
131.         $msg = $this->frame($msg);
       _6 W8 C8 D/ y  T
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     ; F# ~" M! F: ^2 `; g# V% _
134. 
     7 A  P" B) x7 ]$ w. @; q
135.     public function frame($s) {
     ) o* }: h5 O. N: h; K8 W
136.         $a = str_split($s, 125);
     $ y5 H/ w% _$ Z. E' K, L  T1 k+ [' y, ]
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     1 Y' h8 N% a( {. Z. h
139.         }
     % u1 L" o( C9 W8 T3 G9 t$ V
140.         $ns = "";
     
141.         foreach ($a as $o) {
     + j$ K  N. e7 {/ {; h
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     3 a9 _8 z* t% R" f
145.     }
     
146. 
     + s0 q( X6 l4 k; {* I( O
147.     /**
     ! h# A5 t# e& A
148.      * 关闭socket
     
149.      */
     4 w( ~; P# z/ F$ I' I# l$ I
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     ( C9 m3 v; H9 K1 }  X
153. }
     3 m" e( g( Y$ d. ~( w! [; k$ X
154. 
     
155. $sock = new SocketService();
     1 I/ g; G# `& E% p9 \/ M% H
156. $sock->run();
     8 y- a% B$ d  |" T/ z! |
157. 
     . h& ^- [1 c7 A* l7 `  w( h. w

复制代码

web.html
& P! b4 B- m0 G: h# X* C0 i

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">
   
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   . q5 K. `. M$ v& v2 s  E
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    , I" v# C/ p! `2 d2 u2 I
11. <input type="submit" value="close" onclick="close()">
    0 [- }! w/ Q  d: @+ j" j
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    9 w6 N# F& `  B& m2 N  |
15. 0：未连接
    9 g0 b% Q: L, G$ g6 q$ ^+ J
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    + h  e6 I8 N: n2 X7 \+ y1 s
18. 3：连接已关闭或无法打开
    
19. */
    7 c1 Q& [2 X9 L2 P5 i4 |/ q
20. 
    $ \4 `  W3 \; p  n: v- Q  a1 _
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    , H# y/ u( x# \! g) X, R
24. 
    - d6 [0 ~, I% C* J
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    6 h. q9 W+ Y# H; X
27.     };
    $ l/ I7 L3 y" x, E0 i
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    ( J2 V- G& q+ j# d! W$ y$ T. Y
32.     };
    4 I9 E! D" q: L8 G
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    3 i3 U7 w, U! j
36.         onMessage(event);
    
37.     };
    
38. 
    
39. 
    ! I  ]2 F' i$ u) J/ j
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    , u' L9 t6 b1 i& ?: n( Q
42.     }
    ( R7 v  t( i" X
43. 
    % y+ m* j- f+ ^9 ~! n- ~3 _4 k1 u
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    8 X" W1 H0 J1 i2 n2 n2 e
47.         console.log("error"+event.data);
    & k6 k  a4 K; b5 \+ r# a5 w& I
48.     };
    
49. 
    % o* \( t. T! _/ E. |/ @
50.     function onOpen(event){
    5 T& V; l6 K) B. [9 S
51.         console.log("open:"+sockState());
    1 j) W9 k) B, U! @
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    5 V4 _8 r3 r7 [% q8 \; y  N
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    7 t% E0 z  n% w- G  e
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    + ^; P; j) u! k
59.     function onClose(event){
    " W/ ^9 c0 Z& Y; k2 A
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    8 P5 A2 k9 h# z4 N
63.     }
    
64. 
    ( D* i* U0 |; L! m- y
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    ' |6 U) O( Z! d+ C& s
68.     }
    / j) S" R/ b6 N% P$ u
69. 
    / J# i) Z/ k7 t+ W, ~" ^/ V) y5 {
70. 
    
71. 
    
72. function start(event){
    . D0 |; f9 G2 E# D/ Z9 e# r2 v
73.         console.log(webSocket);
    ' P3 i, m5 ?8 l4 F+ q& M4 D
74.         var msg = document.getElementById('text').value;
      t! n! L: H  R) y) u0 {. j7 `4 V
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    ; ]2 [) C; y/ w
77.         console.log("msg="+msg);
    ) w  }' }$ G' |6 O
78.         webSocket.send("msg="+msg);
    ; L7 |+ X% C+ v, l
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    ; W2 @/ W! H5 [" C% Q
80.     };
    
81. 
    # C4 {1 D0 l9 h' i
82.     function close(event){
    9 e/ z8 Y  O3 [2 c3 v$ B$ }
83.         webSocket.close();
    4 [6 Q' \9 o: c, F) z9 h
84.     }
      E. P2 D" ]4 Y! b4 f  q
85. </script>
    . `9 Q7 p+ W( G( w# F
86. </body>
    
87. </html>

复制代码

: ~: x( n# B7 b4 y