php实现websocket实时消息推送

admin

php实现websocket实时消息推送
# ]4 x9 f) ?  u3 |

. z2 B9 ~4 `+ g9 @* ?# X! USocketService.php

1. <?php
   + S% s$ q. t, T) @
2. /**
   + D2 g) I; M7 G) M8 {) g) w. e
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   2 j' R: F# q. b! L
6. */
   
7. 
   
8. class SocketService
   6 J" c) [' n- v( m  c; f  u
9. {
   ! L3 R* o  ^1 j$ L
10.     private $address  = '0.0.0.0';
    % M3 N, u2 j9 M, V) A( [1 ~
11.     private $port = 8083;
    ) |1 ~* Y+ m# A% F6 g. P. ^
12.     private $_sockets;
    6 v5 t: s1 C# g5 j  v8 D* y5 o
13.     public function __construct($address = '', $port='')
    $ N$ X2 D) _2 l' i% l
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
      i6 R4 L) o5 E7 u
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    
21.     }
    2 U2 X0 S& J5 @2 X5 x" [
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    & z$ m  a0 W6 ^& l
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    ) C0 y; N$ U( c, D
28.         if($sock < 0)
    % c/ Q6 O  n; {% W
29.         {
    " r7 x0 {) A0 f; ]. D4 i8 S
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);
    6 B: ?- k5 {1 @# ?
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    5 n1 ?3 o- K! V) F% V+ B. o& S) o
36.     }
    - f$ k" y$ k  I3 Y
37. 
    
38.     public function run(){
    
39.         $this->service();
    & X" t! m6 V" O& z0 \
40.         $clients[] = $this->_sockets;
    & Y4 r1 l- d* {1 w- P# h
41.         while (true){
    1 m5 C: h! p+ I5 \7 y
42.             $changes = $clients;
    
43.             $write = NULL;
    ; r1 g: K7 u! l$ O  G' @
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    , D. y& Z( f6 i5 V5 j4 _: P& N
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    , T) M1 ?9 y2 u4 m+ h# s, \. E
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    ' ?  t2 q; c+ S# W
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    ( \9 K4 w6 W, U0 u: ~8 O7 f
53.                     //获取client ip
    . L/ n' w' ]7 l
54.                     socket_getpeername ($newClient, $ip);
    % G# O# o3 ^* T% F
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    , N9 H; h0 y: H- \8 \4 w, [
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    ( A$ n# Z7 \8 x
61.                     //在这里业务代码
    8 k5 E$ h4 Y2 R) S- l
62.                     echo "{$key} clinet msg:",$msg,"\n";
      n# \% b3 ~, N* x: n& G( @! f% h
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    9 Q# h% ?$ y5 v" n$ |- {6 x, `/ ~9 G
67.                 }
    . ]9 Y; {5 i1 E+ F* x" t
68.             }
    5 d, U+ B+ Z; \. Y: x* @; U
69.         }
    
70.     }
    1 \7 U0 b% P3 J5 O" t6 B6 y: x
