php实现websocket实时消息推送

admin

php实现websocket实时消息推送


( _2 l6 \: W0 g1 u$ a' C& lSocketService.php

1. <?php
   
2. /**
   
3. * Created by xwx
   & y3 e0 f& ^5 u! I6 o; h+ Z: t* D7 L
4. * Date: 2017/10/18
   . u7 ]2 V8 g: _, u
5. * Time: 14:33
   " R3 M' n5 w' |, k7 \' j
6. */
   # J$ w2 ?& f# ^- `. m: [+ Y
7. 
   
8. class SocketService
   
9. {
   " ]# |) q3 o9 M
10.     private $address  = '0.0.0.0';
    6 t6 I8 P3 L4 m7 ]7 c3 }
11.     private $port = 8083;
    
12.     private $_sockets;
    . T" C4 k: w- f. P" |
13.     public function __construct($address = '', $port='')
    0 Z- f) F+ P& k
14.     {
    
15.             if(!empty($address)){
      K7 n. K0 E) O1 Z1 Y, e. e. ^- ~
16.                 $this->address = $address;
    
17.             }
    : b# o5 b  e8 j9 j9 Y
18.             if(!empty($port)) {
    3 Y: V# ]: C4 f( D1 i
19.                 $this->port = $port;
    , b3 x9 h+ h. t" t# a
20.             }
    4 x) U; B3 |# \: K  e) n  e) M, X+ B
21.     }
    1 Z9 `% K1 D; T- C' [0 N
22. 
    7 Q6 s9 g. F- K* @: j
23.     public function service(){
    . M/ I* E/ a# U4 t3 y. z2 |
24.         //获取tcp协议号码。
    / d' y4 k& O; M& \9 |
25.         $tcp = getprotobyname("tcp");
    ( i& v. f; R# `1 [2 a* G
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");
    
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    & T8 v) i% h6 o- u* p
33.         socket_listen($sock, $this->port);
    % c! J8 H* A) ]
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    5 s/ q/ G2 T2 c# E( x' P  u( ^
38.     public function run(){
    7 \% ?' {; `, ~0 p8 \, p2 n
39.         $this->service();
    " i0 D; F: z: C0 F$ b3 S
40.         $clients[] = $this->_sockets;
    ! i( C! Z$ E0 M: P. f" U9 a
41.         while (true){
    # y# ~$ k/ u4 P
42.             $changes = $clients;
    
43.             $write = NULL;
    , _  d6 Y9 f# `2 m* |
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    : T" z" s/ f2 ?4 ^) O  u, f" F
46.             foreach ($changes as $key => $_sock){
    3 A5 B; A8 B' T& R) l
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    ( M2 X% @2 R: l* v( a* s
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    8 o5 r4 x+ k! h  C
50.                     }
    1 u7 |. A- p2 K6 M" K: J$ r( y
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    + M$ a, F. B% j/ X3 }
56.                     echo  "Client ip:{$ip}   \n";
    + [: h' u, }- N/ W. F5 l
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    % U9 m' e9 e. h% [; d
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    - m- }, T7 n1 r1 ^% F
62.                     echo "{$key} clinet msg:",$msg,"\n";
    ' g0 H. E( T4 x" M
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";
    
67.                 }
    $ i" T* D% E1 R( a+ x
68.             }
    ( _8 M; k) _1 u  r. w0 m) E
69.         }
    
70.     }
    
