php实现websocket实时消息推送

admin

php实现websocket实时消息推送

4 K- n4 [  ^: s; D3 W1 y) w
$ `' J% b+ A+ ~& ]SocketService.php
  `$ `" P4 L: s" ?9 V: Q$ k

1. <?php
   : c- i* Y( N# Q; w) I
2. /**
   3 P. a7 F# R( U, Q! y: a
3. * Created by xwx
   
4. * Date: 2017/10/18
   $ K' X1 p6 |0 p7 a2 Y% K4 x0 \: W
5. * Time: 14:33
   
6. */
   
7. 
   $ \/ _& {/ C2 V' p6 m  d% n& }; i
8. class SocketService
   
9. {
   / F; M9 ?$ w& w' g$ W3 S: B4 s8 J
10.     private $address  = '0.0.0.0';
    % h" i' R! q8 u' W8 S
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    5 l3 S# L& a4 p; M# r2 H7 ]
15.             if(!empty($address)){
    3 T1 J3 H& q6 X6 \3 ?5 F5 A
16.                 $this->address = $address;
      o2 I. \; [( r5 J0 H- R) e2 ^
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    + D7 P- Q  O: n' _: U! K
21.     }
    : Y5 r% Q, k+ X* G
22. 
    4 ^/ {8 n" o: K$ }
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    $ |' Y4 e8 ?) M' V
28.         if($sock < 0)
    8 Q$ @2 ~7 u( R4 U
29.         {
    : `4 ~6 h0 i# d8 ~% f6 j
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    * V6 p8 q5 O0 V: x* C1 ~& `) a$ v
33.         socket_listen($sock, $this->port);
    5 }6 j  G2 c; `+ {  a' w- r+ A
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    4 c' T* @& F5 \8 \
36.     }
    ! d& I; a. C" M9 ^
37. 
    6 i" s) s' y9 @
38.     public function run(){
    
39.         $this->service();
    4 k! F% B# b" P
40.         $clients[] = $this->_sockets;
    , T/ |; W8 w, C+ }! \! [! N
41.         while (true){
    
42.             $changes = $clients;
    # M6 f1 x/ E7 w4 I5 W5 q5 j) ?
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    1 ~6 Q6 Z' H$ [  v' k, A7 f
48.                     if(($newClient = socket_accept($_sock))  === false){
    7 E6 D' |6 O  `% u# b2 i
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    ) `7 A4 O, L5 X
50.                     }
    $ d$ ~, h& r, C
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    9 s/ K6 c: X+ I- W! g
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    + _4 b8 f, h" U; p! N' a
59.                     socket_recv($_sock, $buffer,  2048, 0);
    / P7 J9 Q. {5 @7 C* E
60.                     $msg = $this->message($buffer);
    9 T, B/ Y2 o3 @% u2 h8 f
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    3 y6 ^' H: Q/ I& A5 S9 Z9 _
66.                     echo "{$key} response to Client:".$response,"\n";
    / I: G6 k& ~+ b6 A' v
67.                 }
    ( ?7 p% K# u6 _5 K# T
68.             }
    ( X" m3 U9 X! G4 C( L8 m/ P" O
69.         }
    
70.     }
    # N% H0 Q+ n6 [8 C6 w, p
71. 
    % @/ H4 N8 k1 l# ~/ Z  ^/ F
72.     /**
    
73.      * 握手处理
    ( _7 h3 D  j- M& H" I) T* r
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    1 P( q; A7 |6 H& x7 g# T
78. 
    
79.         $headers = array();
    : N# Y- g9 k4 D% S/ o# r
80.         $lines = preg_split("/\r\n/", $line);
    / s% {. m9 \) X0 U; D( y
81.         foreach($lines as $line)
    : j; e9 [. {/ c
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    1 M7 q: M+ {$ C5 Y9 u3 L
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    1 a7 P" ~; x$ b! S4 u
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    0 P* P7 `' h/ @: M. J+ _& b
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" .
    2 W. V! r  C4 j, l2 r
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    4 K/ G; t8 t4 \# n" c
94.             "WebSocket-Origin: $this->address\r\n" .
    / l" p2 S% I! [4 e# q
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    1 ^- j2 N+ Y! K- N
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    * w2 n( Q$ r3 R6 |4 A( G3 Z
98.     }
    
99. 
    & j0 E: t$ B, a& B9 P3 R
100.     /**
     
101.      * 解析接收数据
     7 i+ v4 Q  ^9 S' t7 [
102.      * @param $buffer
     ' ^2 ?* E. Q$ N6 I) P0 C5 h7 p
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     8 b/ t' D$ u/ _4 R" o
107.         $len = ord($buffer[1]) & 127;
     1 `% h1 d- L+ C
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     / t4 |* t' _7 J, _/ u" S/ d3 {( o
110.             $data = substr($buffer, 8);
     , v3 C; s3 `' K
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     # e1 W8 ^6 N" `
113.             $data = substr($buffer, 14);
     5 E# p; J1 l; x7 v
114.         } else  {
     9 U5 q# o, D8 J4 J2 x# [$ ?4 K
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     " H" P6 _) G8 Z3 U$ G+ i' p3 G- J
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     % x! C, ~% Q+ e, L
120.         }
     9 X( W  g' c+ j0 B
121.         return $decoded;
     
122.     }
     $ f% h  Z0 f- y/ D6 z3 V
123. 
     & A# n9 V( F5 X- L
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     " K1 ?, f3 |' _3 e1 Y
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     ! ?/ ^7 B- Z) ?; W# R7 _
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     4 Y2 z# z8 s5 F0 c) `" D! ?7 k( A% P; l
133.     }
     
134. 
     
135.     public function frame($s) {
     - n1 B( Q4 Q0 k$ s* q: E  f2 j
136.         $a = str_split($s, 125);
     ' z  y7 ]; b, C5 [6 r
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     . j/ ~8 w" B, f
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     - g3 F( z: G2 Y0 F! @
143.         }
     3 L/ P& _6 G# k/ |: j
144.         return $ns;
     9 D# ~& o9 f: J7 t6 q
145.     }
     ) H/ t( n3 l% m7 I. M$ X2 R
146. 
     
147.     /**
     + ~- q6 W  m+ Y; N7 K
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     ' x, _6 ~9 ?  c% {+ [
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     2 ^0 G; D9 }0 {+ e; P, b) i8 ~
154. 
     
155. $sock = new SocketService();
     8 P; S8 E5 Y$ t1 ], r# O
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   - S* |5 K2 l9 s) R
3. <head>
   0 Z) H9 U6 A$ W! E- S$ |
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>
   5 J5 s' i/ ]$ X+ s) J( B
7. </head>
   $ b4 O1 @0 f3 `8 ]  S
8. <body>
   
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
      i4 N! J+ P5 l5 t! G
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    1 k- ^5 S3 Q5 d
13. <script>
    
14. /**
    
15. 0：未连接
    ) I7 ~+ B& D$ B- f/ c
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    
19. */
    ; ]& O% Q! O6 n. F
20. 
    # S" J' \/ a; g% @
21.     //创建一个webSocket 实例
    + l  q1 B1 E- M( p8 _" A" r# F
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    0 `  g  Y" @+ c! ]3 ?/ ^- n, {
23. 
    , H" N& I' t2 p5 a9 q5 F
24. 
    % U! H- g( C* |; n& ?+ l
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    # S/ ?, d2 O. @" [# r
27.     };
    ( g6 L8 S. b  {$ H' b0 g% b7 @
28. 
    
29.     // 打开websocket
    0 K1 A3 j8 `9 o3 l- c% P% N
30.     webSocket.onopen = function (event){
    , V2 E* o' k) B$ c+ w2 I
31.         onOpen(event);
    
32.     };
    + ~% y& B2 s3 q% c3 v* N: x: {
33. 
      D% H' \- B& p: h- J. X5 H+ H
34.     //监听消息
    * C- n! M  z* i0 E
35.     webSocket.onmessage = function (event){
    ; Y2 t/ D0 ^! i$ C' P
36.         onMessage(event);
    . v' h. v1 m- \* [3 y
37.     };
    + C0 ?% g% v2 Q& ?& E2 T7 q" r
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    + b. s3 S4 u, G. d. ]/ ^
41.         onClose(event);
    6 m0 P$ t- v7 v# G9 n+ c: h
42.     }
    
43. 
    
44.     //关闭监听websocket
    0 O, L. F& a+ u+ z2 [  A$ K
45.     function onError(event){
    ! w' U. N2 R& @, M$ f: h
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
      l4 t' o- i! Y
47.         console.log("error"+event.data);
    
48.     };
    $ [$ c! c# i% k3 E* [2 ?1 u& ?( T
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    ) D5 v8 q) o- N7 z. ?( b
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    - F2 c% C1 g2 u& |! ?% e
55.         console.log("onMessage");
    * z6 |. ~% j5 J# V
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    - K2 L1 S1 u4 r4 b( }/ u. b; Z8 p5 L
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    + N6 W1 s9 I% j2 P; Q7 q
61.         console.log("close:"+sockState());
    ) O$ g9 }4 P5 L  p! O, W: W: ]
62.         webSocket.close();
    # A% k5 U0 J* K$ d# L3 Q( z
63.     }
    # y. U9 Y; B7 B0 V
