php实现websocket实时消息推送

admin

php实现websocket实时消息推送
' X7 U4 ]3 j% A) e" }: e. r2 f3 u

SocketService.php
7 Q- V7 a' u0 f+ ?& i

1. <?php
   . L' u' E) W0 x+ J1 b$ m- \  |8 f
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   ' Z3 H: G- w9 C9 u, ^9 M! }
5. * Time: 14:33
   
6. */
   
7. 
   4 r& S+ D- M4 Q
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    8 ^8 a! O5 t7 X; b* N  \+ e
14.     {
    & E  a" U# ~$ f. m9 w
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    9 G) q- h6 S8 Z# J+ L+ o
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    8 r# C  A( m- Z* e# _
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    + M7 R1 m2 Y! [& d* M4 U
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    2 I7 w. h* J0 C+ j
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    6 C6 J' k, W; `( N$ {
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    * l( O$ A2 O2 Q" m8 R# P( K
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    
38.     public function run(){
    5 w3 }' T# e- e8 F/ o3 v
39.         $this->service();
    0 W7 V' X# J# w% K
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    # g6 o  }1 ^7 o! ^7 ^
44.             $except = NULL;
    # d2 x8 B0 d/ C% Z/ w8 @# n3 t( r
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    7 o: }* H; A/ b$ P( z
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    7 P# Q! b1 U8 k0 U2 |5 K
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    # s# \8 z0 J% l1 {' S# N
53.                     //获取client ip
    # Q2 G- N( L. M  p+ r$ Y- H
54.                     socket_getpeername ($newClient, $ip);
    ; r' Q7 A% \, W& p" d1 {
55.                     $clients[$ip] = $newClient;
    ( [4 }2 g6 e3 c& ^5 H6 x* S
56.                     echo  "Client ip:{$ip}   \n";
    5 K$ ~$ G# W5 s( f( @8 ^
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    9 W1 T$ v  S5 W; x2 m6 H
59.                     socket_recv($_sock, $buffer,  2048, 0);
    2 `) Y2 c+ ^" ^6 n- ?
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    7 ~+ P- m6 r! P/ x
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    & {4 n3 w1 k2 ^  |! N
66.                     echo "{$key} response to Client:".$response,"\n";
    6 V9 W* S4 k3 _1 ^. m# a! X7 x) D
67.                 }
    
68.             }
    
69.         }
    
70.     }
    $ ~, B3 |: C! Z9 V
71. 
    . |) ~+ {9 R1 K% {6 t% @
72.     /**
    ) Q, y  M, [, r, C1 z
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    1 \* T1 I) z; |4 @
76.      */
    
77.     public function handshaking($newClient, $line){
    . M/ |4 D2 ?; b0 l9 V
78. 
    
79.         $headers = array();
    & r; n" Z  S# R& f7 a# y
80.         $lines = preg_split("/\r\n/", $line);
    
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];
    + A& q  x& A& A, {3 ]: X
87.             }
    1 _) T$ o* \6 ^" a2 b% M& K# g
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    / @! \$ U1 [# t. D1 R6 C& O
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    ; j8 i$ q5 K6 w5 i& n/ U9 @
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    2 _) s+ d+ E7 }
92.             "Upgrade: websocket\r\n" .
    - L# L) l8 A' L2 B
93.             "Connection: Upgrade\r\n" .
    2 p" f1 A1 A" ~- v) Y0 i
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    ; H4 y/ E: j" g% G  ]0 R
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    : |; e7 S" s8 P9 l, z7 f
98.     }
    
99. 
    
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     8 X7 T3 c3 {4 d8 R
104.      */
     ' Z5 C9 U( }6 J% F4 ?; G4 Y
105.     public function message($buffer){
     " C8 |9 u0 [, e+ R
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     8 v9 R% y$ t7 ?3 N0 T6 f
108.         if ($len === 126)  {
     % }* ]' E: e8 I9 J) g
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     5 c; ]* L, m* }- `. D7 n0 ~
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     ' v( N: L0 o$ K* p5 m
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     ) F" `2 |+ J6 o$ }0 ^
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     6 w" ~2 O- }$ i% f/ @# e  N
120.         }
     
121.         return $decoded;
     
122.     }
     / x+ [7 l$ J/ ]; x  X9 [+ L# ?
123. 
     
124.     /**
     ( j6 f( O  B, P7 Q$ }
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     ! c: N# x$ f( L% D# C  N" q
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     6 D3 C  w# K: w" T  K
129.      */
     % |  s% M* r. T7 S* B" `
130.     public function send($newClinet, $msg){
     5 Q$ \/ U  W# w3 _- n  k, |. O
131.         $msg = $this->frame($msg);
     5 u  T* u' m9 w8 o' {+ w
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     ' n+ O# U2 u8 P: @+ R) A6 q
134. 
     
135.     public function frame($s) {
     9 }) t! V0 [: w8 u2 U
136.         $a = str_split($s, 125);
     & x" W$ E# L& A+ u; k, q6 j
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     ; d+ Y+ d! g- @7 S/ g+ w
139.         }
     6 D' o0 o: Z5 U) `% r4 M
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     + L# n( g/ x- e9 K, E5 I# E
143.         }
     
144.         return $ns;
     ( D" S: g& k- R+ g/ d; \( D2 e2 f
145.     }
     9 s' y8 u8 O7 A+ q4 Q( t
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     ) E: Y) Q' e  D2 i8 H1 d
151.         return socket_close($this->_sockets);
     
