php实现websocket实时消息推送

admin

php实现websocket实时消息推送
1 Y# B# ]6 ]  T4 O: H( ?
. [! m0 R+ ]; ?8 `
SocketService.php

1. <?php
   
2. /**
   # w) o0 R) M: o' i$ P& I8 b
3. * Created by xwx
   7 p  t5 i5 f: R# M/ X+ G2 x& E
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   + f2 t5 E/ r" W. V- R
7. 
   3 ]% n, T7 Y2 @4 [) o) I, Y
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    1 R" X. T. L' F: W( }
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    / H7 t6 P( ?9 B6 r1 Q0 Q5 F* A
15.             if(!empty($address)){
    # O, F% P2 C: C2 L
16.                 $this->address = $address;
    
17.             }
    : f& e/ s) w, S, y3 }
18.             if(!empty($port)) {
    ' R+ \' o- X: t$ v' C8 z# k5 s
19.                 $this->port = $port;
    
20.             }
    
21.     }
    ! @4 _! [% j2 ?6 F
22. 
    % J5 V! j' Q# ~# z" j
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)
      l- I5 p" q9 X6 e, O" A
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    ! s; I4 ]: e1 w
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    , ~- a1 j) T5 S* F4 g& s- \
41.         while (true){
    
42.             $changes = $clients;
      E7 j. Y, H; m6 ^9 Q9 s
43.             $write = NULL;
    
44.             $except = NULL;
    , K* N6 Q- m2 u9 L: X5 l; |; P" {
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    1 l% }% R$ Q' W& R9 O; m, a
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    + _3 f( Y. o3 {( Q8 X) \" T  E
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    / J' l9 t+ J% d0 d
53.                     //获取client ip
    ; A$ L4 A. g! F8 t- y4 d
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    5 B% |5 f& U% h" K' }+ r
56.                     echo  "Client ip:{$ip}   \n";
    ; Y; {5 Q9 F. T! N4 c$ i
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:');
    ( {, V2 R3 }8 P. W6 @- g
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    ' d; Z6 l1 O0 X
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    
69.         }
    * H" i3 G: x  c* g$ U  I/ X
70.     }
    
71. 
    
72.     /**
    
73.      * 握手处理
    4 Z. l( N$ w: _) U( v/ w4 @
74.      * @param $newClient socket
    0 N( {, f; S+ s
75.      * @return int  接收到的信息
    7 {8 P* @, z/ f$ q5 V: L
76.      */
    " R8 X9 B8 x! B/ E3 \% s0 W
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    $ N6 Y& X& D! D, t8 |. R' H
81.         foreach($lines as $line)
    / [5 B5 A& V  k$ v; ]
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    8 Q5 o' u3 i; D" i1 f" ~  R
86.                 $headers[$matches[1]] = $matches[2];
    ' S5 b+ P9 [& s: q& k* _
87.             }
    ( m5 |6 N5 o5 i% C$ P9 a( a" g
88.         }
    3 C; d0 n$ s3 b
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    1 y4 h$ M5 Z% d
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    5 I9 W1 o% c. V2 R2 B) t5 c, k: o
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    6 r' N+ t  e! p& o: y( ~& F
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    * D# Y) W8 I) m: g1 L/ D8 U
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    + ?/ Q  o2 ~+ U
98.     }
    
99. 
      }3 Q# @$ E" i% G" a. m
100.     /**
     
101.      * 解析接收数据
     9 J4 y' i2 c# j: ?: ^/ C
102.      * @param $buffer
     4 g3 j9 F2 t- |7 @& r& J
103.      * @return null|string
     : s; i" T6 C" g1 [' S7 x! b
104.      */
     $ S6 r# D1 D% G; m' R0 z
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     . p* G5 @9 r3 Y! W- v
109.             $masks = substr($buffer, 4, 4);
     : l1 ^8 C! t% I% M; x; K, J
110.             $data = substr($buffer, 8);
     * x- ^  ?) ~0 r! O  \
111.         } else if ($len === 127)  {
     ( e. f+ E  w' a5 i8 Q
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     3 a0 w0 |( d; Z6 Z1 s& J5 p# Z% D
114.         } else  {
     ; V; F: H  q& i% T- P
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     * Y' b$ k8 a+ a  x1 P( y
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     ( Z! w$ t3 R- D& G9 V1 E  |
127.      * @param $msg   要发送的数据
     0 J/ q& O, r+ V& C/ p" [: [
128.      * @return int|string
     ) F/ z6 Y  M7 q" w" {
129.      */
     8 Z3 t% y- _2 f( u, m- P3 T
130.     public function send($newClinet, $msg){
     ) e4 c3 I# x, ?# C8 |+ _( x. T
131.         $msg = $this->frame($msg);
     * T  k$ c) S& A( x, p
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     - B- S0 G) B2 f' V; u% i0 ~
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     6 Q) v7 o  A2 H1 p& h! p. p  D1 n
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
       o( I, c4 U# g( `: f7 E* J
139.         }
     
