php实现websocket实时消息推送

admin

php实现websocket实时消息推送
5 q8 N* y2 Y: Y9 z6 U! k, m! _

: ?7 c+ s' p7 i# l  NSocketService.php

1. <?php
   
2. /**
   7 o6 s7 m9 F9 s
3. * Created by xwx
     j+ z3 t  C! Z6 J+ {6 d- E
4. * Date: 2017/10/18
   : l- l9 J% ~, p* _
5. * Time: 14:33
   
6. */
   5 \6 [: ]( [3 d$ q
7. 
   
8. class SocketService
   ) f* s7 W) N3 w# x1 h' d
9. {
   9 a( Z+ w: f5 ?. u2 y  E+ j
10.     private $address  = '0.0.0.0';
    " U5 R/ W: h( `4 [# ~# E. @6 t7 F
11.     private $port = 8083;
    
12.     private $_sockets;
    , ]3 D: ~7 E0 Z+ `5 H, B/ y
13.     public function __construct($address = '', $port='')
    5 h; @1 H! |$ G6 l6 ^
14.     {
    ; S) X" a5 r" m
15.             if(!empty($address)){
    7 `  {9 t+ W' w. X* J
16.                 $this->address = $address;
    : D. ?+ g' Q& O' u% ?+ }
17.             }
    - D) V2 M1 M" V2 ^
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    # }+ Y/ n+ u8 c; b' H/ _
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    ! g; I# M2 ^9 v$ Z$ ^
24.         //获取tcp协议号码。
    4 ?8 |6 T7 g: e
25.         $tcp = getprotobyname("tcp");
    1 p0 l: B6 T1 N" f- Y
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    4 f" V  U  h8 g/ h' [
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.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    : j' h2 J/ l  w& c# T
33.         socket_listen($sock, $this->port);
    - }: g' ?1 N/ s1 q$ g: L7 V6 H
34.         echo "listen on $this->address $this->port ... \n";
    6 y" N  E: c; L  t+ M* X: \7 @
35.         $this->_sockets = $sock;
    
