php实现websocket实时消息推送

admin

php实现websocket实时消息推送


* ^7 g" W/ _* u* |8 XSocketService.php
: ?, [2 _' m! m- i) U* K

1. <?php
   
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   : Z$ W4 d; T+ u5 o" U! [
6. */
   " X7 S4 ?; A' T1 ?5 l4 H
7. 
   
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    $ I" t* H9 D$ B' V" Q
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    & x  h2 F; Z8 Q: m8 P
17.             }
    
18.             if(!empty($port)) {
    ; u  _/ W( f# M. h/ H
19.                 $this->port = $port;
    
20.             }
    7 N. Q( M  Z2 T
21.     }
    
22. 
    ; U$ U$ ?+ ~8 ]& }. u6 D
23.     public function service(){
    : |! G4 }0 D) m# b- Q' E
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    3 N. B* [, h; p0 J
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    ! V8 t* {5 S7 C. K3 A1 h& R
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    . a& i# _8 x8 d) ]% }- f$ S
32.         socket_bind($sock, $this->address, $this->port);
    5 o- h& R" G& _
33.         socket_listen($sock, $this->port);
    4 f0 k' v# }4 A+ T6 A' ?
34.         echo "listen on $this->address $this->port ... \n";
    ) D- ]7 g! V4 F