152.     }
     ( A9 W/ q& m+ K: ?
153. }
     " {: L3 ~! S/ I0 Y5 N2 P  s
154. 
     
155. $sock = new SocketService();
     + O* [$ x( Y, t* p! h, S. O
156. $sock->run();
     3 p" b- o1 S) m# K/ Y
157. 
     5 f# v! W0 e* c$ c5 h

复制代码

web.html
, K9 u, V7 ?& k* [1 B' o  [5 L

1. <!doctype html>
   
2. <html lang="en">
   
3. <head>
   
4.   <meta charset="UTF-8">
   & A. b6 U0 Z5 _, c0 P  @! N
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   ' ?& s& v. @4 v, o9 a( h& U
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    7 b( V8 W+ d! y% m( V
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    - T3 m6 l0 X$ O: ?! m
13. <script>
    
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    * @  [3 Z7 I1 G
18. 3：连接已关闭或无法打开
    
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    ' ]: W- J6 {) ?" u; U& j
23. 
    * V# u' ]# W& Y3 O. n( t  `# O5 `
24. 
    
25.     webSocket.onerror = function (event){
      P; x9 |' N. @; d) n& ~: b
26.         onError(event);
    
27.     };
    
28. 
    ) @% q- ^# X. b! K+ z, P5 r
29.     // 打开websocket
    , N& |9 P" ^4 n! Y# `
30.     webSocket.onopen = function (event){
    6 a1 P5 C' t$ E6 w2 c8 Q
31.         onOpen(event);
    , S: z  O  I3 c
32.     };
    5 E4 m8 r8 B+ H3 l( R) f6 Y
33. 
    
34.     //监听消息
    ( f, v0 y" U. e
35.     webSocket.onmessage = function (event){
    + r; h2 r( g' k" G2 l! h! f7 ?
36.         onMessage(event);
    3 o; f, ]4 O' Y% Z
37.     };
    
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    4 ~( e! u  `2 P7 X0 j2 m: W# k
42.     }
    + _  r* L) h  Y- e
43. 
    0 v, \* q8 n; v: S6 }, w
44.     //关闭监听websocket
    * @- n! T( ?" l+ G" m) n3 O$ f6 ]' ]
45.     function onError(event){
    , t( u: I8 \8 z: g  d$ o$ {  o3 ]
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    : g- A, s% x# a) R+ i% p$ h
47.         console.log("error"+event.data);
    
48.     };
    ' [. k! B2 l; f1 E0 j3 X
49. 
    # J& d; |+ M* W! A
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    0 L. H+ T- h+ u4 @# Q
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    + Y- w' \: A! Q* n6 a6 Q7 |2 ~
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
      @7 [* d6 W1 G/ v+ i
57.     };
    9 w/ l+ ^  W! m3 z( s
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ! G8 ?) K0 y) u! F( W5 f
61.         console.log("close:"+sockState());
    ) T; y' [/ w1 x& s% X' \
62.         webSocket.close();
    ) M2 T$ A) b  k$ }' [" m) G0 {$ S
63.     }
    , z1 N4 l# E# K
64. 
    , ]$ }: t+ m. _& t- R2 c0 e  k+ n/ b
65.     function sockState(){
    - U8 q0 v2 [3 |7 g/ w- d
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    6 k! d% j! c5 d7 k) {2 Z
67.             return status[webSocket.readyState];
    
68.     }
    7 {- }, G/ m+ Z/ q, _
69. 
    
70. 
    
71. 
    ( c) x+ i) N3 ~+ _  p: X, P9 A
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    8 J# f% P, @  E6 V1 W4 t/ ^
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    $ B1 z1 E# C+ R" x; x# b; T0 ?4 ?8 d
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    9 a( p1 h9 P0 I1 c3 V9 P+ S
80.     };
    
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    , E) c+ i( j. O8 L8 \# `# j
85. </script>
    ; Y) F) G. ^  o0 c8 l2 B6 V0 D
86. </body>
    
87. </html>

复制代码

  S; X/ q0 ]1 {' O- y# f$ A& A$ `; l
* _" k5 m7 f, }2 |8 C: e0 c4 \9 `