php实现websocket实时消息推送

admin

php实现websocket实时消息推送
* o8 C" y3 f( k4 s9 G

7 [( J, V# }, K% [2 sSocketService.php
  V0 X- j+ L- d: ?6 M& R

1. <?php
   ; [* I- D# T4 B* m2 J' T4 ~5 S
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   $ ?- {3 c% b, {8 P/ \0 _' F: v& \
6. */
   
7. 
   3 j$ Y: r4 D, w* ?6 e  S% b
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    " W- j  h8 B8 b- Y, b
13.     public function __construct($address = '', $port='')
    
14.     {
    8 C1 A& E8 a# I# e8 l: \" d
15.             if(!empty($address)){
    * i# U7 O& v6 Z3 D+ n
16.                 $this->address = $address;
    0 y7 a9 [5 F+ a# n3 m
17.             }
    
18.             if(!empty($port)) {
    & |# ], V5 ?1 o; t! [
19.                 $this->port = $port;
    & l; E* n* l5 J, i% y
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    + y- d3 i. A2 e
24.         //获取tcp协议号码。
    / l* T$ O: A( o9 V1 q
25.         $tcp = getprotobyname("tcp");
    7 i) R0 Y$ I0 b8 V5 M
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");
    7 o8 n, w5 |2 m- \# {+ }# R
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    : k; P* S1 o3 t' W# {
38.     public function run(){
    5 G! S# }( W% p: U( i
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    5 s5 G6 O2 ^" V: y& W" {9 V4 Z
42.             $changes = $clients;
    2 ^2 F3 F! c3 n; K
43.             $write = NULL;
    
44.             $except = NULL;
    " u! V# b, P0 ?
45.             socket_select($changes,  $write,  $except, NULL);
    * }4 T+ ~3 |6 N! U, K
46.             foreach ($changes as $key => $_sock){
    , F/ l& C8 z/ m, Q9 D
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    % o9 ~3 D4 ^1 r2 i2 L
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    6 l3 ?; s2 t& o, \% M
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    . T* O% j$ X3 ]* |* G' O
52.                     $this->handshaking($newClient, $line);
    1 z7 ]8 v( _$ \. o
53.                     //获取client ip
    7 t( E* g8 h! h: c
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
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.                     //在这里业务代码
    * n- e( C' o' i) X3 B" l. R  ]" }
62.                     echo "{$key} clinet msg:",$msg,"\n";
    # N# k0 C4 _9 t1 h. b$ F
63.                     fwrite(STDOUT, 'Please input a argument:');
    9 P0 V6 e: m  @" Y, b0 G; e
64.                     $response = trim(fgets(STDIN));
    4 F* n1 k/ ]( F8 b  A8 y
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    ! t0 h5 [5 H" W' a- @2 ^3 o( t
68.             }
    ) j! \0 Q5 f& X6 ^
69.         }
    : i  U+ d7 h0 J; s
70.     }
    ) J* I1 M! y0 t% h1 p2 c" d
71. 
    
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    + `1 E( l7 b9 s: k/ s7 g
76.      */
    # E5 u- s& L0 v, @' ]' P7 Q, t0 s! u
77.     public function handshaking($newClient, $line){
    
78. 
    + o! F$ I6 J6 G. M
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    & W2 R: B. D8 z
82.         {
    
83.             $line = chop($line);
    4 i9 z. [% t1 n3 Y+ D$ Y
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    7 n0 D; ^- h9 A+ g: {
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    * v: L" X4 ]1 |7 t/ y. ~& S
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    6 ?$ O* ~8 a% [6 e% k
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    1 y0 z* a9 E  {" k* T7 t+ g
92.             "Upgrade: websocket\r\n" .
    + J4 s9 s  C* Z6 Y* T0 d2 _
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    6 n( A* g+ c8 \: u8 p
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    4 b4 B. k7 H) d& z+ I, v
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    ; F0 `0 W, h+ r- G: B' W
98.     }
    3 S+ h9 S0 O% [
99. 
    
100.     /**
     ( C  }  Q$ y! t/ _8 P% \. r
101.      * 解析接收数据
     1 q. p9 N. p6 Z) _8 N$ ~4 D3 g1 U
102.      * @param $buffer
     ( z9 A# U0 o8 U9 ^! }
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     ( ]* p' J- Z7 w, a0 S  a
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     0 w/ v* @9 u5 u5 y3 ?  [
108.         if ($len === 126)  {
     1 q2 m9 l6 d5 D' H7 n
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     - ]( x* a) T2 |( p6 T! l8 @( ~
111.         } else if ($len === 127)  {
     * o6 d1 G3 |# I& R( r
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     ) E. Y8 [4 x% ^
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     " U. w) y" H! Q: y" Y3 _
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     6 T( ~  ?- l, M# Q! |$ v& G0 x
120.         }
     4 ~, T2 x5 i. h: ~8 x8 [" L- b% O
121.         return $decoded;
     
122.     }
     
123. 
     ! w: ]( ~( m) B# A" B) n  x
124.     /**
     ; u: ^5 ]. {1 K8 z7 n9 L. p
125.      * 发送数据
       J% C! J2 [* Q- l5 w0 n; R
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     # {  N& ]" V1 y  i
129.      */
     : K5 x- h- S; r# Y6 \4 G: M: J
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     
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];
       m, _8 X! k9 n( R" n: u/ m
139.         }
     * x2 B- |  D% |2 P. \7 g* Z0 b
140.         $ns = "";
     + \$ K3 Q0 [) B% k+ i5 x
141.         foreach ($a as $o) {
     0 P/ X4 \  S/ K
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     6 h( y7 G6 A8 Y4 f& I
144.         return $ns;
     
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     9 N/ f2 Z& K2 j( y) e# [$ N
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     $ |5 x) }* T' ]
152.     }
     
153. }
     , k  T$ t2 {/ |) l( J
154. 
     % A' t; Y" M/ w
155. $sock = new SocketService();
     ! y& Z) z* ~- o( ^% A4 V6 |  p
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
   : ?, H8 H3 o/ r: C) E9 s7 |
2. <html lang="en">
   
3. <head>
   & [2 ^8 t; b  t
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   3 D# b0 P" z4 Z
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    ( u2 n6 k! K. @! |/ l
12. <div id="msg"></div>
    ' @; b& t  ]& H5 |
13. <script>
    # y& C! Y$ e. H. G" _* ~8 k7 ^' F$ U
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    0 k- J! G+ B, e0 v5 Q
17. 2：正在关闭
    * Q" O& [: y; o
18. 3：连接已关闭或无法打开
    & \% t6 l) n8 a4 e
19. */
    6 F; |$ ]2 x, C% C/ G6 k
20. 
    
21.     //创建一个webSocket 实例
    3 L% u' J. ^$ W2 D' N
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    $ K* u, S1 R/ y9 h* k
25.     webSocket.onerror = function (event){
    " D6 ]2 L% E# ~! @5 {' _; X; ^
26.         onError(event);
    
27.     };
    . T4 A! p( z# n+ ~  s/ s1 E
28. 
    1 \# C5 k1 e% k2 ]
29.     // 打开websocket
    3 a: F2 {* M% T. e
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    4 f7 l0 _* j* ?' w+ F- m3 L2 x; ~
36.         onMessage(event);
    
37.     };
    
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    1 ?, W; K( [* s8 g+ P  D2 p% ?: v2 t
42.     }
    , o) I6 ^( M# k' k7 d+ U4 Y8 Y& P
43. 
    # v. [- p5 g( U. r. w
44.     //关闭监听websocket
    3 U" b. L( t2 p1 i7 w
45.     function onError(event){
      ?2 n* f9 P4 C' K
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
      Y! _3 h$ L# M% }# L: k* j
48.     };
    
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    1 G2 Z# k  C% D! ~, A, w
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    4 H/ L" v* o7 \' [
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    & b( g0 W0 a# H1 G
61.         console.log("close:"+sockState());
    $ r( i. ?. b4 x" M
62.         webSocket.close();
    & Z9 Q  B1 {7 p& G, Y! D
63.     }
    ( \3 h9 o1 y2 o% p
64. 
    ; [$ _) C" Q, R/ K, r# o+ k
65.     function sockState(){
    ( w$ _  ~7 M& N+ W3 F3 r
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    3 f) a7 Y$ e8 m1 R1 R
67.             return status[webSocket.readyState];
    * ?5 s; }# K& G2 [
68.     }
    % V* c8 @3 z- `! s9 P
69. 
    ; C2 |& _! R: b+ m9 y9 I5 @; ]
70. 
    ' Q* z4 a$ f' j, R' V
71. 
      [3 n2 g4 c4 }) l& Q
72. function start(event){
    
73.         console.log(webSocket);
    . t1 Y+ s  X1 e* D1 Z& w: }  ]
74.         var msg = document.getElementById('text').value;
    ' b" }/ N( O4 m
75.         document.getElementById('text').value = '';
    ; T; |% [  M: s  Q& a
76.         console.log("send:"+sockState());
    2 e3 q1 C1 H9 d
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    ; j" E6 j8 @( T( E
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    4 {0 X  K  Z1 @
84.     }
    4 v4 Q- }( e( A4 F  N/ }3 z
85. </script>
    
86. </body>
    . Y' e1 X) o& K1 O$ j8 w) J1 e# C: O$ C
87. </html>

复制代码

3 L4 E4 c  }2 u9 _9 |7 y* Y$ j