php实现websocket实时消息推送

admin

php实现websocket实时消息推送
) {/ `/ H- L( J  J1 m
! X2 X2 F4 ?' Y" C; W
SocketService.php
* h8 x) |4 c. F

1. <?php
   $ |1 x( y) k5 ^
2. /**
   ! T2 V( z* U4 r; t) |
3. * Created by xwx
   2 l- A0 q2 g" g9 n- \/ z, r
4. * Date: 2017/10/18
   
5. * Time: 14:33
     ~# }- H; g- D  `' \3 F
6. */
   
7. 
   3 S/ G* x3 y4 K9 Q; T7 t
8. class SocketService
   
9. {
   " O, v$ ?- h7 ?; {) C+ M, G
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    7 I* F( T" [- y/ L
14.     {
    , T! e/ Y0 p5 K& V
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    1 C" ]" f- j3 b! N7 y7 c6 J( j
17.             }
    
18.             if(!empty($port)) {
    $ W  \* P6 j5 t5 {8 E0 J2 O2 x
19.                 $this->port = $port;
    ; i' h$ p0 B/ u. n& }+ {
20.             }
    
21.     }
    + m& D6 x+ n8 D. u
22. 
    ( {, \4 C5 V, w
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);
    
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    ! N; V7 p# B, J+ f$ ?! Z% Q
32.         socket_bind($sock, $this->address, $this->port);
    # v6 r3 ?' e+ O+ ?5 h( Y7 j
33.         socket_listen($sock, $this->port);
    ; K& V0 y+ C  a& u
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    7 b* ~" G* W5 {; F' @$ l: Y
36.     }
      A3 t9 d! \7 A  G9 l
37. 
    / ?- h8 x6 Y1 k7 z( ~: l# G+ b. E
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
      k* m% C/ k* z5 U& r. {, C
42.             $changes = $clients;
    8 }* R/ N& R# n( S8 ]' {0 c
43.             $write = NULL;
    9 T7 ^+ D& A- C6 Q$ y: u
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    ) t; n9 a7 a# ?; S9 U
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    9 _# F4 ]* {7 S5 b1 d8 u) P( ]
48.                     if(($newClient = socket_accept($_sock))  === false){
    + d& W& F3 X% q3 Z/ _& q
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    + r: k, ]$ ?' n/ Z3 G( v
50.                     }
    " N9 J  h# O5 M% S' S& p2 f
51.                     $line = trim(socket_read($newClient, 1024));
    / X9 Y2 C7 S2 O3 S* x) U5 s
52.                     $this->handshaking($newClient, $line);
    ' ^: Q+ g0 Q4 R' K& r/ b  ?
53.                     //获取client ip
    + w( u# C$ p- W) Q+ _
54.                     socket_getpeername ($newClient, $ip);
    : R5 Q( r- v3 m7 i! f
55.                     $clients[$ip] = $newClient;
    8 f  P) A9 `7 Y% l9 d9 ?
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);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    " [! h* `5 r0 \# `
64.                     $response = trim(fgets(STDIN));
    : l0 u2 K" ^1 X; z* c9 `
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    0 q# f$ ~+ C4 @9 e* A0 W
67.                 }
    
68.             }
    
69.         }
    4 n9 T6 S( v' s
70.     }
    * ^2 ?0 f% o5 R- P; j& \8 l# V6 ~
71. 
    7 j+ x/ r/ @& O* Y  l! d: `) {
72.     /**
    0 l2 t8 ?" k7 X' P
73.      * 握手处理
    - L, ?8 J: ]' Y& l& N
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    6 A; U4 ]# \4 ], V5 F& i" \% K
76.      */
    8 E8 ^$ Y% z" f5 z  M, ?/ z
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    8 Z& ^! _& l8 K7 b
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    6 r6 l) t+ t) @: K
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    7 C! e+ A# L+ s4 D; k4 a/ h
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" .
    8 q3 g/ Q& _+ D
92.             "Upgrade: websocket\r\n" .
    ) q" X/ |, r% d1 e
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));
    ( B* r' f; C. s
98.     }
    
99. 
    
100.     /**
     
101.      * 解析接收数据
     6 b9 M3 k* ?1 T- q. [) r
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     / _0 f% E# I# \/ T- G1 c" G) K
105.     public function message($buffer){
     3 c% z" o9 a# \0 k+ o" P0 p
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     8 e0 A1 M. H- \& n# ~* {: H
108.         if ($len === 126)  {
     9 t( W' u# o+ E6 ?. U
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     4 f1 K7 H0 Y& \" [4 y2 f
112.             $masks = substr($buffer, 10, 4);
     ( ?; h4 \! R3 X) T- o6 W
113.             $data = substr($buffer, 14);
     9 P' y% z1 S0 V$ h
114.         } else  {
     5 W) |# J; U  |* C2 @
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     + M& t+ `( A$ k! R
121.         return $decoded;
     : I/ a1 h( C& D) T& w( b1 b
122.     }
     8 l/ |5 c5 |8 s0 t8 J" i- ]
123. 
     
124.     /**
     " P2 f# `5 O2 {0 h$ l* k* ~
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     7 z- h; a$ v" Q, [; v8 y" o5 y* Q
127.      * @param $msg   要发送的数据
     2 f, b3 O( V5 r( T; Y' o) e
128.      * @return int|string
     $ z0 M4 ^1 R. r5 r1 f
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     1 ?% S" {0 h6 d% M0 ]4 t; ~- t+ v( q
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     ; h) G# S% ^+ v$ g2 B9 ]6 Q& X
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     # V. L+ J. N8 @4 g
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     & ?8 d4 I9 ~, G& q
139.         }
     
140.         $ns = "";
     5 [+ U' U3 W/ b
141.         foreach ($a as $o) {
       T$ s6 Y0 M0 j5 F# Q; Y
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     , \# n0 g& v$ a3 I& a; u0 f
143.         }
     % W8 h( L6 n& ~# N2 l4 s
144.         return $ns;
     ' |$ h. m% m" h' O: Z# \! B( E
145.     }
     8 q6 u1 f1 M$ h( i1 g( r' P
146. 
     
147.     /**
     
148.      * 关闭socket
     ) x1 H) V, z1 V# f/ |
149.      */
     7 s+ Q+ _1 j- O/ k) \
