php实现websocket实时消息推送

admin

php实现websocket实时消息推送

9 I6 x8 Z3 ]5 m% U5 s  s
SocketService.php

1. <?php
   ( a1 }/ F' {2 F6 l$ Z
2. /**
   ' o/ @9 r/ ~8 r( F, o
3. * Created by xwx
   4 G* g/ }+ C) I% I% Z1 K
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   6 T0 r' i5 I: t! F# Z% g- ]
7. 
   ) x0 x  U# p/ q& S
8. class SocketService
   0 _; K& Y  n0 y- S* b
9. {
   
10.     private $address  = '0.0.0.0';
    / k0 d3 z. l; }0 @# ~! R# O
11.     private $port = 8083;
    
12.     private $_sockets;
    * T8 V  |, L4 X9 C
13.     public function __construct($address = '', $port='')
    
14.     {
    & y& Q* Z9 Y5 S/ k* W
15.             if(!empty($address)){
    , b! R7 ~* t* B
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    " K, ^6 {5 D+ \1 S& e$ _8 q
20.             }
    
21.     }
    
22. 
    ; g4 o$ d0 ^% ]" c
23.     public function service(){
    , @; o+ f) E0 L+ X; `
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    0 Z" d) L, X6 f( E2 ]& a5 E
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    4 W* F+ z: \# f
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);
    
33.         socket_listen($sock, $this->port);
    - [) c; ~# k# l0 s0 L4 _
34.         echo "listen on $this->address $this->port ... \n";
    % I: w1 U% L% ?+ T# V" E  h
35.         $this->_sockets = $sock;
    8 t1 w! m# Z9 w1 Z+ `1 `' u
36.     }
    
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    - X" Y) w% m- a$ j  \
41.         while (true){
    
42.             $changes = $clients;
    : a+ Y- a2 f& E. ]/ v% n
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    3 Z! ?" o& n/ k! ~/ I0 M8 K2 l
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");
    
50.                     }
    ' G* j. i0 \/ `% l/ O5 `2 f
51.                     $line = trim(socket_read($newClient, 1024));
    % J( U* n- `% F; b! F2 `
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    5 v" F. R% S7 W+ @( e$ k
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    $ j- ~: R8 z9 |; j; B
59.                     socket_recv($_sock, $buffer,  2048, 0);
    , T$ I1 K' S) \/ h* S3 J
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    . r/ B) w. f- ^% r
62.                     echo "{$key} clinet msg:",$msg,"\n";
    3 r+ O/ }$ u' T8 H# y1 B
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    : O* J" _4 u3 D$ [. p7 H" h* {
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    0 J! |& G( j# @; O+ T$ u) G
67.                 }
    
68.             }
    ; c0 f7 J  W9 Z! Q
69.         }
    
70.     }
    7 A% ~  L- S! z6 X) q
71. 
    - d4 {- H+ q+ B& r, c; {2 l
72.     /**
    $ Y" F, b2 S( x( s2 n
73.      * 握手处理
    , ^2 q( i9 K+ @& t0 C! X) O
74.      * @param $newClient socket
    & F* F6 E+ \+ v9 B$ K! g  M
75.      * @return int  接收到的信息
    
76.      */
    5 A7 T, W% T; Y. C! n5 G
77.     public function handshaking($newClient, $line){
    5 {" c4 X2 i) Z; o# u# D! E1 k
78. 
    $ T# p& V3 Y4 B* U
79.         $headers = array();
    ) a, l+ G% f4 s" g8 ^
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    , N! a) y( v6 f! x# }9 H
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    3 }$ o& Z* ?' e8 ]. O9 a" [
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    # I% Q& a: s) \. K6 O% F
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    1 ]. n! I6 L; O% T
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
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".
    $ T. D" _% `$ ^2 M" y! i% @
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    , A$ f* [' A: T% W; W) t$ Z! p2 O7 Y
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    8 F0 c0 _; S/ B+ ^  i5 h" n5 w0 B6 Q
98.     }
    9 x/ J# H& v! h9 A( w- w9 F6 L2 Y+ J
99. 
    
