php实现websocket实时消息推送

admin

php实现websocket实时消息推送
4 ~5 v8 p7 ^1 V: v- J/ {

SocketService.php
0 z* X" ]# R, z5 r' R8 n& [

1. <?php
     G! E! w; j8 o: a6 d- b
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   9 [- [" o0 t1 H( n' V' j
5. * Time: 14:33
   * L5 N5 _1 M3 H
6. */
   
7. 
   & ]- H% w6 x, d3 Q" w2 r! Q
8. class SocketService
   0 ]! }& r; j# j+ R% y$ r+ a
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    2 ]5 O: y; U% ?4 n
15.             if(!empty($address)){
    ' B  R# e& Z: J$ b
16.                 $this->address = $address;
    9 H8 o( Y4 `" P% n8 Q2 W' ?
17.             }
    4 E- a: ~, ?( k( E0 i/ X
18.             if(!empty($port)) {
    5 [$ l1 m$ h  O. S
19.                 $this->port = $port;
    : n" D+ I& ]0 t
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    , f2 o. \8 a8 O+ P
24.         //获取tcp协议号码。
    : u0 K7 ?) a! n3 P
25.         $tcp = getprotobyname("tcp");
    , h* P/ j+ p" l7 Y3 |+ p' B
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    & N( y1 G, G8 @& |. R. ~; T
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.         }
      C+ T$ ^8 D( T
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    2 B- y3 J7 {4 b  h
34.         echo "listen on $this->address $this->port ... \n";
      N& h5 [6 S: D. i
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    3 S9 I: P( U' ?) E" m2 Y$ f
38.     public function run(){
    
39.         $this->service();
    ' R( w4 K# o' b
40.         $clients[] = $this->_sockets;
    % T& e! e" l9 w8 @1 e7 m
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    1 Z6 k6 _7 w/ |) D0 r# b/ p
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    % c/ ^3 i+ L  E  ?
50.                     }
    ) y$ g' k; t9 i) y( D- G2 J6 B: \
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    5 Y) V" A0 b, x7 `2 S
54.                     socket_getpeername ($newClient, $ip);
    2 F& ~) _3 u8 C& }3 B9 a7 W/ J. y
55.                     $clients[$ip] = $newClient;
    ) m% y& i! R" ^
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    + r, J, D* I% c7 |1 K" b6 q" ?
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    0 f  Z% q, Z0 k7 j% j
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    - y( Y) M# K& b: J2 X4 N. D4 S7 K
65.                     $this->send($_sock, $response);
    " v( [9 `& l0 B" x6 q8 D% z
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    
69.         }
    ' b& M9 w9 J7 m/ l
70.     }
    
