php实现websocket实时消息推送

admin

php实现websocket实时消息推送


SocketService.php
3 F  [4 r6 L7 }3 w/ n/ m

1. <?php
   
2. /**
   
3. * Created by xwx
   3 y3 ~! s2 _- s* S
4. * Date: 2017/10/18
   3 b3 x$ h( a" a$ d( p* B
5. * Time: 14:33
   
6. */
   1 B" W- p( v- B9 T
7. 
   . U5 \9 A2 L- w( e
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    # L- D0 {$ R. h; i# n- m& C$ p
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    ! e% t7 |, m+ `0 a, Y' G$ w
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    ; w# A. \! Q7 M. I* ?
24.         //获取tcp协议号码。
    , {; S! W) v2 D1 E7 X  T7 @
25.         $tcp = getprotobyname("tcp");
    % ~4 I0 _) y+ Z. e
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    
29.         {
    % b# q  |- F( o5 j$ @" q4 `- n2 i
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    7 u  R/ n6 ~: E# R4 g3 R$ y& r
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    ; q) D( ]' n# K; @
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    3 x/ |' Z! ?$ F- K! y$ b2 X* m) P
38.     public function run(){
    
39.         $this->service();
    ) e: A, _. T/ F
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    ' l$ X4 @6 V. H* z8 u
43.             $write = NULL;
    
44.             $except = NULL;
    
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){
    8 w7 U/ I3 v+ b5 j' X( Y3 C( T
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    . c8 U6 P/ B* w
50.                     }
    % C5 h8 n$ J" q
51.                     $line = trim(socket_read($newClient, 1024));
    " }$ P- }" [% L& I, J
52.                     $this->handshaking($newClient, $line);
    1 Y7 p) \0 f7 J  c3 ]" C; Z
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    2 @& C2 b8 @+ `4 s! B
56.                     echo  "Client ip:{$ip}   \n";
    7 R3 f$ p- M* O
57.                     echo "Client msg:{$line} \n";
    8 @- K" j9 Q% k: m& U# o5 @7 V
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    & D) x. a; J6 w" O& `2 B
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    % w3 h/ b4 @) O# c, f+ K8 D; {& ]
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    ! E: B7 {" E  ?
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    / D$ n3 v2 x4 A
67.                 }
    
68.             }
    
69.         }
    4 [# L  B$ V& t% O- ]
70.     }
    ' c  L, p3 j0 ?8 O4 g0 J
71. 
    
72.     /**
    $ K% M# T+ @4 w' r- b
73.      * 握手处理
    
74.      * @param $newClient socket
    8 i5 {9 D- c! G6 y& `
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    & A1 Z9 L, M3 l1 _
79.         $headers = array();
    + `) Q0 c! f# z! m
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
      H9 l/ g$ D" N
82.         {
    2 K# ?  X7 {5 v; x# N. K
83.             $line = chop($line);
    8 {6 u1 L; v' l" }- a$ L# M: P; ^+ X  w
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    0 E' N5 z8 `: V! T$ J& G0 W7 M  [8 K
86.                 $headers[$matches[1]] = $matches[2];
    ( C; D1 \7 _3 ~4 T: o3 i
87.             }
    
88.         }
    ( S  y* W% E9 E# ?8 m
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    9 a8 q/ j' S$ D8 h3 |! y
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    . V& G" H, e" R- P% ^& ^1 _
92.             "Upgrade: websocket\r\n" .
    
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 G$ `% q- P6 {4 I# [
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    9 Z) X. q) G8 e, V
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    * G; |8 |( Q( ~
100.     /**
     1 I* s0 [. `* q  N
101.      * 解析接收数据
     
102.      * @param $buffer
     # }, J- V! o% A; L4 k
103.      * @return null|string
     5 r' Y2 U  x2 E0 r/ [+ ]
104.      */
     
105.     public function message($buffer){
     ' ]6 l4 }4 U8 X3 M9 D6 Q
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     * G. _" s/ Z$ B) H: ~$ K1 W
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     + x5 b& Z0 m; A
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     / v, U& x4 z( ~  ^. v
113.             $data = substr($buffer, 14);
     
114.         } else  {
     0 I+ I9 w) h4 R- O: K
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     ( H# r" Q# Y7 u
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     - ]8 n2 w8 k! \8 |
121.         return $decoded;
     $ h9 F, s+ W1 ]1 m% n4 n- N# P
122.     }
     
123. 
     