71. 
    + P/ w5 Q2 x' P1 r! p
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    % F$ {; V. s7 D  I- z& S
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    1 _+ l, j0 `2 \9 K& U
78. 
    + I- Y, w5 M/ B# p4 {* U3 B" \' W
79.         $headers = array();
    3 [. e+ v+ f3 x: P2 N5 Q
80.         $lines = preg_split("/\r\n/", $line);
    3 V2 y; O, ?4 k% N2 W+ F
81.         foreach($lines as $line)
    
82.         {
    5 Y* w; K5 L$ s6 @! F1 O/ }
83.             $line = chop($line);
    ! c# G9 y! c" q3 M& h
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    $ {2 i8 m6 y% {0 \
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    5 t5 t# L9 u& S( c# U9 E& N+ g/ K- E
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
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" .
    + n: s6 R+ n* a( G1 z" c& X
93.             "Connection: Upgrade\r\n" .
    4 b  s! F2 L! t$ e! W
94.             "WebSocket-Origin: $this->address\r\n" .
    # w) a! a( n2 }9 H4 y
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    ; J% o; P7 ?# H8 A' ?
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    ! y" Q1 Y; n0 i- `% G1 Q. n$ e3 z
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    
100.     /**
     ; e9 ^( D& l2 w% \2 y7 m
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     / w$ T2 D$ i# t; E& A
105.     public function message($buffer){
     2 u; W9 `! S8 k
106.         $len = $masks = $data = $decoded = null;
     2 @+ h9 {7 U/ G% a; L/ a  k% l, L6 E* Y- l
107.         $len = ord($buffer[1]) & 127;
     , a8 Y# t) v5 S; V4 ]6 [* }% Y
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     - x6 P6 i% e* f/ w( h! H" c0 M
110.             $data = substr($buffer, 8);
     " C5 u& e  ^* H& M
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     7 q3 W+ d4 i7 L; d( Y, `
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     * @% m; K8 u0 z+ D
118.         for ($index = 0; $index < strlen($data); $index++) {
     0 P7 P2 Q4 ]# E0 H' v9 [8 ?# }
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     ) y6 J  g4 R/ f& z" z- ?1 O
124.     /**
     ! w2 u2 f9 V8 y1 S' u& N; t+ @( L: b
125.      * 发送数据
     $ `. z& _3 e4 t# S8 u0 {2 t1 f
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     0 w: W# x2 E# G* w+ ?' {
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     8 a( @4 J0 C7 _# [2 l
133.     }
     
134. 
     . M/ ^3 Z# E) Y, d! [* E4 a0 S0 k
135.     public function frame($s) {
     : `+ H* ]( ?7 D8 ~: z
136.         $a = str_split($s, 125);
     4 |5 e/ Q0 `8 L' z' m  p
137.         if (count($a) == 1) {
     6 O4 _9 d( D3 X: J( E" h
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     ) p6 [5 W% S: `' }! {, ?
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     
145.     }
     
146. 
     3 d6 I; V9 r# b% b* y
147.     /**
     ' o# O% S& p8 g7 R( p2 K" C5 j7 k. _
148.      * 关闭socket
     
149.      */
     6 m6 Z: s2 a/ o9 t
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     - h9 Z+ z1 O6 W- P# w
152.     }
     ( Z3 x. r2 {3 p
153. }
     
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
   0 f4 K; x4 L" v/ Y- s" P- i
2. <html lang="en">
   
3. <head>
   , s+ O' v( Y! O9 {# ^
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   % g' e# o- n2 P: c
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   % m: l9 q! w3 \
9. <input id="text" value="">
   : ]* ^* b/ A, ]$ J! I9 Y4 j1 A
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    ; |# h9 q0 K# E3 ^9 c! ~8 h
14. /**
    3 r8 r9 \$ z% H
15. 0：未连接
    
16. 1：连接成功，可通讯
    4 P! V  L: q& Y
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    # w$ O- N9 B5 L" q" b4 w
19. */
    4 f( n0 B2 y5 s* ]3 J
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    " q  s: @* k& X  F
24. 
    
25.     webSocket.onerror = function (event){
    9 Z% Q- _  N1 d5 b; T  n
26.         onError(event);
    
27.     };
    9 }4 i: r; |8 U* z& M/ ~
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    : ?  b2 J, u5 u7 y. L: w) V8 H
31.         onOpen(event);
    
32.     };
    
33. 
    # ]2 n9 X: W8 N. _1 o: ^. B! w
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    8 k( E+ ^% r+ M7 M# l8 R3 C
36.         onMessage(event);
    " i8 v$ u( T* P7 e
37.     };
    , a' H  O8 h$ d5 y
38. 
    6 c; X" H9 b$ U5 [( n0 v+ V
39. 
    8 P+ E; C4 N8 O9 y/ l/ Y1 @
40.     webSocket.onclose = function (event){
    1 p+ w. d" z% k3 X3 z
41.         onClose(event);
    
42.     }
    
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    # _% R+ W  {. a" ^
47.         console.log("error"+event.data);
    ) f0 N7 T' h1 A1 L- n" f& m
48.     };
    / j. j' A; p$ L
49. 
    , k2 g; g2 {& b5 B: e+ t
50.     function onOpen(event){
    # b. ^$ e% K# T& s( `
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    ; x, G0 h( F- E
57.     };
    $ h% c4 |' Z1 Z8 r8 t
58. 
    * w3 @, N" x. \2 Z) W- P
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    1 l+ v% o. }  N! l- t
61.         console.log("close:"+sockState());
    ) b$ I9 R  z- t6 p7 S
62.         webSocket.close();
    $ K" O9 @/ K4 Q- u+ t
63.     }
    
64. 
    ' Y; B! V  Q# ^) @( h
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    % u8 d9 F! _+ g& p( l
67.             return status[webSocket.readyState];
    ( |/ t* u  c1 n  I+ x* R2 `1 [
68.     }
    
69. 
    7 {- A9 c( [7 [3 ^
70. 
    % K8 [6 w2 j2 l- o1 ]$ K
71. 
    6 `) i8 m) c) T0 z1 z
72. function start(event){
    ) J% `1 @9 ~7 y& E
73.         console.log(webSocket);
    8 U% @4 d: E- n
74.         var msg = document.getElementById('text').value;
    " P% p& a# }- X* @+ ~7 ^# P
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    3 O$ {  w/ ^; D
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    ! ^( b# _( m5 t& `7 Q3 r0 e
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    * r* h: i& F- n0 n* a3 I* ~0 r/ |
85. </script>
    
86. </body>
    
87. </html>

复制代码