36.     }
    9 s2 Z- M# u) q3 V5 ~% c8 E* t
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    + d4 N& h  H# i5 X; M
41.         while (true){
    ! u) _& v+ S( M5 b- \- B, [
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    / R" D0 C1 c. W' {
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    ) S3 {# x3 }' d' Z" j: d, {1 |
48.                     if(($newClient = socket_accept($_sock))  === false){
    ) b+ W7 K' J  {. `2 t8 C
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    9 F' b% ?+ B/ M
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    ! y8 P9 A8 c% ]4 h. W  ~$ y! K
52.                     $this->handshaking($newClient, $line);
    ' Y6 R5 b8 \8 B# ]
53.                     //获取client ip
    ( j* i. Y) {2 \7 K7 H0 R( j7 v
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    & s" m1 W2 h3 Q5 B; ?  m* B. T  o
59.                     socket_recv($_sock, $buffer,  2048, 0);
    3 v( |- [$ O5 u1 d" E$ M1 A# ]
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    1 \( I* |( c( @
62.                     echo "{$key} clinet msg:",$msg,"\n";
    1 f- L8 R8 o/ {1 n
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    ) h. P$ E. b& k
66.                     echo "{$key} response to Client:".$response,"\n";
    6 W+ y% w* G% U; |! v4 `" k3 G
67.                 }
    
68.             }
    
69.         }
    ; Z6 F! G1 r( R7 a0 Q( z  e
70.     }
    
71. 
    
72.     /**
    4 G4 R0 j0 ^: w5 n
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    % Y* B6 `9 U) {! G( c2 e3 Q
76.      */
    5 X, X- p5 i2 K, P! z- ~
77.     public function handshaking($newClient, $line){
    
78. 
    ) f1 Q) _) ~, T) n$ T: X4 z/ ]
79.         $headers = array();
    4 `) W: z, w) F8 s0 N0 n
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    # a$ i" s5 r: N) }: q9 g' D# k. N
82.         {
    + Y- S. b- e- M1 I. [
83.             $line = chop($line);
    + ^7 u; }2 r: Y/ t  t* }
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    2 a7 g2 Z9 J# F8 T8 a' Y( {
85.             {
    " Z5 z0 G& J8 Y* D, l  k
86.                 $headers[$matches[1]] = $matches[2];
    ; K2 a: t) E3 H" t' R) R$ b
87.             }
    ' z, W" p7 ?% N1 a4 g
88.         }
    % }, d. t* H+ I8 z$ Q1 I$ Q: c5 J
89.         $secKey = $headers['Sec-WebSocket-Key'];
    ) o5 v" ]1 |# y
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" .
    0 B& W% P. G6 Z3 w0 Q  U
93.             "Connection: Upgrade\r\n" .
      i* R! z2 c2 e2 X, ^
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
      K$ ]# {3 w. l: N4 |1 M, n
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    ) ^  f: ?/ c. W/ W4 q) Q
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    7 F9 h& F7 ^' |6 U
98.     }
    
99. 
    
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     $ v' U4 r( m# ]- {
103.      * @return null|string
     # w- s- r% B" ~) U  q  F* \& i# k
104.      */
     
105.     public function message($buffer){
     % `: s1 r, X4 |- F$ K5 }
106.         $len = $masks = $data = $decoded = null;
     4 s, J0 m9 G. T/ F) Z( _* }
107.         $len = ord($buffer[1]) & 127;
     ( b+ T5 {( s) n" ~  Y
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     # Z) P) g, S% m0 E* P( Y) a
111.         } else if ($len === 127)  {
     ; u( h; L1 O  z' p' l6 c, v! D
112.             $masks = substr($buffer, 10, 4);
     * l7 `. A9 J2 d4 v* t  `3 B
113.             $data = substr($buffer, 14);
     3 ~3 ]* j& q) ^8 S  K
114.         } else  {
     ) I: C4 z* S: k0 e' n" |
115.             $masks = substr($buffer, 2, 4);
     7 j- H" y2 b- L, H/ |
116.             $data = substr($buffer, 6);
     9 n, A; Q% ]! ?# D" f. d) F5 S5 B
117.         }
     & d( X4 [& R- K4 K+ i
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
       \. c$ }' Z- o0 K$ h
121.         return $decoded;
     1 H, m7 [7 y1 J: v! a) A( `
122.     }
     $ }3 }% s, i% ^: H0 e  t* a
123. 
     2 ~0 h% |4 W- |$ @9 q/ I/ Y6 C+ b
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     ( l" P& _( C5 e4 n; Q2 l7 `9 v
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     # z2 @" ~  a+ `9 S+ e1 f
134. 
     9 \! }9 F) g8 C' i. ^; Y5 Q
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     # l0 F3 S) ?# n: Q
139.         }
     