64. 
    + ?& V. U& B/ Y) V  i7 W: A9 M0 G/ x
65.     function sockState(){
    ) a0 |5 [) E# q/ ~8 N" x- P
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    + H; R: z4 T! ]/ I
67.             return status[webSocket.readyState];
    
68.     }
    ' ~3 v# a1 m+ H/ H. A/ U7 P
69. 
    
70. 
    
71. 
    
72. function start(event){
    9 ?0 w6 d" Q$ N4 q$ T
73.         console.log(webSocket);
    7 f  Q7 |/ [7 Y% ~
74.         var msg = document.getElementById('text').value;
    8 }. ^, f# v  V6 v! l7 @, v& H
75.         document.getElementById('text').value = '';
    9 ~# d7 A+ d  \
76.         console.log("send:"+sockState());
    ; f, ]2 ]9 @7 f! r$ f. e
77.         console.log("msg="+msg);
    # l3 z8 W  ~. }  |  c6 l0 F8 Q
78.         webSocket.send("msg="+msg);
    ; P3 u  H& }$ U: U
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
      E- @8 d& s. M' n) E6 o; J$ I
81. 
    & n2 }( l. r8 a/ X; Z9 p' q5 b" q
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    ) t/ |8 F( Z0 H  W( ^0 O. n
85. </script>
    , s2 p2 e6 F9 H0 Z6 l6 }
86. </body>
    
87. </html>

复制代码

: m& c) C+ X& l. ^
+ _* `) I: r5 r& {2 ~: R( a
  v4 a2 b/ O: d9 j