php实现websocket实时消息推送

admin

php实现websocket实时消息推送


8 d" a& w$ H  Y, S( ^5 }( F& nSocketService.php
+ Q$ r. k. D7 y

1. <?php
   * l$ s5 k3 j0 f& c
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   % V( V) y6 L5 _$ B1 I
5. * Time: 14:33
   
6. */
   
7. 
   
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    3 F0 ?5 }+ M7 _) P: O2 u3 q! F% e
12.     private $_sockets;
    % R9 `. ^* {' A; ^% Z+ U
13.     public function __construct($address = '', $port='')
    4 R: V4 w. m1 X2 b
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    . O) N3 i% \0 `% }# V; t  y, P
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    5 l! ~% O- ~+ x6 y4 b1 D
23.     public function service(){
    
24.         //获取tcp协议号码。
    * K! L9 k  l1 @
25.         $tcp = getprotobyname("tcp");
    8 n7 d  l( [7 l4 ]) R
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    5 v( L  R/ t. I
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    # o( V  {* G$ {3 C
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    6 r1 |  L: V+ K, R' {+ G! I
34.         echo "listen on $this->address $this->port ... \n";
    9 s2 ?) P  _$ a0 J5 \" n/ Z7 X
35.         $this->_sockets = $sock;
    ( \) ]5 k6 O* U+ [5 k
36.     }
    
37. 
    ! R- q/ l1 Z) G! q- E# I& [" ^! _
38.     public function run(){
    
39.         $this->service();
    + P2 `+ y) u! N# g: Q/ R& O7 o, P
40.         $clients[] = $this->_sockets;
    & x+ a0 ?) y" v+ B; q" a! l6 A
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    . X0 P' V) @+ F: v' R5 P
45.             socket_select($changes,  $write,  $except, NULL);
    1 l0 l- j# W- f+ l( T) A1 Z" W. k
46.             foreach ($changes as $key => $_sock){
    5 p, u' ]( H9 w4 n5 Z
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    " P8 a6 L  v1 K& I0 F7 a
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    " g3 a7 [0 F0 T6 ^
51.                     $line = trim(socket_read($newClient, 1024));
    4 Z3 Q$ Y/ _( Q% p
52.                     $this->handshaking($newClient, $line);
    / R3 e. x8 w# o. R% }
53.                     //获取client ip
    ; ^/ R/ S4 X; j
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    ( ^6 \# k$ x  m
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    3 p6 }$ I: `: K" Z( u
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    # m7 v# |, Z6 u
62.                     echo "{$key} clinet msg:",$msg,"\n";
    ) B5 R8 a# Z% M4 t' R
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    4 B* }/ y. d. C% W3 y0 J; @4 }
65.                     $this->send($_sock, $response);
    6 h6 d  F6 \8 s- w( y
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    4 ]' d8 @4 F* F% l! B1 G/ b* j! @
68.             }
    $ @6 y9 J9 d* g, ~  m
69.         }
    2 U/ U; N* J1 ?
70.     }
    
71. 
    
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    % z" ]2 x# e4 o) q  a; }* c
76.      */
    $ J: Y: J0 W/ I( p; Z9 v8 w
77.     public function handshaking($newClient, $line){
    
78. 
    2 Y; c  v- Q4 g% u
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    & `8 O1 P) A# Q2 U' o) U% e) O
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    3 x; d. j+ C8 B; y9 z( u
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    2 z2 H- r  I2 k+ }) a" C1 b
87.             }
    
88.         }
    % ~" Z' H% `9 ]6 |! \, Z* P
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    0 W; H9 W' j% H
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    # s9 L) a1 s; d3 E4 n' ?  r6 A. V
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    * G5 w& U. @8 C* p* u  n* D+ J
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    
100.     /**
     + }- d6 [7 R/ Z7 W
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     3 e/ p2 e' a) ]2 B6 ^, B; ~. x
105.     public function message($buffer){
     ' L- z2 g$ ~9 O; R- ~9 c# \
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     & g6 B( D+ n4 n
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     " }0 c: n9 Y. y1 `# A
113.             $data = substr($buffer, 14);
     3 O  D, r6 G. Q' {% q
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     - N' g* R1 N6 v6 p7 B
116.             $data = substr($buffer, 6);
     
117.         }
     . v) n, m- h& I  x& K
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     ' m( N& a( F& |. ]
122.     }
     
123. 
     2 o7 i7 H# A- G. g5 R
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     3 _1 x# p2 K- r9 e# T1 m
128.      * @return int|string
     
129.      */
     & F2 g) z% ?4 R/ B' u7 x
