php实现websocket实时消息推送

admin

php实现websocket实时消息推送

8 \4 C( {) k% f4 R0 ~* e
SocketService.php

1. <?php
   
2. /**
   % e6 v+ v# e' h3 V
3. * Created by xwx
   8 I# K6 ^3 g( a
4. * Date: 2017/10/18
   ( {" B/ `' ~3 i. S: F
5. * Time: 14:33
   
6. */
   , d3 Z- S) v0 n' x- [
7. 
   
8. class SocketService
   . }& e5 I3 ^- N+ r
9. {
   
10.     private $address  = '0.0.0.0';
    7 a: a: J, b* R6 x% g
11.     private $port = 8083;
    
12.     private $_sockets;
    % I1 a6 I8 P7 {+ q( u" n
13.     public function __construct($address = '', $port='')
    
14.     {
    / ~, ^5 O$ M7 c$ i0 u
15.             if(!empty($address)){
    " X9 `( \( o4 A9 M: e- C
16.                 $this->address = $address;
    ' H/ m; j7 M+ U. S
17.             }
      H2 p9 W; |* z) D% {9 U8 x2 z
18.             if(!empty($port)) {
    ( G3 C4 R' M! @7 E  E  [0 U& x  `  m8 o
19.                 $this->port = $port;
    
20.             }
    $ L4 c( y& K1 u% {9 Y% t' e
21.     }
    % v$ H6 ?/ X& Q' r) d7 D
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    ; @4 T$ w5 a4 B' W
25.         $tcp = getprotobyname("tcp");
    1 v& `, \2 W( U& r3 }: Y9 y) E5 m* E
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    
29.         {
    8 \; i6 r  n" j. q" @/ s
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    ' G" w( o/ U" ^/ K
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    7 P- W4 F3 k7 [: K- c9 E9 n9 p
37. 
    
38.     public function run(){
    
39.         $this->service();
    3 @6 X. [3 a, v" w& k7 t# i7 O
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    * l9 a0 \  }3 Y0 f* i; d/ j' R! r4 `
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    + X* o. `* I- O! |# [7 m8 \
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    " t3 Q2 z* Z2 d) d% o/ m* |) X8 o, L
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    1 D5 p% C' W& A2 Y4 R! V! E
48.                     if(($newClient = socket_accept($_sock))  === false){
    4 S2 H6 b& c1 D2 i+ ~1 P) H1 ]
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    4 s, z: M% ?/ u  X6 b# J
50.                     }
    1 ?( w; ~  W2 b  J9 X
51.                     $line = trim(socket_read($newClient, 1024));
    2 ]: K& C' K7 b3 d7 h8 x
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    % p! M9 N& m) X& z: B
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    8 L6 O1 n7 m9 M7 R# B4 X5 [' t
58.                 } else {
    - |( X! f0 C" F  W
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    ! P, w  L! Z/ i, i0 D/ ~. a5 \) d
61.                     //在这里业务代码
    ) j3 x: b# x) L% O+ c7 ?4 w
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    $ ]& u" {1 R  D& |
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    
69.         }
    
70.     }
    / a5 Y+ z6 o6 L
71. 
    2 ^, K7 h( i6 w6 l
72.     /**
    . S, s, ]/ r6 N& q
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    & {& D5 v( I. }  ?3 ~4 y$ z3 o/ |
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    1 ^0 L- E" y) N8 e* u4 ?
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    , `7 H5 n2 n5 T1 X+ d# u* @
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    # e5 p: u3 s6 K, s. d' t+ x
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    2 |; l2 x& g, I3 z- S1 \
87.             }
    8 M9 t3 Y* F, N5 k4 a7 N1 m  A) @
88.         }
    1 f& ^& X# z: V3 z% u
89.         $secKey = $headers['Sec-WebSocket-Key'];
    ! G- ?( C. q9 a& k8 f+ f# r: I* A
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" .
    ! P$ v' A/ N' p, s
93.             "Connection: Upgrade\r\n" .
    ( B/ S/ V2 ~; U$ [& Y
94.             "WebSocket-Origin: $this->address\r\n" .
    " a: J: f1 E6 H' X+ ?
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    # ?9 l6 j2 _) ^( v
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    : j) ~, Y& l$ i( }1 p! i9 `) J- [8 B
98.     }
    ( b7 O/ {, u6 e; N/ D
99. 
    
100.     /**
     * ]' a0 b7 }3 E0 z5 E3 j* E
101.      * 解析接收数据
     
102.      * @param $buffer
     6 @/ g3 I5 V% D0 L1 t4 }% U
103.      * @return null|string
     4 g* D" P1 h6 P! k1 E& F
104.      */
     
105.     public function message($buffer){
     5 {/ I- n/ C# F# f+ y% {2 i9 D
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     0 q( r4 U6 |% F7 X
108.         if ($len === 126)  {
       `1 ^6 i0 {2 O. s9 n
109.             $masks = substr($buffer, 4, 4);
     - j3 N4 O% M7 j1 t- P* O  K9 a
110.             $data = substr($buffer, 8);
     0 f: v* S' N1 e% X+ d$ y; K: L
111.         } else if ($len === 127)  {
     / V6 H# J# D3 E5 q6 a
112.             $masks = substr($buffer, 10, 4);
     & ~" e/ m7 M' h5 C; ^
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     $ r2 W& j3 r; V* F! _
116.             $data = substr($buffer, 6);
     7 h: J* S* _' r' i  D
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     . q$ C: N: Q# E" ~; o# R
120.         }
     - ?9 p0 [) s. V3 S9 t; P, m9 Y
121.         return $decoded;
     
122.     }
     
123. 
     
124.     /**
     2 e! p; I. O, m4 }& A7 E3 j
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     0 O# t4 A! f6 q8 l4 R
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     * u* e. C; c5 Q2 V
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     + I+ \7 \' Q1 Y5 q/ l
133.     }
     
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     4 y1 X! g* ^. @0 ^
137.         if (count($a) == 1) {
     * s' P7 H9 u& r) q9 V1 v
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     " J$ q1 T( y) j/ U
139.         }
     
140.         $ns = "";
     4 a' K7 g% `3 Y0 Y& v! Q, I% V
141.         foreach ($a as $o) {
     & r. w$ t! y1 U: V
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     7 p# G3 m# S+ F% A; S4 R0 F$ |
143.         }
     1 q- H2 i5 \8 ]4 O  i! I
144.         return $ns;
     
145.     }
     ' x6 f$ w# k3 S! s) y, h$ ~# p- ^
146. 
     
147.     /**
     
148.      * 关闭socket
     , l: o+ a" g" }1 A' z
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     7 p" X" Q9 [: H4 k. C# [
153. }
     
154. 
     5 ^. z( J9 U* {' b' e' Y
155. $sock = new SocketService();
     2 \1 H! L$ h% g! I, u, E0 ?5 |" d, C6 K
156. $sock->run();
     
157. 
     % O* g9 h9 w& K' y

复制代码

web.html
% y. _1 `8 ~; _' z

1. <!doctype html>
   & w7 [* V6 D; i% U! w% R! D- r8 |
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">
   , o/ P, g6 ^6 Z9 g$ y% k2 L
6.   <title>websocket</title>
   
7. </head>
   " y6 y$ X- E" k
8. <body>
   3 R. p2 [* {0 L! O0 I1 M& V
9. <input id="text" value="">
   & z9 @! m8 v8 h8 c0 d
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    + m0 h8 \) c) e0 H% G
12. <div id="msg"></div>
    ) V" O3 M8 F5 j7 k& h( U
13. <script>
    
14. /**
    9 a6 M! p' Q5 N! a) T& i( Q! L
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
      d' K6 d, Y# j' t1 M4 L# S9 u. P
18. 3：连接已关闭或无法打开
    ; Q7 `! e( Z4 S8 n, V; [- U7 r
19. */
    . R2 @; |0 F- j5 L9 f1 S# `
20. 
    
21.     //创建一个webSocket 实例
    3 ^- b" M: B) f5 X
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    7 X0 n/ E: M# l& M; C2 o9 ^2 W" b
24. 
    . H; y; U( |; }. b
25.     webSocket.onerror = function (event){
    / r* Q: [$ z0 i* w  z6 L8 H% z
26.         onError(event);
    2 m6 h/ _: v; G- d
27.     };
    
28. 
    6 W0 H/ d# T. S0 L$ W* Q
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    ; h0 B$ M3 m" |9 {9 \
31.         onOpen(event);
    
32.     };
    
33. 
    " `: K5 ?" n" m% |
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    / `" @' m: E3 s1 H  f" K( R
36.         onMessage(event);
    8 Q2 W. K. k' C$ s6 Z
37.     };
    
38. 
    ) H5 ?: C4 Y$ W. \
39. 
    1 ?' @) E4 R) P6 k- U$ H9 e
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    + s/ K) G/ v1 y: G5 b  U
42.     }
    
43. 
    
44.     //关闭监听websocket
    7 N6 v! N. P! i
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    + ^+ \7 ?7 I" j, k2 ], Q+ A1 h" s
48.     };
    
49. 
    3 b+ ^; n' B! i" e  G, Y
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    4 J  i3 I, B% D% s* A
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    % O7 q, Q' N! G5 O# b) z) A
61.         console.log("close:"+sockState());
    : a' g0 p' ~1 h  Z% v$ q
62.         webSocket.close();
    
63.     }
    4 D5 @6 o* M) V
64. 
    
65.     function sockState(){
    0 Y7 A: Z" \8 z* K7 e2 v
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    7 y' h. v  n# r8 p5 O3 a
68.     }
    ' S/ S1 |8 z3 {/ e4 n% H
69. 
    
70. 
    
71. 
    
72. function start(event){
    2 ?6 v$ Z- _& f* V8 G
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    . ^/ I( ^; |& c7 s( L, _( r
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.     };
      |1 s; v' O" B9 L/ ]
81. 
    
82.     function close(event){
    ! T3 }4 P+ f2 k* [. i! e4 V
83.         webSocket.close();
    # z9 R: i2 n: k1 d
84.     }
    
85. </script>
    
86. </body>
    
87. </html>

复制代码

4 F: N$ z, ^3 D+ l

( g# a9 |7 B2 ]9 y