150.     public function close(){
       m' A- i: W7 n- Y" q5 P: w8 N/ W
151.         return socket_close($this->_sockets);
     4 N( z9 Q+ C- U, l
152.     }
     
153. }
     
154. 
     ) f. l9 F. b) _9 e' O3 v7 _
155. $sock = new SocketService();
     
156. $sock->run();
     4 m) j% g! g0 s8 p
157. 
     8 j; y5 E  c& u

复制代码

web.html
) v% O5 f, n. n) o& l1 S  y

1. <!doctype html>
   
2. <html lang="en">
   ; K+ C8 z7 U  [
3. <head>
   
4.   <meta charset="UTF-8">
   * E8 z- V3 Y) a  {7 y7 U* e: Q* t0 z. F
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   2 j8 g6 B; \3 T* ^' A
7. </head>
   * k  _6 L, h0 R
8. <body>
     t( W$ G3 P, f6 {
9. <input id="text" value="">
   ; U% k& o  `; [" \1 v
10. <input type="submit" value="send" onclick="start()">
    5 q, {* Q$ F/ D
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    + y& @' M% m5 M* U8 g- W7 ~
16. 1：连接成功，可通讯
    . s/ s% ]. [3 M) q. F- }
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    8 {5 g% L  j, l+ h/ B* V8 z7 ^4 B
19. */
    ' Y4 a! g7 D  p$ y; |
20. 
    ) M0 T; H" c& B4 @, x, h3 P
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    7 i  x! ]! t% C) p6 ?' @1 q
24. 
    
25.     webSocket.onerror = function (event){
    $ y2 y8 [. Y! o
26.         onError(event);
    ' ^0 E" O4 p5 T0 U) Y5 @8 ^% ^2 }
27.     };
    
28. 
    
29.     // 打开websocket
    ; Z* h: {  H& z+ I4 N2 y
30.     webSocket.onopen = function (event){
    & s0 @9 w# @% \# b2 }
31.         onOpen(event);
    , W9 J* j. ~8 c. j
32.     };
    
33. 
    " M; k' C% `# }2 o; ~
34.     //监听消息
    7 z* ]5 C& d, G9 e
35.     webSocket.onmessage = function (event){
    . W2 B: D7 b5 l9 N9 W- \$ j4 z
36.         onMessage(event);
    
37.     };
    $ a6 y& j; n, }0 F
38. 
    3 T5 ~8 b0 ~- M
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    8 D' v. r. [6 [' O1 {/ m
42.     }
    
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    1 u1 Y1 H) \; o; i) {
48.     };
    
49. 
    
50.     function onOpen(event){
    ; K' p5 @( V, I5 W3 @; C
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    * y: `1 ?5 C: I
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    % y# p0 v2 `. O  s. l
58. 
    5 C, V8 A9 [7 q: z% |! ]$ z
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    8 L; d5 g; ~4 M" _$ ^
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    4 u. U) W% C' ^2 R# @! ]8 }
63.     }
      f! N1 J9 }* X& y
64. 
    4 M+ D6 B$ j& [* K- c
65.     function sockState(){
    - @7 D" E* s, w  G8 T1 t4 C
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    # H8 v1 A) o' Q( i( }/ O
69. 
    
70. 
    . c) f: O3 D0 j9 M+ L
71. 
    
72. function start(event){
    % b7 K' f5 ~. P" f7 f5 L
73.         console.log(webSocket);
      N! E2 P6 K  m/ D6 T9 w
74.         var msg = document.getElementById('text').value;
      U- r8 G" h9 O2 }7 b# G  V
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    * m) V- K6 ?1 h/ ?
77.         console.log("msg="+msg);
    0 ]9 b# t$ R$ e0 z# T
78.         webSocket.send("msg="+msg);
    # X  R. J. b9 \, e. L
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    ; G! n$ A& j' B: b" \
80.     };
    
81. 
    # {! W5 X0 \; ]; |9 `# H9 j5 ?% ?
82.     function close(event){
    
83.         webSocket.close();
    + C" @& A; o3 Z0 m* J; `3 w- U
84.     }
    * y) z) _  D7 u3 `$ A3 P6 ^, l
85. </script>
    + o8 m9 j* A2 M8 P, a
86. </body>
    & L/ T2 O2 I% R, E  h# r5 V0 W
87. </html>

复制代码

5 h; g$ F/ n  S1 e6 V: j

1 A: a- @2 Z) w; i% i6 a