130.     public function send($newClinet, $msg){
       G9 x$ S; E" _( D9 q
131.         $msg = $this->frame($msg);
     ) B( Z. x+ ?8 P0 b+ `# X
132.         socket_write($newClinet, $msg, strlen($msg));
     5 \" I( Y, `- E9 h! o
133.     }
     
134. 
     
135.     public function frame($s) {
     # g# a& a. c+ v. _
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     3 C, m. \  K7 v
139.         }
     - E  w- g! k( J. P+ T" t
140.         $ns = "";
     7 B2 g' r3 E# d. y
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     / ?' w; `; L- g, e; N
143.         }
     
144.         return $ns;
     
145.     }
     9 d! [! c1 I" w4 h2 @
146. 
     0 L" i7 \; G1 q3 e
147.     /**
     
148.      * 关闭socket
     
149.      */
     , T8 {- Z- I& K% V, q' o: J
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     
154. 
     4 B: v, R! N5 u
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     5 z  M' n( q+ _' s. w) _

复制代码

web.html
0 o+ A" Q$ A8 v/ N4 d' a( m) p

1. <!doctype html>
   ) V* I8 y. R8 W4 P: H
2. <html lang="en">
   ( |3 ~# t4 O9 ^( K
3. <head>
   ) e4 A' L4 a. U" L  L3 A# h
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   2 J' i) U2 i. V
6.   <title>websocket</title>
   9 U: i; y' ?* k( o+ E
7. </head>
   
8. <body>
   
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>
    5 p2 C4 a9 h# Z- b- Q7 t+ F
14. /**
    5 Z9 B% C! F6 B7 }# ]+ i- s6 r; F
15. 0：未连接
    4 _- ?+ e6 t' B% ]. ^: H
16. 1：连接成功，可通讯
    - P% @$ a7 j& ]- t! T9 Y! K
17. 2：正在关闭
    ( X. n* J7 Y' p( @
18. 3：连接已关闭或无法打开
    / |( K  u2 p: O% d
19. */
    
20. 
    9 ^$ u3 h5 _+ X. ?# t8 `' J. K
21.     //创建一个webSocket 实例
    - j2 X  Y' G9 Z
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    / K/ `2 b8 e9 q$ i7 [2 {
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    % A% Q7 `$ O/ p$ }' l  ]7 D
27.     };
    
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    / ~8 m; Q$ C* [+ o0 D; W' o' {7 U" H# t
31.         onOpen(event);
    8 s) @8 R1 A+ z: }. y
32.     };
    
33. 
    ; U0 J: Q' d2 i; M5 A5 m, f
34.     //监听消息
    * }, g7 l: @( j
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    8 z+ ^) _4 O& i  M2 v+ \
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    ' I0 w- U) U& O7 }2 H- U* v+ {6 h8 V
43. 
    / q7 h1 z  ~' l, ~( t" ~
44.     //关闭监听websocket
    ( d+ E4 K- x- p3 s
45.     function onError(event){
    9 p. l: p: z  x8 x4 }" i& a
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    % C7 I0 G4 ], Z: v. e' `
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    7 u/ z$ V$ `8 w! y. ]0 O
50.     function onOpen(event){
    9 K- _$ p2 W; V9 G  v) s! h( ~$ q
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    - V' O8 \. b& y+ c8 W
55.         console.log("onMessage");
    8 A* k5 }+ J: e+ V4 s) H
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    / z) o, X0 Q* ~2 u+ J) S  w
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    # J& M' r: I" O
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    5 R) g& w: p3 @( x8 D0 U9 ?, k, \, z$ j5 e
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    
70. 
    % n' b8 V$ ]5 S/ ]
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    5 `" L5 j3 _6 X; D! O1 R
74.         var msg = document.getElementById('text').value;
    " c6 V6 a- b( U7 X  d# V8 a% \& o
75.         document.getElementById('text').value = '';
    * N, @5 c) [1 ^7 u% s! L. G/ L
76.         console.log("send:"+sockState());
    " n7 g: h6 {4 a: k! r
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    - [5 @3 {4 n) a5 o3 X9 }! O0 G9 }
80.     };
    1 t* K+ I& s9 K6 ?! O
81. 
    + H4 Z! ?  \6 J1 n5 b9 n
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    ' W, B3 N4 S) S
85. </script>
    
86. </body>
    
87. </html>

复制代码

0 x2 |  A* A* ]* `& X7 g9 \