php实现websocket实时消息推送

admin

php实现websocket实时消息推送


' Y5 R8 L" E; jSocketService.php

1. <?php
   8 G8 y4 z5 t* @5 o$ R5 `8 [$ _% ^
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   1 J2 g" }0 o9 ?
5. * Time: 14:33
   
6. */
   3 v2 _* n* `. f, e
7. 
   
8. class SocketService
   3 ]' {& o+ x6 o8 J
9. {
   3 R  G) }2 e6 ]) W4 {* T6 S. S
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    3 q% x, f, H) i$ @7 e7 p, \; r
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    - e% C' o& z4 o- u5 k0 h8 d
18.             if(!empty($port)) {
    ( J! ?" C& v" k; c$ ~% I/ p
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    . I+ O4 t: [  U7 E: N1 e& O
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    0 N9 q6 E  D. [
28.         if($sock < 0)
    1 Y' n& ?0 A0 y- K! l2 N  b7 o
29.         {
    5 Z! A% Q5 z0 U( Z
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);
    & E/ p& }2 S! ^$ G! u) k* e
34.         echo "listen on $this->address $this->port ... \n";
    + c: @, [& y, |& ^
35.         $this->_sockets = $sock;
    5 e4 f; H3 w  @: y) J
36.     }
    
37. 
    / Z8 |$ l. J% E% v% j5 D- _
38.     public function run(){
    " K) i  p$ `: N# M# w! T
39.         $this->service();
    % T: Z7 h$ M. W% Y1 V. l9 S
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    9 e1 s; V: D) K& a
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    8 E5 W7 Z: ^8 a
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    , Q3 e* _, G: H, S: R
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    8 g: @, e# u) `& z
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    : c8 c2 Q7 y% }: ^3 Q
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    ! F# X0 @8 x- s9 `, A  P$ t. k
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    # [9 u* d$ j- }$ K3 E
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    & T7 J9 P2 Z) K/ z: h
64.                     $response = trim(fgets(STDIN));
    4 p/ j" v' K. l+ c- K6 i& f) n$ g
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    
69.         }
    3 m, [/ n" m/ ?; X! q
70.     }
    
71. 
    
72.     /**
    1 H. u: j$ Y2 N4 x( V5 l) g2 x
73.      * 握手处理
    
74.      * @param $newClient socket
    , s2 C, |. W. C& s
75.      * @return int  接收到的信息
    5 M! S  I8 x2 x% g5 }7 A" v* g2 }
76.      */
    
