php实现websocket实时消息推送

admin

php实现websocket实时消息推送

9 m& y0 \# Y- `% }
* M) D7 j+ q+ TSocketService.php

1. <?php
   # ^% G3 r/ k* d/ J
2. /**
   % s& [0 m3 O+ I0 p/ q
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   - o* a* O/ n5 [% l# W* @) j
7. 
   9 N7 [  A; |6 h) T5 m  ^; T3 R
8. class SocketService
   
9. {
   - e' z+ H2 ^7 n3 l& G
10.     private $address  = '0.0.0.0';
    . @4 v9 r6 Y  L6 r8 y" ~7 N& a  m
11.     private $port = 8083;
    1 ]( B) c: }4 ^. L6 t7 F
12.     private $_sockets;
    7 c. r* u8 X% ?' s  s, e# J
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    ) n& Z) D5 y) w
16.                 $this->address = $address;
    ! p3 H$ |, U% N7 M" A
17.             }
    
18.             if(!empty($port)) {
    5 @' V5 P* W; C
19.                 $this->port = $port;
    1 I+ O; A2 p9 p4 ~5 V
20.             }
    ! V% a3 _) n) g: q5 M6 r. l7 K' c
21.     }
    , x8 y6 d7 T. O0 x
22. 
    
23.     public function service(){
    " H% p+ S; X: F* p# U# Q
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    / P) U, {0 W+ h4 |
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.         }
    ) r% n: i& u, r% C% y
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    # j$ R& z) z/ T8 A5 [
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    8 l3 `! S( o7 |3 Y) `" E5 A, F
41.         while (true){
    
42.             $changes = $clients;
    4 U& K& a8 w/ I0 y7 Q! V/ B
43.             $write = NULL;
    8 c8 R% F8 U7 N- N* b
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    ! g8 C0 e  f' t5 Z' R' b5 p
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    / U1 U9 I/ [9 {- A' L  e4 j4 k- a
48.                     if(($newClient = socket_accept($_sock))  === false){
    " O) O) L* U0 t) m' K
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    9 G+ W: Z; a$ t# k
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    8 f' i3 o" i# a& F
54.                     socket_getpeername ($newClient, $ip);
    % ~+ z! y! g4 D" A  J
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    7 H& K+ \' Z9 J5 s# S8 v
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    ( X& J, v* s2 M" f( R
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    3 Y2 k; a2 V* `5 h- B9 l
63.                     fwrite(STDOUT, 'Please input a argument:');
    3 o5 Z5 h8 i! E/ L# X4 J
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    8 H2 e0 i2 S0 p0 [& `# d7 b1 H7 ~
67.                 }
    * N$ S/ w9 o+ b( l
68.             }
    
69.         }
    ( @8 T, w9 F' r  s) [4 p
70.     }
    
71. 
    
72.     /**
    
73.      * 握手处理
    4 g. M  V0 p0 a  K: y' D4 C
74.      * @param $newClient socket
    ) r) \- X) }9 p8 k+ X3 a
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    / m: G( S6 _7 X! N+ O+ {+ g/ N
78. 
    ; x5 F% u$ N6 z; B$ f
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    % p! e2 d0 ~$ S1 Z+ e6 Q
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    9 E# m4 R2 ?/ n: q2 o; o' y* H2 F( q
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    : k* Z. W8 @4 D5 f
87.             }
    ! n/ R  {) v7 J0 y
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    ( C/ i# C5 D/ o8 K- j
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" .
    . ~, E, ^6 I- z( f+ p
93.             "Connection: Upgrade\r\n" .
    & E1 M4 R$ @4 Y% r. Y5 t
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    7 ]5 i& R8 W( h4 w! L) A* r1 @0 S
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    8 V4 _5 _5 ^7 Z$ U+ j- e, [
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    $ D% y5 a7 M# _4 h- o/ V$ h
98.     }
    5 T- D( I5 s  L' U8 t5 D
99. 
    " b9 R1 o8 J' o3 l1 L8 Y
100.     /**
     
101.      * 解析接收数据
     7 }# K% m& C6 d7 x9 ?
102.      * @param $buffer
     
103.      * @return null|string
     ' A9 T3 i+ g- [1 e5 J8 W
104.      */
     $ {& _/ b2 C% u& T5 h
105.     public function message($buffer){
     ! L- m! J" u- L) h9 T. s+ ~$ w
106.         $len = $masks = $data = $decoded = null;
     , T; S( h! o% r! j5 U
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     " b5 S1 S, Z% }) V' O
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
       T! r1 l) `2 \% i
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     ! h7 W. z: w1 w+ I8 U
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     8 N! K) M6 `9 a; O: X$ t1 H6 [
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     3 M9 q" B( u; U5 r. t; u+ s
122.     }
     
123. 
     
124.     /**
     4 _- Z$ M6 @( w4 S: K
125.      * 发送数据
     9 [* V2 Y! t( M, f! T9 B. O
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     . U2 @1 l" s, F% ]8 L
128.      * @return int|string
     : p& \! J! M, C- {" S2 e! b
129.      */
     
130.     public function send($newClinet, $msg){
     + N6 }' k& W8 v* }  b1 F
131.         $msg = $this->frame($msg);
     ' f& x; ]: v" z5 o' y
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     
135.     public function frame($s) {
     1 h- c6 {  i8 K  u9 E
136.         $a = str_split($s, 125);
     % R8 f0 G' [$ b& T9 `4 D* `9 |' p4 d
137.         if (count($a) == 1) {
       l, @  X+ ^/ A# I
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     + ]* o; n& t! E: J  p9 |& g4 A
139.         }
     
140.         $ns = "";
     + t: E3 P7 _% d/ S, ^+ f% j0 I
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     ! t1 @' ]# N' R6 O7 V3 i2 y
144.         return $ns;
     . @7 B4 n# {3 Z; W3 V
145.     }
     
146. 
     
147.     /**
     0 R7 d2 Y( [2 b" u4 [( ~7 g, I
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     + D, m" n, n' h0 L  Z
152.     }
     / N' ^5 k3 U8 w+ M
153. }
     $ B* |  f$ F4 N  E( y
154. 
     6 Z: K, c0 g2 W" |
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html
. {0 T- [1 _3 L8 e* c' g- i

1. <!doctype html>
   ( h3 e0 v8 i  E3 `5 W# U& A
2. <html lang="en">
   1 d( b. x) t2 j+ ^; u  ~
3. <head>
   8 S* n; F/ p1 E, Y
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   0 I" i- O: k: X, E: O; w: K
6.   <title>websocket</title>
   $ j/ S' C% |0 D) I1 p5 z
7. </head>
   8 V. v, q! }; w4 B: e1 B3 |
8. <body>
   3 u" O$ |# B' P4 A9 S# J" U
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    * A( v& j. d  L$ ]% h+ P( K
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    # E. X* o. ~) N  L6 G' ^, `
14. /**
    ' l5 q9 E( a; C4 ], D( t# U
15. 0：未连接
    
16. 1：连接成功，可通讯
    5 w7 O8 @* a0 [- ]( ]1 a) Q, C
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    0 B% c4 I1 G6 N6 p, z5 c
19. */
    / d, G3 [' s3 m
20. 
    6 P( o% Y# z+ R8 \
21.     //创建一个webSocket 实例
    / Y- z$ f/ }+ W' o: o# W% S* h
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    3 ]# t  c/ |) R+ z
23. 
    5 p% [2 c9 z* {/ w. W+ @$ V
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    ! H+ ^: b( g( X8 F  E
27.     };
    * A3 E( h: B' d8 O, Y$ D( b4 i* Z
28. 
    0 X2 O8 {( T& i' E* {, h
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    1 w2 a3 h! u6 M1 t; T- }6 C7 k
31.         onOpen(event);
    8 m  y) a9 x5 |7 U' s
32.     };
    
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    4 D  r! X: j2 s
36.         onMessage(event);
    
37.     };
      `& u0 E. l9 T$ w. |. j0 W% m  f: r
38. 
    
39. 
    6 w" r* ]7 t3 A' [1 e
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    0 n8 o+ @; M5 h- N! A4 \4 K
42.     }
    
43. 
    # J& s, L0 q) O% q5 E4 c$ T* @  s% ?
44.     //关闭监听websocket
    
45.     function onError(event){
    & {( X4 ^; x" G( z; Z
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
      M3 [* O9 q) j2 [: O
49. 
    
50.     function onOpen(event){
    + m/ G. Y$ o( W; P. N! y
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    * d) r1 f- r3 ]; u  B9 J9 U; `
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    " x: a0 X9 Y; R( f7 l$ W: j" c; I2 t
58. 
    , z1 m8 Q3 v  _% N0 J/ G# p* b
59.     function onClose(event){
    ; W7 p  g$ t/ B! p& y7 f2 ?& n
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    + J0 A6 i% {$ ^; y( E$ @# Q2 U
63.     }
    
64. 
    ) U. H" B& V2 s8 C  F7 N' }
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    1 {& E  ~1 \  v3 N7 ]
68.     }
    
69. 
    2 y% X* \" v. q2 E( O1 S
70. 
    
71. 
    % M, D- N/ B) R. U3 d
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    - z7 Z% ?. V1 V5 u) Q0 M
75.         document.getElementById('text').value = '';
    $ a8 u$ s4 `6 S. ]
76.         console.log("send:"+sockState());
    ' ?9 ]+ U8 _1 m1 d
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    4 J) |+ x5 O5 F; d; K. V& j
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    4 t; r, t1 |' b: [8 |. j( O: P# L
80.     };
    
81. 
    
82.     function close(event){
    0 }3 R  n5 B* I: @5 P
83.         webSocket.close();
    
84.     }
    
85. </script>
    2 k& \9 [: B9 j9 E& c
86. </body>
    
87. </html>

复制代码

/ ?$ b1 \" K/ _7 Y7 Z
7 e2 _( f3 [) O4 J4 z/ o' r