php实现websocket实时消息推送

admin

php实现websocket实时消息推送
  @$ m8 V3 u. F. M, J4 {: Q
3 w4 U: g! ^4 D5 m+ \1 \- H
SocketService.php
% q- J% E! m4 m

1. <?php
   
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   ; I! I( R6 M" j; n3 u" f, n; B
5. * Time: 14:33
   & d8 h  Q1 O% \7 f1 P; r
6. */
   7 e  v9 q& l! C8 v
7. 
   
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    : ?  m. q: u  p  b) W* U, `$ ]8 h
11.     private $port = 8083;
    2 f1 k7 e" u) U: L2 I  d
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    8 w+ A+ J8 a$ `9 F) Y$ T; Y1 `
19.                 $this->port = $port;
    ! j- J2 v" d2 u  R7 S
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    ; \5 t3 q% i2 I* d2 o: I# L5 H
24.         //获取tcp协议号码。
    8 M) a( l" ]! G8 M; z& ?
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    / ]$ U& \- Y4 ~: [7 A8 F+ A
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    / w# l% d' A# {0 M+ ?  n
32.         socket_bind($sock, $this->address, $this->port);
      C$ s6 F/ k0 g/ S
33.         socket_listen($sock, $this->port);
    9 \3 e/ ], ?8 z2 `, N* V
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    4 T7 g8 j- ^# H$ }9 _
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    ( F6 Q7 L+ e6 j7 p+ C! m
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    1 @2 a6 k, i3 H! B
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    ! ]6 o) g' k; O7 q* H& M
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    . j; k. }0 N3 C+ Y5 f" a  U& ]
48.                     if(($newClient = socket_accept($_sock))  === false){
    : Z" R/ }/ A1 }4 y; C3 T2 x
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    4 ~/ H" @; n, ^8 Z, d. P5 k3 |  Z
50.                     }
    6 L) ^6 }' a6 Q5 g4 T
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    / f1 `/ t1 O% t% @  n: @5 s* X8 s
54.                     socket_getpeername ($newClient, $ip);
    2 V9 X: n1 A+ s& `  j: C
55.                     $clients[$ip] = $newClient;
    8 Z6 x3 g( v# c- F  p# @+ k+ l  ]2 {
56.                     echo  "Client ip:{$ip}   \n";
    # v1 b0 W1 x8 _2 z; @; e9 R/ y% x
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    # q! A4 R0 ^- N) |4 P
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";
    + |) k1 a8 |7 J! C
67.                 }
    
68.             }
    1 o7 ?  Q4 z9 O) b" ?# f" H0 F
69.         }
    
70.     }
    
71. 
    , q* w- x+ j3 |& M8 `
72.     /**
    ) b. s' q" @* A% D
73.      * 握手处理
    , c9 N! E# F& \, G: f# W7 ]
74.      * @param $newClient socket
    & k& E% z6 Y' D
75.      * @return int  接收到的信息
    : r3 B6 l4 |2 I) ]
76.      */
    
77.     public function handshaking($newClient, $line){
    * M4 Q2 R, A$ z
78. 
      d8 M+ Y& ^! a5 J
79.         $headers = array();
    4 }' W( d6 C! V; l9 P' t
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    " V  }+ M3 ?) @+ d$ Q( l
82.         {
    
83.             $line = chop($line);
    : a% p3 b# y. p2 e3 x5 P0 `
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    0 S; N2 ~8 N1 C. v4 ~% x* K
85.             {
    , u& \) v; h6 S7 R2 e
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    ) w+ v+ g9 |( R' i  P5 B+ Z% G& J$ A
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" .
    ) X, n" G4 x" S* A
93.             "Connection: Upgrade\r\n" .
    6 X4 P6 q5 {4 l
94.             "WebSocket-Origin: $this->address\r\n" .
    , M" g+ g- v2 A$ g+ D5 }9 ~1 M  N
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    9 ~+ [9 @9 H' K$ D' Q) l
98.     }
    
99. 
    $ P+ \* r: g' f6 O9 S+ w+ A