77.     public function handshaking($newClient, $line){
    0 z3 S& a& q" _" g) F8 q' P
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    6 E6 i* }& e% h! {8 _
82.         {
    
83.             $line = chop($line);
    2 t" `0 Q* \/ r0 {9 t' }' U
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    ' G" W( |: h4 t  b$ q3 K
87.             }
    
88.         }
    1 O4 V( }8 m4 W# l0 T7 a8 b0 k
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    + q/ w! V9 U3 ^, x# r7 q! P
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    / l3 j, n( d. K* w3 n5 Q$ z
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    
100.     /**
     & P7 @0 |0 U" c
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     1 o5 _2 D$ W) p
107.         $len = ord($buffer[1]) & 127;
     * g0 _5 ~' h" F3 b1 @  ^0 p
108.         if ($len === 126)  {
     - s- X/ O5 ]- h/ e6 U4 r/ Z
109.             $masks = substr($buffer, 4, 4);
     6 m0 l5 S7 |( ^, j  ], a3 N
110.             $data = substr($buffer, 8);
     - x, A8 j$ V5 {
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     ; H( ?! Q- Y2 m9 E  D# Z
115.             $masks = substr($buffer, 2, 4);
     : o, _! Y. {: ]
116.             $data = substr($buffer, 6);
     
117.         }
     4 q/ V; H- q, `' H
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     4 d3 B) t& x  i3 U& s# S
121.         return $decoded;
     
122.     }
     5 p* p  T) w$ U! M
123. 
     
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     8 Q! h! |& Y; x  {: J- u
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     : H; ~5 {  G# M$ t) |0 r% u
130.     public function send($newClinet, $msg){
     : x* v& `4 K  F
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     % W  Q/ D$ G+ D3 J$ d* Q' p
134. 
     : B' ?. ^. w# S5 P
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     2 `% }# o8 x1 |3 c  k( G5 X
137.         if (count($a) == 1) {
     1 @+ c! T& d% |; h: E" P. p$ _6 q
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     / R; V. D! k( D  }
139.         }
     2 c0 ~9 t; Q9 A! Z/ B% O1 i
140.         $ns = "";
     & X; q: y# M/ J  S+ J5 ^
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     ) g) i; T& I$ B% C$ y4 ^# ?
143.         }
     
144.         return $ns;
     
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     9 x/ d' O& q, [4 \  x% q( |
152.     }
     
153. }
       \! f5 C' ^, ?. @
154. 
       N8 S) a1 I3 Y  |2 O8 @
155. $sock = new SocketService();
     
156. $sock->run();
     4 g9 ~9 n' C# d  b; \! \3 S
157. 
     8 N9 i( j& |2 ]+ B+ m$ G6 ^( k

复制代码

web.html

1. <!doctype html>
   ! b" ~, P$ ^1 t+ ]9 o" }
2. <html lang="en">
   
3. <head>
   4 u  m  ^  W- K4 O- F7 }: q0 T2 \! X
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   4 T; o/ f9 J7 g- N  I4 \6 C
6.   <title>websocket</title>
   4 c8 U3 C% o# Y6 P2 B" s% t
7. </head>
   " Y. ^7 w+ {7 v3 w: `% ~8 p
8. <body>
   . {/ T, z6 H7 f8 y8 a% p* u% c5 \
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
      E) t9 |4 Y) W2 R
11. <input type="submit" value="close" onclick="close()">
    " d+ y# l  ]6 q- o" N
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    ' s4 O& }" Y7 V4 P3 |7 D
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    $ n( r- v1 ~: e
18. 3：连接已关闭或无法打开
    ) Y& m  {6 \( y% v# F( E/ s8 }
19. */
    
20. 
    6 Q" l# q. A1 ^& ?9 }- i, T) }
21.     //创建一个webSocket 实例
    ) K" D; x8 z) N
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    ) h, x) \# H: h$ k3 Z/ {
28. 
    
29.     // 打开websocket
      w* _3 s5 @# p5 S8 Y' R# b" H
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    1 y( m% l! E, T1 Z+ f
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    $ U, Y. E9 ]  Y4 M2 S* Z7 h
36.         onMessage(event);
    ( A9 G3 r& _0 Q8 r- \8 u# `
37.     };
    6 ?9 R, C- H: b5 O+ a
38. 
    
39. 
    5 m; m- c0 x7 _5 T4 L; r* m; N0 _5 q0 d
40.     webSocket.onclose = function (event){
    : n* f# d( w. J( B& R, J( Y
41.         onClose(event);
    1 w: M, H% x5 l+ `$ F9 @1 _' d9 V
42.     }
    
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    & G6 K. P% M; G7 u0 k( K( t
48.     };
    
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    / Q! a0 y0 E- }! w7 y
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
      `4 O, h3 t1 E/ I
54.     function onMessage(event){
    
55.         console.log("onMessage");
    - E8 a- J3 l: }+ |
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    + C7 A% b* k( a7 e' C* b9 H0 x! q
57.     };
    
58. 
    ! P9 B) L: j7 g
59.     function onClose(event){
    ' g# s3 V6 s( }( ^4 i
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    : d' R- M" k, T# a0 E. z+ v0 }+ ~
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    - C9 ~) z+ u. o4 A: P) m: y" {- p
68.     }
    & I& h4 L9 b# U* d' Z4 g
69. 
    # b; i& e6 y1 B
70. 
    . m0 I& q& W) Q) l) E- i
71. 
    
72. function start(event){
    . J1 ^- i, K5 _: y( S! A" _
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    8 f  e) _6 T  }' h- n2 R
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    % N; \" @: b, ?" J" E
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    0 I+ Y1 n/ N7 S: e3 I
80.     };
    
81. 
    ; z1 n% I5 t. u# d  y
82.     function close(event){
    
83.         webSocket.close();
    4 I5 N1 E3 `& u$ ], `& r9 Y3 y
84.     }
    
85. </script>
    
86. </body>
    3 m3 D4 t) V1 m, x
87. </html>

复制代码

' N2 E1 S% ?& Q5 R