140.         $ns = "";
     + Q9 o+ _1 `2 w1 p4 M4 @
141.         foreach ($a as $o) {
     * `5 f, S( `6 s4 m) D
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     $ S' O7 ]- {$ A/ w) |( G* C7 G5 x
143.         }
     0 p' J. k/ f# @, @+ j" L0 A
144.         return $ns;
     
145.     }
     
146. 
     1 C' Z) \. t, e5 ^
147.     /**
     
148.      * 关闭socket
     ( [/ p. X- c6 _' G2 p0 _
149.      */
     3 K& O. e: D! T# n. g, E. w
150.     public function close(){
     3 ]- c+ s4 [& @4 O
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     : O! {3 a6 k6 R: \8 J$ }: d
154. 
     - J5 {4 j6 ?- N+ J+ R
155. $sock = new SocketService();
     9 Y& v; d9 f0 H0 x" C: o
156. $sock->run();
     
157. 
       S) [; H2 U3 E% n9 I: n1 q

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   
3. <head>
   
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>
   & D9 W, {: ?" _- y+ i
7. </head>
   
8. <body>
   5 U9 p" f+ h( `0 O/ Y  g, T1 z4 k* p
9. <input id="text" value="">
   : j* g; Q1 Q$ u0 i5 X9 t
10. <input type="submit" value="send" onclick="start()">
    ) \. W& K, [% I- R) p! p% D" y- Z
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    - E5 U, v9 `, _
13. <script>
    2 X4 x0 x, o. ^& P2 e+ l
14. /**
    1 _( N- x/ E, R+ e; h4 ]$ q' ^2 e
15. 0：未连接
    : _6 D) }" ~4 n( ]. V/ N
16. 1：连接成功，可通讯
    + P! F! p. @0 }& W% S
17. 2：正在关闭
    / D4 g; e# O3 Y' |; P% r
18. 3：连接已关闭或无法打开
    
19. */
      f& l6 ^  z1 e2 \/ u0 h
20. 
    # E, K3 L/ W0 E( N2 K
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    3 q) \  k2 X, X, y+ i2 p1 P. Z! ?
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    1 k, g7 s0 j8 Y3 }4 ^$ Y" `) N7 f
27.     };
    8 w! t$ }7 ~; X  P: P* a
28. 
    
29.     // 打开websocket
    - a5 A$ M* T9 x  l9 |$ h
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    * z) o; g+ F8 \6 }) I
32.     };
    
33. 
    ( U8 a3 l4 {( C% o  g
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    
39. 
    8 ^3 X" B# |: f
40.     webSocket.onclose = function (event){
    3 i/ F, |4 O# H3 j6 W9 f8 ^% \
41.         onClose(event);
    ' Y" c+ Y5 b0 i- p
42.     }
    " E7 C/ w! k$ F  e0 W
43. 
    1 X3 n( L, J) d+ l& c; Q5 B
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ; T" G. i( w: Z* S$ u; C
47.         console.log("error"+event.data);
    9 m! H6 m7 }3 Z
48.     };
    0 o8 Y; f; T$ G7 W' U, M
49. 
    " U- B  _* N9 L; Q# W( r
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    + f- i( p$ {" L- r4 ?% a
53.     };
    ( Y+ M# ~# g. ^+ e7 J3 @, `1 u
54.     function onMessage(event){
    6 @/ f7 T1 V" p' d& o+ Z. A+ \  q: `
55.         console.log("onMessage");
    ; N4 _: k6 S- `  f; L1 K' s
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    2 G) @( x* p( y1 k
59.     function onClose(event){
    0 |! E3 Q. K6 Y  K. U9 c8 E
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    6 j+ b. G) ]5 L" s
62.         webSocket.close();
    % e7 F' u8 C. {& r5 X+ j
63.     }
    
64. 
    : {( R- Q/ k: f: [7 I
65.     function sockState(){
    ; u9 Z0 V0 B; f
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    . s; X: c% z% M7 i- S
69. 
    
70. 
    
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    # J0 V4 \1 [9 ]" B+ t3 d
75.         document.getElementById('text').value = '';
    ! C& G' }, s# j% }* n1 D: F1 }
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    + E2 g3 j3 k1 }. q! S
78.         webSocket.send("msg="+msg);
    . W- ^; c5 |; h8 [$ l7 x$ v
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    ) v7 I. ^) K6 d
80.     };
    
81. 
    9 t6 L0 }' L( @4 T
82.     function close(event){
    , r0 m) h: z( U( ]& B8 f0 }
83.         webSocket.close();
    0 m2 M& ?6 l4 J$ w, g( V) Y
84.     }
    
85. </script>
    
86. </body>
      ]* {2 g1 N4 V4 D+ M
87. </html>

复制代码

0 F5 M  w6 y: J# c
" y% ]- m5 V; @! [