100.     /**
     * Y' j- Z+ f' \0 J1 \' x
101.      * 解析接收数据
     + D9 e% q" ], ^4 s
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;
     5 m% X8 q$ q( w) D7 }. \# ^$ u
108.         if ($len === 126)  {
     0 ?9 {  e6 Q8 A, a+ l3 Q6 s
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     ( v  @3 ]9 t. s! c
113.             $data = substr($buffer, 14);
     1 E" O. a- I7 E$ h+ R$ z
114.         } else  {
     7 d* ^+ Z/ r) \6 W( _
115.             $masks = substr($buffer, 2, 4);
     7 m/ P+ P0 p! C: ~2 _
116.             $data = substr($buffer, 6);
     5 g! ^6 b' ^5 P3 N2 A1 a  I% F
117.         }
     ! c( [4 a, M5 |! B3 W
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     2 j1 l- P2 i, d$ E! T8 s
122.     }
     
123. 
     
124.     /**
     4 \/ `  f! c4 \) a: q1 a
125.      * 发送数据
     # P& O4 H- l) c# c: ^/ L# M7 ?
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     6 {7 q* z" C( N. Z. B$ J. b" b7 ^
128.      * @return int|string
     7 y# \; |/ J2 D! i' N7 t
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     8 ]% Q' }/ I. q$ \
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     7 W6 R7 C* }! K$ F) j
134. 
     
135.     public function frame($s) {
     * W1 u% b% p9 Z: U) Y; |& h( W" r  h
136.         $a = str_split($s, 125);
     ) x+ @! ^3 i! N
137.         if (count($a) == 1) {
     % h. N% \1 p' _* b% F
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     % m8 q/ k$ g# Z1 A
140.         $ns = "";
     
141.         foreach ($a as $o) {
     2 E2 @; j; Q  l3 w  i5 C
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     % g9 e1 k& T& [
144.         return $ns;
     
145.     }
     1 `# x) b& l; l% B; l9 ^8 z0 [
146. 
     
147.     /**
       d3 J, _' {5 }2 E# g7 a" y$ i1 ~
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     ) O, S/ z1 O. z. V
151.         return socket_close($this->_sockets);
     7 ]4 Q, F9 u2 b% S# |
152.     }
     ! d+ p7 \2 b% G& j6 B: K6 j
153. }
     
154. 
     / m& B- `, L& c6 S+ ^- m; j' z
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html
( C3 b* w+ _6 Y$ f, g; K+ B

1. <!doctype html>
   
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">
   2 Y  F# R1 B# a2 ^
6.   <title>websocket</title>
   5 o4 o- L7 ~+ s! \$ ~# a
7. </head>
   
8. <body>
   1 ?' |. T) {: V( T9 Q
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    1 i! \' l6 D7 h* r; E' d- M! ^
16. 1：连接成功，可通讯
    " X- a8 c" t0 N% v% `
17. 2：正在关闭
      P, h3 D. o+ x4 y+ ^1 V
18. 3：连接已关闭或无法打开
    , x2 }4 L  e9 {: [  f7 k
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    * y9 R9 `' D9 a* S. N  p+ r- v
24. 
    
25.     webSocket.onerror = function (event){
    2 n* W# d% {5 l# T  H9 [2 ]4 F
26.         onError(event);
    2 X% K+ C; w$ H& @" i4 P: U8 }
27.     };
    ! |* e! Y: c" i7 Q
28. 
    ; F5 |& _: e% {6 A3 ?: H
29.     // 打开websocket
    ; @2 N/ {8 b# \& ]
30.     webSocket.onopen = function (event){
    - N' Y5 \( M0 q7 \+ {4 Z
31.         onOpen(event);
    ; _* x3 C+ H& m/ O5 ^
32.     };
    
33. 
    
34.     //监听消息
    $ I/ L* Q0 `( z$ m! |' j
35.     webSocket.onmessage = function (event){
    - y6 g# b3 z$ |) ^+ G, [* J* ^+ e3 o
36.         onMessage(event);
    
37.     };
    
38. 
    ; F0 i# d" u0 o- Z, u* |9 o  x1 R
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    1 u4 B; |# K# T" X/ p2 \
43. 
    ) d% K+ C' E* Z; C! f8 R3 R' J- Z
44.     //关闭监听websocket
    
45.     function onError(event){
    8 L( ~7 U% t8 j. {% \: x, z' V. z+ N
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    
50.     function onOpen(event){
    + D# j, P7 l/ [. L6 X
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    * v$ U$ w4 s5 z
54.     function onMessage(event){
    
55.         console.log("onMessage");
    2 r# x7 K% O% P% C3 S9 R' E( [- Y
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    4 ~# k; |/ O# h9 H4 {  [
57.     };
    
58. 
    * G8 {" c) V- H
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
      a% S/ |1 X6 A% m
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    ; A. U1 e1 J; o8 T1 C6 z
63.     }
    
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    - X( O- g$ Y$ l( H& k) O4 h
69. 
    
70. 
    , K$ X1 B# E# {) R
71. 
    7 `7 F! N' {2 z# c: o) q
72. function start(event){
    
73.         console.log(webSocket);
    " h& a$ a/ A! U$ S- x
74.         var msg = document.getElementById('text').value;
    ) z) U3 O& P3 e
75.         document.getElementById('text').value = '';
    ( A: ^" ~* \9 e7 ~
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    , ~- B4 N; y+ _4 g& |9 E6 {
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    8 G- ^  _( A/ r7 M6 Q' h( ?
83.         webSocket.close();
    " j: C! f4 t& }/ a: l8 }3 m) P$ N
84.     }
    
85. </script>
    
86. </body>
    
87. </html>

复制代码

; J( J3 H& P0 d, {