php实现websocket实时消息推送

admin

php实现websocket实时消息推送

6 F' [0 o# d, n. e6 ?  [
5 a# A+ h$ B7 ^, ]; tSocketService.php
! m! K* e, f$ K. ?" z

1. <?php
   / ?' w! j, @) {( x5 v5 B
2. /**
   * w" u8 J7 Z0 }0 I
3. * Created by xwx
   / ]5 t. }) d; u# v# v7 }: E3 \. T
4. * Date: 2017/10/18
   
5. * Time: 14:33
   8 O4 p9 t! R! \% n" s
6. */
   # g: \; b4 b+ A$ C2 b
7. 
   
8. class SocketService
   
9. {
   ( L6 ^$ \- o. a8 h6 F  ?
10.     private $address  = '0.0.0.0';
    1 ?/ u( V! d0 V4 G# i- _
11.     private $port = 8083;
    # p9 R0 h5 A4 W* v( R
12.     private $_sockets;
    * V) W4 {2 x1 m  \4 I3 ^3 B$ o0 M
13.     public function __construct($address = '', $port='')
    . n! V8 Y+ j4 ], ]7 _
14.     {
    . w) v5 l) ?; a9 H
15.             if(!empty($address)){
    # b- w, o4 d  e2 l7 c- z
16.                 $this->address = $address;
    # b! g- x' r& m  V
17.             }
    ! f6 Z( y6 m: R* }- N
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    ! ^3 Z* q$ e9 o0 ]) X8 e
21.     }
    
22. 
    - V% [  d8 ]6 K+ |
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    3 X' E. h& x7 |8 i/ D7 y
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    - Q4 b3 j. K3 X" ^- y5 t4 Y, g
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    3 t* A/ y0 M/ l, t
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    + J6 T+ D" J& r' G; ^8 y, r( U
35.         $this->_sockets = $sock;
    / c- S& ~9 H, V6 r" o# L1 j
36.     }
    
37. 
    
38.     public function run(){
    5 t6 k7 c8 X3 ]4 N+ p2 g2 G' t
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    , A# h) \& ]* T7 ~+ ?5 p* _/ @
43.             $write = NULL;
    
44.             $except = NULL;
    0 Z& ~. b* `/ P- S' O% B3 p/ F
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    . `' O" b& C: C  x  N& u! @
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    " w& H! W" z5 D+ M2 P6 i
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    4 @1 W! {$ ]/ g
53.                     //获取client ip
    . n* F9 p' z7 o; n9 n
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    * }0 i% c, Y+ e, W
56.                     echo  "Client ip:{$ip}   \n";
    ! Y- r' H; f. L" N5 w; `6 V
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    ( p2 A* B5 v8 o1 D" H
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    ( \, I- o: V. I8 U! R
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    9 B$ i5 P: t8 D8 |0 x
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    - {9 v. l! x+ F$ W" W* `* C9 u
69.         }
    
70.     }
    " \& r3 |( m' f" u! A
71. 
    
72.     /**
    1 N* Z, M# h- T* u- o0 ]& X
73.      * 握手处理
    ' r  R& S+ P3 H  T8 {7 R* A& A
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    ! q2 c& t+ ^$ g* U* N$ Q
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    - X4 Q! Y2 ]0 `" `/ {6 Y0 P
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    ! {# h9 P& }' r* N  g; r
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    4 L& q! B& h- q5 f* P3 \
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" .
    
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. 
    
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     7 E& j7 a# W$ \" o& k
104.      */
     ' m& {+ U. t) N" @2 S' T
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     , O% Y) ~5 v' `' T3 K$ j
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     / q3 K1 Q/ k" \, P# [
111.         } else if ($len === 127)  {
     0 m/ i* E# {) g" v# b7 c- m
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     7 ~$ i# c& \! s. e
116.             $data = substr($buffer, 6);
     
117.         }
     ; T* `& C9 x2 }7 D" Z( U
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     ' @+ J2 F3 O2 o2 v  y8 q: d
120.         }
     7 q* R) A) T- r- M4 [
121.         return $decoded;
     ( b2 x. k3 ^4 n, p0 C) G: V9 ]
122.     }
     
123. 
     . [4 J) C  A3 @, C, l
124.     /**
     * a3 g) z3 ~0 ~! C
125.      * 发送数据
     9 _  y) }' A! ~. \
126.      * @param $newClinet 新接入的socket
       E8 i, M  o3 Q. S4 R" V1 q
127.      * @param $msg   要发送的数据
     . ~9 k* s$ i- T* m0 M- `  L
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     + C! D& c0 S, P
131.         $msg = $this->frame($msg);
     " @5 t$ y# u% E  G