35.         $this->_sockets = $sock;
    / `) R* G0 X4 Y* l' t
36.     }
    
37. 
    % ?' ~9 n9 U. U
38.     public function run(){
    * D' e/ Y- }0 t5 t$ p3 v4 K, Z3 i6 a
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    # x! a$ q: D9 p* E2 D; f. {# n
41.         while (true){
    - O& Q' V: U' F9 a
42.             $changes = $clients;
    ! ~2 q! c3 v3 \
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    9 `( B2 A. n; K. f- w* Y* [: S
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.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    / y4 [9 _3 h. {- r2 s& V& [9 G
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    2 n' d+ O$ }* H7 P' {
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    % i$ ?' s& s( W
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    # w; I5 ^$ [+ o; T$ p0 v
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    / E# f( k0 v" h' c& F' v8 H
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
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";
    & s1 m5 I) C7 Z& p' ]
67.                 }
    
68.             }
    . I. I1 Y- b1 {  y
69.         }
    # ^  T1 x; j6 ]8 D1 R) [( D
70.     }
    + T" Y/ a( O/ t% M( T9 Z0 i8 y
71. 
    
72.     /**
    " B  X* h. n) T4 S
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    : M# C4 V/ ^6 S- M9 @5 G
77.     public function handshaking($newClient, $line){
    # b' ?; {& l# y; `& {' d# U
78. 
    ( ?+ a- W4 [/ n7 w5 S9 L
79.         $headers = array();
    % e! ^. Y/ k: Y5 s1 x2 i
80.         $lines = preg_split("/\r\n/", $line);
    1 a  M1 R4 X5 }: ^! U
81.         foreach($lines as $line)
    
82.         {
    ! X0 P$ a- D( V5 }* c
83.             $line = chop($line);
    8 F! W: N( x5 c3 X8 w; Z- p! P: A: s
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    & }* u! z7 f+ m% t
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    % Y& i4 |4 y8 b9 S9 i' R
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    ; @" s- N  d4 ^7 m# s
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    ) g$ M* c9 K0 `" @3 z
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    + b, q# a. U2 D6 H. e2 n. o
98.     }
    
99. 
    ) K' O4 F4 ^+ ^
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     + O$ a* E1 {! |+ q/ z
103.      * @return null|string
     ( P: M$ Q& ^# L7 J. ]* }4 j
104.      */
     ! y$ `4 N' @$ r2 L: d
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     . ]3 O( p) x( b8 N$ {6 Q; d
107.         $len = ord($buffer[1]) & 127;
     * T) m. H" Z( G, \! v1 a
108.         if ($len === 126)  {
     ) ]  e3 o$ E. \- p$ j0 D
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     " Y5 p; |6 {2 |8 w( t0 L; S8 Q) A
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     5 _+ _, F1 \( R& Y5 M9 P  Q8 F& o/ M
113.             $data = substr($buffer, 14);
     
114.         } else  {
     3 k% _1 a( Y9 M' g  i4 d/ V8 R) ]- D
115.             $masks = substr($buffer, 2, 4);
     / [+ g9 v4 Q4 v3 T$ t; p
116.             $data = substr($buffer, 6);
     
117.         }
     + V8 j; i8 y( q& \& L) [
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     , M8 e/ q" ?# G# E& {3 _4 W' r. J
121.         return $decoded;
     0 n' K  H: L! e
122.     }
     
123. 
     / w; X) T7 a1 H: m
124.     /**
     9 ]; B7 W3 @$ m8 a7 R/ }: G( g  V
125.      * 发送数据
     5 k9 W, {3 f3 h' L( e; J* u
126.      * @param $newClinet 新接入的socket
     + D" m; M/ f3 m. U
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     3 p/ Z. Y2 H# B2 v" {( ^9 C2 ~
133.     }
     
134. 
     
135.     public function frame($s) {
     , V: C) g0 C. t9 h7 r! x
136.         $a = str_split($s, 125);
     ' ~" N* G* J9 A. \. F, F
137.         if (count($a) == 1) {
     ( L  L: R, Z. \7 f$ U4 [
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     % j) S; r/ o4 n) F' ~% M, R
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     0 M, R/ B( u8 P: B
145.     }
     
146. 
     ) D$ d% c# q% k* Z. s  ]
147.     /**
     
148.      * 关闭socket
     
149.      */
     4 a% t  [- x' n+ p2 W* ~
150.     public function close(){
     8 d& l' s, u9 ^& V/ O
151.         return socket_close($this->_sockets);
     / K. ?6 v# c4 _( A2 L& I
152.     }
     
153. }
     1 R5 O1 \5 t9 j9 u( x7 w" t0 @& O3 T
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     8 r9 M4 V* t. l7 _: r* B
157. 
     

复制代码

web.html
* U6 `3 K. y3 D3 m7 t5 j3 X

1. <!doctype html>
   1 L/ O, j" R. c6 g$ z) {; i
2. <html lang="en">
   0 h( [6 }7 N8 G- x8 d/ H, z! u
3. <head>
   / E  @" }% ?  Y6 d# J
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>
   # G" w* d% ?0 e
7. </head>
   
8. <body>
   + \" [- D. y9 x5 N
9. <input id="text" value="">
   ( j1 j% L6 M- w5 R
10. <input type="submit" value="send" onclick="start()">
    ) @  [+ ?$ Y6 b
11. <input type="submit" value="close" onclick="close()">
    4 \/ ]5 b. t6 `
12. <div id="msg"></div>
    6 U) _. J7 U3 W* z4 J1 U% e
13. <script>
    , a5 ?& }9 @4 @5 O5 n
14. /**
    ' \9 G0 H- s! m) Y! ?9 H) x1 }
15. 0：未连接
    
16. 1：连接成功，可通讯
    ! b2 V9 l$ i* E
17. 2：正在关闭
    0 c# Z2 V1 q* z+ f4 i
18. 3：连接已关闭或无法打开
      {) T  C% }/ N% [1 @8 |" I% ~9 o
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    ( Z4 Z' T$ n) x7 m
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    % u) ^: @" Z& R% W$ }& l( x; X$ h
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    / k. b% ]3 }  t  T
26.         onError(event);
    
27.     };
    ; n% c6 Y( h# f6 Q/ J
28. 
    , H! M% c3 r, C6 a- S" F/ H7 `' y
29.     // 打开websocket
    ) e0 `  E) ~' |. M% |2 k7 Y/ z
30.     webSocket.onopen = function (event){
    1 e: X( S3 f# p# L
31.         onOpen(event);
    6 j. Y0 v3 c& K- D# t4 q
32.     };
    
33. 
    
34.     //监听消息
    2 S* c, n2 K5 p" r- @1 }
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    4 K. l% b5 G- _8 R* E* a% W. z
37.     };
    
38. 
    
39. 
    2 W  X) g6 q. Y8 `
40.     webSocket.onclose = function (event){
    ' B, {7 t7 j4 `$ T' m
41.         onClose(event);
    
42.     }
    , X9 z' h8 v3 g7 ^
43. 
    . l: L% j" N. h8 |3 [/ [
44.     //关闭监听websocket
    ( M( u4 `2 o& v% p+ l7 k
45.     function onError(event){
    1 f' p( A  h& ?1 i, F$ T
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    5 a- \, _6 V/ ~& k8 ~8 P1 S. {+ E3 C6 W
47.         console.log("error"+event.data);
    & l+ d5 T( G9 R! Z$ g) M
48.     };
    
49. 
    $ V- e  a' U6 Q- p
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    * _% V4 J$ c- H4 A  Q! }3 l
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    7 v: b' s9 h" q" }" K# Q
57.     };
    
58. 
    ; i8 g& `' p* Z6 }8 E9 l
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    : @& W+ z  }( s
62.         webSocket.close();
    
63.     }
    8 O* D- g. i- W0 @
64. 
    ! y* ?6 s8 q1 @9 }  e
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    $ `3 Q, b& {! y; e
69. 
    ' W7 p. I) K6 |" r3 G+ Z
70. 
    9 W8 I7 m) N% `4 u1 B3 j, z
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    # N! H: T4 ?4 W* m% I2 ]& `" U
74.         var msg = document.getElementById('text').value;
    ' ]/ Z# b2 L' {+ M+ x. \. U
75.         document.getElementById('text').value = '';
    * i  W: h" \- j, Q+ L6 L6 f2 {
76.         console.log("send:"+sockState());
    - E5 X! f, L/ ?* t/ K( e/ j
77.         console.log("msg="+msg);
    : c1 [" N. S# F  F/ e
78.         webSocket.send("msg="+msg);
    0 u+ U' e+ {& e# N
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    6 m: _+ x( k1 U  k( z' V
80.     };
    
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    
85. </script>
    " \5 c# u2 \, `/ Q; A8 O
86. </body>
    
87. </html>

复制代码

( C! C' x: }5 @* I3 W2 q