100.     /**
     
101.      * 解析接收数据
     0 a2 \9 ~( D3 A
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     7 C( i( d7 h2 B- _- F
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     5 X: b" l" x& Y1 y, F- c2 n: q5 ?
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     / d5 D8 {6 D7 N& M
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     * a* O$ P5 F' C( J
115.             $masks = substr($buffer, 2, 4);
     : l) w: H8 k/ O8 O+ k
116.             $data = substr($buffer, 6);
     & q; j5 ~$ p2 Y7 `
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     3 j0 y+ Z2 H) A3 ?
121.         return $decoded;
     & O5 e7 Q! E- k4 f  m5 q" e
122.     }
     " B" ]3 a3 {9 f3 r& ^, t- @% P
123. 
     
124.     /**
     
125.      * 发送数据
     0 r4 j7 e: N5 D7 T. _1 ?
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     ! t2 N5 p- m5 \
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     7 l( I) s# ^# L7 v* o
131.         $msg = $this->frame($msg);
     $ b! T& B7 m, ^. l4 Y) g0 ~
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
       n$ L, Z0 |& T
135.     public function frame($s) {
     : r+ r% G7 U- n4 [. U3 d) \
136.         $a = str_split($s, 125);
     : Z/ Z# Q! u. {* o2 G7 ]
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     * V  G* }1 N2 w; W; F# V
139.         }
     8 b5 f# \; z/ m" S
140.         $ns = "";
     9 U6 _# W  ^! f& M/ o
141.         foreach ($a as $o) {
     " t! d6 G; t2 \1 x& N* d
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     / ~# S0 u5 P3 o9 {9 A7 b
144.         return $ns;
     9 o( ]( ]  j4 F. Z  X* s! z& L
145.     }
     
146. 
     3 d$ p' M, C/ a
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     $ z8 k/ L- Y( I5 `
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     $ x' b0 R$ s$ V- _
157. 
     

复制代码

web.html
3 Z7 x$ T4 ^7 g) c

1. <!doctype html>
   2 b; a! ]1 \2 \( ~# b
2. <html lang="en">
   " [$ l" @" e+ T5 N
3. <head>
   
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   " Y# E7 y) @0 O
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   % X! Y: q5 \2 p
10. <input type="submit" value="send" onclick="start()">
    # A" f7 j8 N( x' ]) C
11. <input type="submit" value="close" onclick="close()">
    1 Y+ D1 a$ u: x' \
12. <div id="msg"></div>
    $ O$ a$ b3 i3 J& n3 H: @5 c3 W; {
13. <script>
    
14. /**
    
15. 0：未连接
    0 I% ?/ O: R4 h# A, U1 U' W0 ]1 h
16. 1：连接成功，可通讯
    # S% Z! M: L! E5 E& u$ V
17. 2：正在关闭
    9 r2 j1 j7 ~6 e; g% s
18. 3：连接已关闭或无法打开
    7 e- N  y3 n! n1 u
19. */
    ! E6 }) h& S& ~& n6 z
20. 
    ' l6 }$ Y! p7 ?4 i! O# Y
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    7 R" o& r9 A' D0 B$ K
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    ' s8 X4 f4 P3 @% O- I( i7 E
28. 
    
29.     // 打开websocket
    # F, |" i# A; W2 k+ B
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    
33. 
    6 G, `) d5 i+ `4 c& U* ?* ]- i0 @5 B
34.     //监听消息
    * A7 f$ J* u. |: ]6 |; U2 l
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    4 g( i+ y$ ?/ d6 ^# R8 T
37.     };
    
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    ! m  G( G6 v: e1 |
43. 
    
44.     //关闭监听websocket
    8 S6 A' C3 Q9 q) @* B9 y
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    3 q8 n- p  D: C. o' g, s
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    
50.     function onOpen(event){
    * s# h- V" C/ |' U8 f3 s# R
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    ( g, I5 v4 }( @( M6 P9 u
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    9 b; I7 Z- Q, g$ c
59.     function onClose(event){
    / ?  U; E1 {% v2 f+ q% ]
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    + ^, G& U; j1 c+ m6 Y
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    - U7 Z2 Q. }) ^( `# r$ Q
64. 
    
65.     function sockState(){
    + M! r6 J+ j1 E' V- V7 j
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    1 _: l( o1 @; b6 O9 v) a
67.             return status[webSocket.readyState];
    $ i  x0 ?1 i' T' m
68.     }
    
69. 
    
70. 
    3 M! B# k& [3 E0 P) p
71. 
    ; p0 M& A, V% I6 K0 K
72. function start(event){
    ' Z$ z" ?) T4 r7 l$ N0 T
73.         console.log(webSocket);
    ! a7 n' a5 C& i) b( N
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    ( }1 n* M) a+ e& X' t  E% |+ A
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    # n0 m* r( h( O0 `  c( f
78.         webSocket.send("msg="+msg);
    4 `2 c  [* t4 L; N* v" ^6 ^4 ?# ^- g
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    5 f" @' v6 v$ |3 I# p; @
80.     };
    
81. 
    
82.     function close(event){
    $ j! T. a% @& }8 ~, ^, r6 [2 {
83.         webSocket.close();
    4 Y( I" ~/ X7 O
84.     }
    
85. </script>
    
86. </body>
    
87. </html>

复制代码

% c& V; H; r4 u) D