71. 
    % \$ B; v- [! D$ F# C
72.     /**
    7 E- B' W& _6 a9 S5 p
73.      * 握手处理
    " i3 E7 N5 c5 O/ p5 }
74.      * @param $newClient socket
    ; c& r5 A+ L% R0 E- x+ o( z
75.      * @return int  接收到的信息
    7 J" q+ }  n" P
76.      */
    + j/ M4 b4 r6 O
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    ) {6 ^" ]' s" U2 @+ D. U
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    ' T% n  N# O* y- Y1 a
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    6 z. Y& q. ^9 C, L5 P1 Q$ A5 R+ @- c
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    8 `; P2 e7 q$ X" w& G5 u7 u
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" .
    - l: t5 Q" o. _, d
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    ' E  U% i9 z: ^9 v, J9 ^7 ^
94.             "WebSocket-Origin: $this->address\r\n" .
    . U, S4 f' Z3 m# H: I; P4 \% v  y
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    8 A4 t5 v' D! m' n# g. R9 p, u
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    8 H( E) M& u/ _# T. C
98.     }
    
99. 
    $ j6 N1 y1 p8 {
100.     /**
     - B$ J0 Q. }6 L; |+ T0 ]
101.      * 解析接收数据
     ( }1 Q; m2 Y7 Q- `" c: P: v5 E
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     + T/ R  s$ j. r7 Q% q/ O& R3 P+ s
108.         if ($len === 126)  {
     ( d% O0 \0 G& k
109.             $masks = substr($buffer, 4, 4);
     9 {  i, e% K# u; g+ h6 G( @$ @( y+ `
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     : V( y- {* U/ A3 K8 L7 b& @! J
114.         } else  {
     3 e& G5 P6 _4 D) h4 N# {
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     ( W  S# _& M# `- O* T0 S: ]: I
120.         }
     $ c& M' b8 a& I9 O3 |, K
121.         return $decoded;
     
122.     }
     
123. 
     ' E5 ~9 f8 }& s- i1 T
124.     /**
     
125.      * 发送数据
     ; e! W6 ^& t8 K
126.      * @param $newClinet 新接入的socket
     3 v) f6 k& f/ \) e
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     ; S$ N" j( s+ G, I+ [
129.      */
     5 f, J! b, U4 o) D1 }. u
130.     public function send($newClinet, $msg){
     0 ^4 U2 m; r; f  H3 K! v
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     $ {4 y: V% s5 w- ~0 C8 p' }' e( B* q
134. 
     
135.     public function frame($s) {
     9 V1 ?# r* G, f" g1 D/ q' w2 R) d% `  I
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     ( r1 U6 ?! D9 g- L
139.         }
     
140.         $ns = "";
     " h1 c8 Z* C2 H  q6 u5 Y
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
       w1 w0 m2 o- w" F( u# ~
143.         }
     2 l9 k1 x7 ~" k6 c6 i+ L8 k# o3 f
144.         return $ns;
     4 x. p3 }: f7 b+ m7 u
145.     }
     8 V1 S2 A2 {" b* O
146. 
     6 L) d' M- n  k8 ^" c2 ]
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     # d- {, I8 }) Z& Q7 i. I( g) ?7 @2 t* z
152.     }
     
153. }
     0 n1 p9 t7 ~* Q+ M' M
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     & @7 l! V0 A% N1 i' P# ?, t8 f
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
     ?# u3 |: @9 E$ T5 l3 h5 s
3. <head>
   * e% K( ]2 E& z  C) p- k4 y" v( c
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>
   & Y- P. y9 p1 [% L, x
7. </head>
   * d$ m+ o/ v! H' d( H) ~4 q: [4 `; i
8. <body>
   6 D, F5 `9 y- g' p( S
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    ! U8 b% b' e" T  m0 e
12. <div id="msg"></div>
    1 \! z% l6 }8 T
13. <script>
    
14. /**
    6 Y  }' e: R4 P4 L
15. 0：未连接
    
16. 1：连接成功，可通讯
    # m) r' a3 q3 s5 D9 D% e, u( L; F
17. 2：正在关闭
    5 I0 H9 \/ a) m1 V) R! s; j) Q6 P
18. 3：连接已关闭或无法打开
    
19. */
    ( Z) y2 j9 y5 l7 L- l4 a
20. 
    
21.     //创建一个webSocket 实例
    # A, X+ D5 l; ~- H" X3 k9 l0 Q+ i
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    # G6 W$ {, ~% q6 |$ Y' ~
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    9 G% S2 G" X6 N+ {% p; B5 h
26.         onError(event);
    
27.     };
    
28. 
      Q5 W2 e+ v8 x  C/ O1 Z
29.     // 打开websocket
    ( V' ~1 z8 \1 o6 }9 @" w/ Y  z
30.     webSocket.onopen = function (event){
    3 M* {+ s: @; @" C  K: ^5 ]0 x
31.         onOpen(event);
    + a( L8 u  ^! D9 k) C/ ~
32.     };
    
33. 
    
34.     //监听消息
    9 F8 p/ {1 i. g% I
35.     webSocket.onmessage = function (event){
    # x( D! t8 J2 r9 E- m
36.         onMessage(event);
    
37.     };
    
38. 
    " y0 @+ t1 k9 s3 B
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    8 i9 ^- K/ U) \% Q; M
42.     }
    
43. 
    
44.     //关闭监听websocket
    - y+ u6 F6 B! Z7 X
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    " [" _3 o# e& b1 |! j
47.         console.log("error"+event.data);
    % E6 L/ }" M4 s! c
48.     };
    8 v2 w! @' W/ @- ^  }. s; i
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    # K  B7 N" u& `, \4 o. P
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    6 z6 K. o) u. @& k+ f
53.     };
    & k6 y8 Q8 f3 t/ E* L" f
54.     function onMessage(event){
    % q; q9 q. R5 @0 O; J
55.         console.log("onMessage");
    - j% i" p! b3 n  Z' d
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    ( g3 e( I# V- u/ q  S
57.     };
    ! j/ L7 ?; m5 L; N
58. 
    4 W! e. g! p) _8 t% |. P1 v8 ~) }/ ^
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    . }0 l: x# U. V0 Y
61.         console.log("close:"+sockState());
    * k  C/ A4 }5 S! K% e
62.         webSocket.close();
    ! M5 P% \6 ?3 O* u4 ^
63.     }
    
64. 
    6 @0 O# n' J* L9 _, X, p# z
65.     function sockState(){
    ( F( K0 h6 }/ w3 N8 ?
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    ; u/ W3 S  @# Q3 A
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    
70. 
    ; @( Z9 v. }9 G, }/ z
71. 
    # e  K1 u' n# ?& d9 r/ ]9 N/ H
72. function start(event){
    
73.         console.log(webSocket);
    0 w2 b1 c) n% M" _) |
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    2 h! A. o  u4 e: ?6 b8 k
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    7 n: _4 f. C  m# K$ Y" Q
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    & Y; b0 t. h- i1 O  T
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    . m# C! _6 n4 {, X8 T
84.     }
    0 r3 O) M& u: s
85. </script>
    % I! R$ v8 [) d
86. </body>
    4 B# k+ d( m' P' y  Z
87. </html>

复制代码

' {. {# [! ]2 p$ r. N4 u