71. 
    
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    % t( A" u* e& r1 T) u
75.      * @return int  接收到的信息
      k' |: h0 g- \- \
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    & @. U2 O/ H3 q. k7 e0 \
79.         $headers = array();
    . b2 B6 t! V* |! t& \4 N' e2 \' t
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    5 z& W) Q2 u0 n; d" ^& o
82.         {
    
83.             $line = chop($line);
      }, D* r: q/ D
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    ! u% _4 G+ m# }4 Y. J* l
85.             {
    * D6 H, L% x1 [+ z- c1 {
86.                 $headers[$matches[1]] = $matches[2];
    - k; m* e# R# w- c0 W4 W
87.             }
    
88.         }
    5 {* Y5 R' L# w5 _" B
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
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" .
    ! K, n+ J; x$ u9 M7 O
93.             "Connection: Upgrade\r\n" .
    . F0 M5 s4 z9 h2 q: l
94.             "WebSocket-Origin: $this->address\r\n" .
    6 o" w' t7 L0 \
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    2 V, J1 c' ?2 K5 V
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    
100.     /**
     
101.      * 解析接收数据
     / @" s9 ^7 P  Z3 j: u% g* m
102.      * @param $buffer
     $ i) K9 I+ q" Q
103.      * @return null|string
     
104.      */
     ! [# i8 p- P* U/ Q
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     ; v( V+ i8 D; w) C  `
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     $ _# y( p. G! t! w: u$ _# C
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     . G; |2 y, G7 O& K$ }
117.         }
     : F. L6 V4 Z& H( I4 F3 I  }' }
118.         for ($index = 0; $index < strlen($data); $index++) {
     - \$ k9 p: {. a' o: s
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     5 c; ]0 I8 E: V$ c% b' H
120.         }
     # i, f  m2 }2 F! d7 N" |; s
121.         return $decoded;
     9 ^% m) ^6 P' K+ |% P" X
122.     }
     + \# n  e3 V6 K  Q5 d* j
123. 
     
124.     /**
       @5 `/ I& d8 I* n
125.      * 发送数据
     9 U) P2 I) n" ~  S
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     7 J9 [" q. d* M
129.      */
     & I' q* k* i  ~- e
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     8 N$ [- l1 m" w. t* ?* R
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     0 {3 W# s8 U" V; E$ O( f
134. 
     
135.     public function frame($s) {
     1 S7 S' M0 [9 }* E$ s! I1 k# w
136.         $a = str_split($s, 125);
     * g2 E3 m3 n+ s+ e3 R3 G7 {2 I' G/ s
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     % \& [. t$ \- X" Z8 p
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     
145.     }
     ; p8 L# @& Y1 r# a9 Y; }3 B7 H5 G
146. 
     5 Q: G$ b$ E8 J
147.     /**
     
148.      * 关闭socket
     
149.      */
     ! N) @. a3 u) b# }  K, Z
150.     public function close(){
     $ `# `- X" L# d% c! _" W& j
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     
154. 
     
155. $sock = new SocketService();
     - o* E  G6 Z, E' `8 }
156. $sock->run();
     7 P! f3 d4 n. g
157. 
     9 l5 w- N% \' B. j  F3 ~: ^8 G) r. s; t

复制代码

web.html

1. <!doctype html>
   - v  g7 H" _* A* a9 o* O. w
2. <html lang="en">
   
3. <head>
   ! \/ I; R5 [, _& z$ l0 W/ {
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>
   ' ?2 a* I: y& R$ E+ o0 E
7. </head>
   $ S+ r. n0 C0 T  c1 S2 T/ P
8. <body>
   5 b% J0 ^- A; T/ g
9. <input id="text" value="">
   - s; c8 B' \, H- I3 _
10. <input type="submit" value="send" onclick="start()">
    0 X" K0 b4 {' _
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    0 e: a& a' I1 I5 L
13. <script>
    6 S1 L* g; k6 ?: f1 `
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    
19. */
    ) j( R% z+ T$ ]( _
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    / n" w; S" B" r: W  G" l4 R
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    5 S) f# ]6 I% B. Q0 ]* K& C
27.     };
    6 M$ ~0 b: i( {7 k
28. 
    % x8 S! |, W2 B
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    5 B  s# q$ W! S; V2 f
31.         onOpen(event);
    
32.     };
    
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    - K$ e1 x. ^: w: P" J
38. 
      I7 g% M7 r" z" A- g
39. 
    % O5 E$ V; r. d6 S3 n
40.     webSocket.onclose = function (event){
    " b% a9 c1 s0 g2 |6 _& S
41.         onClose(event);
    
42.     }
    / r* ^! F; B. L* y" \& F
43. 
    6 N/ P5 D) G4 C& `
44.     //关闭监听websocket
    
45.     function onError(event){
    , c. A; g, i' L  ~, v
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    & V8 q. y+ z" D3 \1 g. g( c9 y
47.         console.log("error"+event.data);
    ) n5 F% @7 z& S
48.     };
    : k- T2 S5 W' r* S, k: b
49. 
    9 A9 R: b  R3 n; }3 D. }
50.     function onOpen(event){
    0 O5 `: A- L) {' I
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    : i# h" u. w4 _5 Z* v- X
53.     };
    & [' h9 g7 Y! X* t* Q9 T6 w/ [
54.     function onMessage(event){
    8 l) U$ {. |+ h$ x$ ?9 H
55.         console.log("onMessage");
    ) F& s. b* \. S/ w8 @
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    ' H( u2 a, T' W! x% @, ^# X$ q
57.     };
    
58. 
      Q7 f$ g/ k; k$ M$ Y
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ; x/ i# _. c$ K% M8 |* q
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    + `9 t1 t* [* F
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    5 ]2 s, l; W* x, O
67.             return status[webSocket.readyState];
    - R1 J, X% D- l& A# T
68.     }
    6 \3 P; w! X" S
69. 
    % A/ V/ b, g: Q: _) |
70. 
    . K8 w' z& y4 M' `+ K
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    * Z2 {, x( W" U  S4 j: y
74.         var msg = document.getElementById('text').value;
    * {, {$ p2 G% {9 @5 I$ c
75.         document.getElementById('text').value = '';
    8 f) A/ M8 D' b3 F+ q' v) f
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    5 ~6 n  H: e% X# o. Y
78.         webSocket.send("msg="+msg);
    2 c- J1 j( O* t4 N: Q/ R
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    * A; z: ?: L7 j: s' R
80.     };
    
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    / C: m$ F) D' V5 b& Q
84.     }
    4 {! S6 Q: J$ a% \1 j
85. </script>
    
86. </body>
    $ e+ i0 y, m+ s5 {2 U
87. </html>

复制代码