140.         $ns = "";
     & w0 v7 _6 m0 q3 a8 Y, ^( u0 Z8 X
141.         foreach ($a as $o) {
     & }( |' B; ^# N$ ^1 ^' z; O
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     3 o$ E$ m2 P9 Z+ \8 B
144.         return $ns;
     
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     6 q8 x' u! D5 ^. p' u
150.     public function close(){
     1 @$ R- N# e+ j/ @
151.         return socket_close($this->_sockets);
     
152.     }
     ( [. s' v: w$ E& j
153. }
     
154. 
     
155. $sock = new SocketService();
     5 p0 d3 d- X8 W; |% V7 [
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   2 M" C6 Y: K- f$ H1 Y3 G, a
3. <head>
   6 M% c! ~. W# J% L* p
4.   <meta charset="UTF-8">
   # n6 {4 k( Z5 `+ W8 `: K
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   ! w0 w9 }0 Z& b1 v5 Y# M) W8 b7 ^4 c
6.   <title>websocket</title>
   0 M4 D# p0 i/ |1 E
7. </head>
   ' |& P3 u' {0 t7 Y, q
8. <body>
   2 \: B6 {$ I: d3 B/ ^
9. <input id="text" value="">
   . f- b! f1 e8 \# ?8 C& A. g
10. <input type="submit" value="send" onclick="start()">
      r  J5 e/ K- f. [! z3 O2 ?
11. <input type="submit" value="close" onclick="close()">
    7 r( m5 E1 u! q) C5 J
12. <div id="msg"></div>
    6 E& a  z2 X6 L( Y$ U. \' {
13. <script>
    # p. J4 ]2 T" x2 {0 @# H4 j2 K$ K1 O7 g
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    " {/ {3 D4 F' `1 l' s! R! F
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    $ S, [" ^; A( ^3 f: U5 e
19. */
    " G* S, e/ V# u4 d0 d+ j
20. 
    " B9 c% x) R8 Z7 n4 q
21.     //创建一个webSocket 实例
    # \; t# L: Y9 C. ]: o6 Q+ s
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    " k9 t: Z3 q& u7 J2 I
23. 
    : a4 q7 j+ d! S+ `1 N7 h" W
24. 
    ) [. L7 Z) Y6 l3 t
25.     webSocket.onerror = function (event){
    + I2 R2 l+ Z6 ?% M
26.         onError(event);
    
27.     };
      _) m& E& z9 w( A5 u
28. 
    ' }+ j- P9 `' N/ r
29.     // 打开websocket
    ) s) r  L/ L& _3 z) T
30.     webSocket.onopen = function (event){
    * Q. X9 g6 A# v" z4 c3 `9 i5 E
31.         onOpen(event);
    0 c" b, L, V& l8 x0 t
32.     };
    5 s+ V% Q4 g, Y6 o, x
33. 
    
34.     //监听消息
    # c4 }0 u6 i" v( e) j. Q
35.     webSocket.onmessage = function (event){
    - V  ~  h, p/ t; n
36.         onMessage(event);
    
37.     };
    4 T1 c: A6 O8 ]; ^
38. 
    6 z- G% p. ?& a6 ?. i; r. b
39. 
    , F7 p% [. U* S1 j* F- X
40.     webSocket.onclose = function (event){
    1 X7 Z8 n" L2 r% d2 M+ {
41.         onClose(event);
    " s/ A+ k" l1 v3 U9 V
42.     }
    ( X3 L9 |  L/ w
43. 
    7 U1 j: w  E& M: J
44.     //关闭监听websocket
    8 q1 k1 I' p4 E: Z" ?' b
45.     function onError(event){
    - d8 c' a+ h( V% v1 z. Y
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    ; V- N6 t% k& l$ z: f$ Z& H# k. A
49. 
    ' w; F+ H3 C  }$ \: W6 m0 l
50.     function onOpen(event){
    , S3 k+ _" m# W% D6 N, E' I7 c$ o
51.         console.log("open:"+sockState());
    ; U8 H0 |+ J& j2 K/ `$ N
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    2 F" D  R% D) W6 v- {
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    ' q( |# b5 e) H# O2 J* o9 n, M. {
57.     };
    
58. 
    ; r* m* `  _; e7 \, Q
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
      O5 Q8 N- S  z6 K. m
61.         console.log("close:"+sockState());
    + ^! [& A  O8 {3 _; |7 ^
62.         webSocket.close();
    
63.     }
    * k1 v- n4 q, s( P  I
64. 
    $ M; S0 K* I1 g5 Z, M2 r! k
65.     function sockState(){
    ' s1 _  S' |: k7 K5 m
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    1 b1 b8 `. i2 a4 I/ _
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    
70. 
    / Q8 v$ y; _/ K! \2 o5 L
71. 
    
72. function start(event){
    0 N* R2 z% x7 I, v+ i6 H3 B, ]
73.         console.log(webSocket);
    : T4 ^3 K$ `/ Q
74.         var msg = document.getElementById('text').value;
    + i  X# ?+ q3 }% R
75.         document.getElementById('text').value = '';
    7 d: i( Y0 e% X' C  F7 v8 G
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    ' H' l9 G( c, B- N$ S
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    ( j$ P, f6 Q8 C3 t  s9 ]
85. </script>
    9 q8 G" y- R: o+ Q% @$ V1 w
86. </body>
    
87. </html>

复制代码

( n$ [$ r( a% W" ~/ w, F, l' ]