132.         socket_write($newClinet, $msg, strlen($msg));
     * I' ^1 B0 i6 O$ ~: H  w
133.     }
     
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     * |1 b/ r+ [: L- p' \
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     7 s2 ~3 M- V2 ]; O! J
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     / ~% j9 C: b4 @5 [  V
143.         }
     
144.         return $ns;
     4 R3 X; K0 R9 C) z" K
145.     }
     
146. 
     
147.     /**
     " c) z3 Z8 A, k# j3 ?
148.      * 关闭socket
     8 P2 Q8 w' G9 {4 c  U+ v; A2 z8 L
149.      */
     
150.     public function close(){
     5 h9 \8 S. N8 I  w% i/ }2 X. x8 E
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     , |  p5 q8 B/ K2 Q7 s# M. X
154. 
     
155. $sock = new SocketService();
     : L5 J2 p. X% a* X. g# ?9 C4 H
156. $sock->run();
     / ]; W( b3 u3 B$ a6 ?! L
157. 
     3 S/ D" x$ z) s

复制代码

web.html
/ `0 g) |; [- G# [8 Z

1. <!doctype html>
   $ c! n* s2 A/ ~" B2 U( X
2. <html lang="en">
   
3. <head>
   ) `6 @2 c. f3 _1 ]# ?/ @( w) u
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>
   ( G4 n$ \4 E" P, w& p
7. </head>
   ' P# k& U; \% J) a, q, t- }
8. <body>
   ' ]! D( K8 ^' a2 y* S/ U1 B* Q
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    7 L" T8 m$ m% y/ H. S, H& q. w
19. */
    7 b* K: A; ]( M( W5 ]6 D8 ^6 q
20. 
    
21.     //创建一个webSocket 实例
    % C$ C0 [! o6 N" X+ T
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
      g' T  b0 K7 y. ~! Z
23. 
    
24. 
    ; G1 B- n8 D: j" Q
25.     webSocket.onerror = function (event){
    3 h" f, ~% S4 Q
26.         onError(event);
    # M$ ]; o4 h8 B% b& s- \/ L
27.     };
    
28. 
    ( s) `$ ]: {; r
29.     // 打开websocket
    6 i9 v2 v  W- N+ _
30.     webSocket.onopen = function (event){
    - ~9 \5 R2 Z1 B1 k& O8 }; p
31.         onOpen(event);
    + R2 \" Z& u' P) }# [
32.     };
    + q' V# W/ {  T' J6 U
33. 
    : c" k& F" a0 j% k! P: D" U: a6 o
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    , `5 Q1 m- k$ S7 C) }
37.     };
    9 u3 g" Q! o. P
38. 
    : _# [) e5 y4 i1 q1 X4 `$ v
39. 
    
40.     webSocket.onclose = function (event){
    - }: c+ L) b3 [% `8 E7 `# s( G
41.         onClose(event);
    4 P% T; ]6 }+ y: ^" Z+ {& ]
42.     }
    2 N  q% ?" |6 F2 k" ^
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    - z9 s& T' A" l0 Q
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    : M- L, H& A8 M1 V- x- E
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    4 O4 C; u5 f& A3 h& {: d7 ^9 Q
53.     };
    
54.     function onMessage(event){
    1 p* a; |$ d1 j  u7 J# o
55.         console.log("onMessage");
    " F; ^4 f" P: J
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    ' @; S( ?/ Z9 q/ e$ q8 S1 v
57.     };
    ' u2 B5 v9 _- \
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    8 N2 c9 }, ]* \- V
61.         console.log("close:"+sockState());
    8 ]' q/ x8 C. `! t8 h4 P0 E
62.         webSocket.close();
    
63.     }
    
64. 
    4 |2 O  q3 i3 A% t8 ]. z
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
      J) T; L) Y* X* N/ K; C6 j
67.             return status[webSocket.readyState];
    
68.     }
    : Z( `- {! }0 }3 @- M
69. 
    
70. 
    
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    : }/ x/ z; d+ C
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
      O' P" E5 z: v7 K. E- P8 V6 w7 s0 X( X. Y
81. 
    
82.     function close(event){
    3 b7 J4 W; K1 V, u6 [
83.         webSocket.close();
    ) Q/ C* x+ {. G* h
84.     }
    6 T# Z/ v: r; _# C
85. </script>
    % w: k: ~: E4 `6 I$ N# M/ V
86. </body>
    1 z- a: L0 T' H6 A4 F
87. </html>

复制代码

% _- d  l- `( Y- N, o% \8 I
! Z* v0 M+ a# _. K5 N* t- V