php实现websocket实时消息推送

admin

php实现websocket实时消息推送
- H( \" N  q% R
; q9 p' _4 R$ G0 I( ?5 |! w
: _8 B1 ]6 y/ [" S8 g8 P; `SocketService.php

1. <?php
   : @3 O6 S( R2 i& |8 T
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   * x9 r7 d* v/ N& N$ i
7. 
   % Q' Q, T) u  C. _8 D3 Z8 m, f1 V
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    + P, i# K. q1 G/ B! p
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    & c+ c5 {+ J) _4 @/ C* n
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    
21.     }
    0 X4 X& o- g* ?
22. 
    % q! {" \6 O! [
23.     public function service(){
    
24.         //获取tcp协议号码。
      @8 L# @& r( N; U
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    0 x9 [( z& b% J
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    / a, R7 u0 o+ s2 q; @
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    - A* Q) Y5 c( _% B
34.         echo "listen on $this->address $this->port ... \n";
      _0 {( ~7 K# q! B& r! X) S
35.         $this->_sockets = $sock;
    
36.     }
    ) x$ H0 k& B; S8 m; A( R+ I
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    8 Q: b" x% d: o9 B9 E$ v/ y" g& n
41.         while (true){
    # y- E* N' h- K& k& A2 X3 v$ Q% p
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    6 i4 V- q( D2 I% d
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    - k. N( I% L+ e$ I* E/ u6 X
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    5 Q% l3 i& W. m9 t( [
48.                     if(($newClient = socket_accept($_sock))  === false){
    4 {) i! q: l5 |- Z# Z5 f. s
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    7 D; a% K4 ?* y( a7 i
52.                     $this->handshaking($newClient, $line);
    . F0 T, Q$ x  s
53.                     //获取client ip
    ) b& N1 l" U9 i/ k$ N$ [5 B2 ]
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    # I, B( S# i. C3 e! F
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    5 L9 O( q: B7 r- F4 {; d
59.                     socket_recv($_sock, $buffer,  2048, 0);
    6 R- l0 X8 X- j5 a8 q
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    ; t9 j9 y$ O7 }8 d4 s" G
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    6 k0 _5 j! F1 d9 Y( O  i9 H' M8 U# u! J
68.             }
    ! `' n0 t( h$ \
69.         }
    
70.     }
    2 a2 v# \# ]' S. X1 g3 g
71. 
    5 r( x' o1 A  v" H6 i/ a
72.     /**
    
73.      * 握手处理
    4 I3 {) f" r& [9 e/ _2 |* f; l
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    - A2 }( D0 m$ |9 r7 O
76.      */
    
77.     public function handshaking($newClient, $line){
    % e3 L3 n& `& O% ^/ r) u" {+ t
78. 
    
79.         $headers = array();
    1 K' W/ Y+ {+ }9 P" Y
80.         $lines = preg_split("/\r\n/", $line);
    3 O+ l9 [6 |7 t
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    3 M1 @$ O7 t6 p- z
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    ( U$ `) g; q  i; e* A& P  \
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    * d% V( U0 |* R3 q
88.         }
      e/ [+ _6 k" w' x+ i8 X9 x% r
89.         $secKey = $headers['Sec-WebSocket-Key'];
    6 @) N5 [" T! }" {2 V: F8 k
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    % M! L7 {7 K/ E# s4 M( D
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    9 a- i3 B  g9 T/ T; `$ j/ J
94.             "WebSocket-Origin: $this->address\r\n" .
    ) h5 b1 S2 l6 ~. U
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    ( R: `9 w- a; j5 k
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    ' o; @) _1 {/ m9 g6 s8 \6 F
98.     }
    4 X' P/ R3 X) Z( K4 n3 D
99. 
    
100.     /**
     
101.      * 解析接收数据
     " Q8 c8 a$ S! B  g6 j! M& j
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     # U+ e' i, X: r' t& A
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     " L% U$ U: b' F' |4 C' B* g
108.         if ($len === 126)  {
     5 X0 U2 V0 P8 s5 \% m" G/ j
109.             $masks = substr($buffer, 4, 4);
     / B5 S0 o' F6 [; Y
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     3 k9 Y2 t2 I( X. J; a  W7 Q" N
114.         } else  {
       u1 k7 Z4 s# B0 P, }
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     & T- G# D2 ^! N) G
117.         }
     * O, s6 r$ a8 C/ r" i
118.         for ($index = 0; $index < strlen($data); $index++) {
     ' X' j2 [2 o8 Q" w% A0 M
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     
122.     }
     $ Y" N9 \) V) {4 L8 Q$ P
123. 
     
124.     /**
     $ _7 r! _7 c* D4 u8 e0 ?! b$ F; \& m
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     0 x7 u) a! h7 t8 w+ m6 i% O
127.      * @param $msg   要发送的数据
     * v$ g4 _7 ?: T- W: v
128.      * @return int|string
     5 ?- `6 m/ V) r; T* ?
129.      */
     ( i) B( ?# X* M
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     6 N& `+ O& a( ?# Z
134. 
     0 g* I; z0 }% S
135.     public function frame($s) {
     * z: v6 l, H9 r, o- U" r: C; u
136.         $a = str_split($s, 125);
     9 M  y( ]$ }9 S: |9 a8 M2 m+ F
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     - q, z; o) p$ }; @
139.         }
     
140.         $ns = "";
     , f' y3 _, u* R% Z
141.         foreach ($a as $o) {
     ! N7 @: p8 ~- r) W) r- ~  m
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     7 V8 x4 r) R0 U' E" w) o" _
143.         }
     
144.         return $ns;
     
145.     }
     - b% _& p7 m/ r; D7 U
146. 
     
147.     /**
     8 i+ l  H) l. i, J3 c
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
       T$ h% p" `  I/ u
152.     }
     
153. }
     ' [! m! ]2 b# V
154. 
     . M9 {: q/ ~% G  k# i1 f7 O& E
155. $sock = new SocketService();
     , j6 ~* n1 ?. p6 _0 Q
156. $sock->run();
     6 c: k! N  N. ?* H. r
157. 
     

复制代码

web.html

1. <!doctype html>
     e% ?8 g8 m& n
2. <html lang="en">
   ; ]0 \: s4 O0 ~/ U, f$ e
3. <head>
   
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   % E7 ^! Y% x* H# K7 ~
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   ! b* R* a- O: C2 Z- B* f+ f$ W! y
9. <input id="text" value="">
   5 Y  l- `. w+ M' P
10. <input type="submit" value="send" onclick="start()">
    ! }- O8 z) T0 N8 S1 G- q6 J$ R
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    ) D$ ?# ]. w0 \/ D( t
13. <script>
    
14. /**
    5 B4 \3 _& j- k, T: j
15. 0：未连接
    . F' t$ [( M6 I* V! A
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    / W, ^7 R( C+ P* [$ k6 T/ C9 J' I
18. 3：连接已关闭或无法打开
    " O' @  ~1 z, b$ t
19. */
    ! S0 x" [8 O1 P
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    2 {/ @1 Y) Y; M5 _/ S% U- k0 `
24. 
    . [5 l4 P7 e' S8 B
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    . x6 ]# ^: _) |. V% f& o
28. 
    , W6 N" J* b+ F/ U
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    * F3 L" C6 Y5 }: ^
33. 
    : p0 {* g/ s' }
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    ( `; ^2 e6 j1 T
37.     };
    8 o7 p2 f3 M7 T: z4 T( m' b
38. 
    
39. 
    $ ^+ P5 [6 H6 z5 E( V
40.     webSocket.onclose = function (event){
    6 M, L. B; i. k) m8 c! K
41.         onClose(event);
      c. _, N& Z2 m7 h; X, }
42.     }
    2 h: i9 E. y" u& @2 N" N" [
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    2 R% ?9 M" G1 d- B7 s
48.     };
    
49. 
    
50.     function onOpen(event){
    $ H6 u3 R) g8 t# R" O0 Y8 j
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    * A+ i9 }/ z- t  }6 I. S
54.     function onMessage(event){
    : j$ V: J& T+ D; q! d+ _1 c
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    0 B6 a6 Z+ ~% h4 Y6 W
59.     function onClose(event){
    % G1 B2 M" ~; w, J- G1 _" X
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    
70. 
    5 x  G. K% C+ w1 r- ^+ T. S
71. 
    - \1 E( L+ l$ P9 ?
72. function start(event){
    1 c+ p! A: F! A0 q
73.         console.log(webSocket);
    2 u! H8 d: A' R5 h
74.         var msg = document.getElementById('text').value;
    / t$ N  s. z* K
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    * T3 |4 M& m- }0 R
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    ; @: {1 ]# G- u/ N( G
82.     function close(event){
    1 B0 K6 w1 b3 w# U0 p+ B+ H  D
83.         webSocket.close();
    " ~) ^4 L0 T' v9 D5 x
84.     }
    
85. </script>
    . \* s' ?: U, {& e0 W0 d
86. </body>
    ! I% ?7 z# S4 V9 O# i2 R
87. </html>

复制代码

( {! ~4 Y! T$ P% S) ^' K