124.     /**
     , x+ o  x/ k0 c
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     # e4 D1 V' |  W  q" f/ o7 D& i6 }
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     * n& V( m) o: X) d
129.      */
     9 }6 I+ T3 T  U
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     " I: w2 Z# Y* t/ s# `3 ^
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     6 o" p' D" I, M9 d
135.     public function frame($s) {
     / z, J2 X2 {" I- O3 t4 u6 W2 R
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     " l! g8 S: p: u! Y% o+ n
139.         }
     
140.         $ns = "";
     : W% V7 p2 v3 k( u
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     % ?* R9 S+ g8 A$ X$ H
144.         return $ns;
     " W1 G: q. R* i/ W9 @, k
145.     }
     
146. 
     7 @6 \2 U3 f  d' e$ f! f5 Q2 `& b% g  s( j
147.     /**
     
148.      * 关闭socket
     
149.      */
     ; I' @& X" I& [% K% C
150.     public function close(){
     " O9 s. I# K* L
151.         return socket_close($this->_sockets);
     ! _, H- l9 w4 I* y
152.     }
     
153. }
     
154. 
     - [6 w3 M$ R) ?: V. F4 ^* i
155. $sock = new SocketService();
     ! H, i' B4 c$ {# n3 p2 v) R* u2 ^
156. $sock->run();
     : m7 F3 ~) d$ t- y3 q
157. 
       l( S& T( _& h  L+ H7 C: z

复制代码

web.html
+ u2 ?6 N2 j0 S  \

1. <!doctype html>
   9 l& i0 ~5 j& y$ s* v, F2 e; M
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>
   3 f- Q; L( e5 a+ m5 A- a' Z% A/ L) S
7. </head>
   7 J- X, A* b) Z. g# [2 L! j! n- Q
8. <body>
   
9. <input id="text" value="">
   8 }( A# Z8 p! X' d) A% o3 b( G
10. <input type="submit" value="send" onclick="start()">
    ! V/ _3 q1 [$ i( f, e2 G
11. <input type="submit" value="close" onclick="close()">
    + T+ Q3 k- {6 @5 w0 Q9 q, [% o' m
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    ( p, Y& p- [5 T: K* a3 I
15. 0：未连接
    1 l% O1 X; h8 Q+ v$ `/ k6 z' y6 l. t# N
16. 1：连接成功，可通讯
    8 ?  Q( r1 l( [+ j$ F: t
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    + j* q8 z2 A/ h7 W
19. */
    2 H4 i; B" c7 G7 j. D
20. 
    7 b  @2 j0 l1 M6 P
21.     //创建一个webSocket 实例
    / J6 L4 P% a" e9 N
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    - ]4 O" v  b6 i  h9 u. U
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    % M4 ^) b! h- K9 N( n: s6 W; r/ |
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    0 H: m6 R9 u6 B& u8 P
36.         onMessage(event);
    * n  I! ^+ @" ?) Y: l$ H
37.     };
    
38. 
    5 G4 U$ [- R# \3 n1 m  k$ M
39. 
    / |1 T+ N! ^4 E4 R- M) u: ^
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    5 K- ]$ p- p1 O& `' }: S
42.     }
    ; U  p- s$ O" A3 E9 u' f( j% L
43. 
    * `5 G' N% q& q6 a
44.     //关闭监听websocket
    - i$ T8 o* a6 X! G' e! w; l7 I
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    8 w$ E3 G0 v, `: {1 C9 o, e; H1 N
47.         console.log("error"+event.data);
    ) A0 W# k. \) q& s1 Z' ]3 x
48.     };
    
49. 
    4 x9 T% z! w. g6 L1 }" O" C2 N) Q
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    8 l$ u2 Q* G5 O. H: C
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    ; W# o) E1 O2 U
54.     function onMessage(event){
    ! n  E  C6 }' e6 J+ D4 V7 f* S
55.         console.log("onMessage");
    1 v. ^7 ~6 S% e' }2 ^6 R9 N
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    0 K4 `% O/ G% V% J6 R: d& {
57.     };
    ) V7 M$ G& R0 x
58. 
    / b. s# w0 O$ Q7 l/ z5 Q
59.     function onClose(event){
    $ P7 G0 ^! u2 h8 d9 c
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    ; N3 c; y4 Z7 a2 k! L" {, @
64. 
    
65.     function sockState(){
    + D$ F5 Q5 D: v, D# H9 B  G
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    5 X' J" R& p* N, U4 p0 j% ~
67.             return status[webSocket.readyState];
    ) A" i+ k; c  P( C0 @* p
68.     }
    
69. 
    , f4 t9 T0 l0 G
70. 
    
71. 
    
72. function start(event){
    . B+ A$ A6 C0 e- T8 }% `
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    # H; e: `/ c) c7 S5 t
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    - j) U3 P0 p0 A0 a& f" T
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    3 D  ~1 x. |  a
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    : q* z5 O$ s# i/ t" Y
85. </script>
    1 ?* }1 R* O! a; L
86. </body>
    ( @$ ^( G8 _0 s
87. </html>

复制代码

; v5 n. W- ^; T# i) o# W' N