php实现websocket实时消息推送

admin

php实现websocket实时消息推送


SocketService.php

1. <?php
   
2. /**
     i' P5 w' H3 ~6 f% {, `
3. * Created by xwx
   
4. * Date: 2017/10/18
   : t+ K' D8 k6 s, U) D; ?
5. * Time: 14:33
   $ M' P0 o5 t- E9 v7 Q, d
6. */
   ( }4 E/ [% B# t! q
7. 
   
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    * Z9 A' M! K) d' m9 J# d$ L; \
11.     private $port = 8083;
    : N2 E: G  ~8 X
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    7 h# ?& A' @; ^1 K: W# J4 G0 \
14.     {
    ( k* z, n! x2 a4 P; J: f0 y4 Q
15.             if(!empty($address)){
      n6 Y: j6 f) @' d
16.                 $this->address = $address;
    
17.             }
    1 r6 j" I) c( `$ |6 m( B7 h! H8 D
18.             if(!empty($port)) {
    - G2 E/ F4 ]( r
19.                 $this->port = $port;
    8 f. j, b; S3 i+ e# [+ Y
20.             }
    
21.     }
    # o4 {0 @/ Z+ U5 o
22. 
    . {8 p$ }0 b: X2 x. {% n6 B
23.     public function service(){
    $ M2 I1 t: b# x9 |! a  f
24.         //获取tcp协议号码。
    
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)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    + a6 m0 x& G) r' J/ K' t- f
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    6 d  ]' O+ l3 Z4 c  s4 i
33.         socket_listen($sock, $this->port);
    3 a0 Z: m, ?  \% g0 A
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
      C- U/ q) m! c5 b! \6 q
36.     }
    , r" I0 P4 I" g8 f
37. 
    
38.     public function run(){
    
39.         $this->service();
    & h1 d+ t3 Q4 L
40.         $clients[] = $this->_sockets;
    . `) }3 L/ m. T& k5 o
41.         while (true){
    
42.             $changes = $clients;
    2 E: G) c4 N8 J
43.             $write = NULL;
    
44.             $except = NULL;
    8 }0 ?* O" h$ x# W$ ]
45.             socket_select($changes,  $write,  $except, NULL);
    7 I% V( a5 J( U' H6 I
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
      v) l6 a7 ]2 e
48.                     if(($newClient = socket_accept($_sock))  === false){
    . S$ e( e  A3 Q% D0 q& I1 Q% ?
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    ( m8 i/ ^/ C8 U( g( E6 L
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    ; C+ o7 j- l3 ?( K) [; h
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    ) e$ w# n( c- g: T) B. V
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    ! i/ \. o# j& Y0 Z; d. S7 `. Y1 P% u
61.                     //在这里业务代码
    
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";
    # H* h% T, m7 D5 O  G
67.                 }
    
68.             }
    
69.         }
    
70.     }
    * R8 o) y9 o. E5 H" w8 o
71. 
    ) c7 N& z2 B+ i5 v% T
72.     /**
    
73.      * 握手处理
    8 {* K) r, ~3 q, T" I
74.      * @param $newClient socket
    ! B3 H0 O% N( j6 T) g" f6 i+ w
75.      * @return int  接收到的信息
    
76.      */
    + J) i$ ]' R6 t3 m0 L8 y% c. m
77.     public function handshaking($newClient, $line){
    3 o; `% t3 g: c
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    - ~# e2 z) S3 e4 O* B9 T
82.         {
    
83.             $line = chop($line);
    4 d! W- x4 X' }5 s6 r+ ?
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    1 w2 ^# u  O. B, ?1 `
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    $ W4 t' B5 w) T( u& z
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" .
    , i: D) F1 V8 m$ J" s5 D  j9 C" Y
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    " _, @' z% z/ I& n: [7 `: k
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    - X+ d$ y" o1 }) }
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    5 ~6 P  I0 q+ d5 A
99. 
    $ j, X7 T7 N: \* R/ a/ ]
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     9 K1 M" A5 l# e4 ~0 x/ L$ o& g
104.      */
     9 ]8 Q& U3 V- Z& B
105.     public function message($buffer){
     7 F3 s1 C) f; S3 N
106.         $len = $masks = $data = $decoded = null;
     ! ^0 i( x6 ]1 R7 ?8 _! u
107.         $len = ord($buffer[1]) & 127;
     ) p4 b7 ~  ]* X$ C
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     - O: X9 p+ N% i  j; n
111.         } else if ($len === 127)  {
     2 ~3 P+ @: e$ H  y5 A, R
112.             $masks = substr($buffer, 10, 4);
     0 V, f" v- U# X+ X2 p
113.             $data = substr($buffer, 14);
     2 e$ k. g1 @  ^
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     ( j7 z  I! M) G+ p
117.         }
     # }4 E1 C6 c* t& @" R
118.         for ($index = 0; $index < strlen($data); $index++) {
     2 w0 c" P& M/ U5 ]) G4 D4 Y, x
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     / z! P% u, x2 l8 v! S
122.     }
     
123. 
     
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     ( d/ o- n- L2 `, I. ?( B
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     : _: V  _! A2 C- R* U4 g" {0 G) C* g
133.     }
     ; B- a. q4 c/ Y9 B- J
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     0 E$ u% H1 s. E; t' y# V8 O6 n
137.         if (count($a) == 1) {
     ) g! ~4 v* f. h7 E7 Q+ T
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     / s7 D$ u! d* e- o
140.         $ns = "";
     1 T8 h  _; n  x
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     ; d# \* k/ n2 r5 m- `7 d0 U5 x
143.         }
     6 T; a! c% Q+ `/ g: F& C
144.         return $ns;
     ' q" ?9 ]  q2 Y0 n6 k- G
145.     }
     
146. 
     
147.     /**
     ) F# l8 p4 n4 k7 K% A( r
148.      * 关闭socket
     
149.      */
     ) N. Z4 V; x( B& |( p
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     * f9 U6 t2 R# o  g; s" k, h
153. }
     
154. 
     - L' r' r% s3 e5 E, A5 J( J
155. $sock = new SocketService();
     - O6 |' ]8 N. J* K9 @& i( u
156. $sock->run();
     
157. 
     2 i# s: g4 }9 [2 n( J

复制代码

web.html

1. <!doctype html>
   ' R0 P5 g% i" I) V; r+ k
2. <html lang="en">
   ! ]0 _0 ?; S  ^; I& p+ h0 D, D& q7 v
3. <head>
   ) K1 R+ T' x4 v. y' ?  F& S' n
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>
   
7. </head>
   $ x3 W/ S! n1 s  R( P
8. <body>
   0 l6 u/ S4 k& R1 f
9. <input id="text" value="">
   ; e8 |( u( ^1 J0 D+ ^7 ^
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    # d3 ^% Z+ A0 c0 O
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    4 B' Z5 n; E1 y3 F
18. 3：连接已关闭或无法打开
    - c9 w1 H2 \0 ]. U& i5 t, h
19. */
    ' P' X/ Z# |4 Y7 l6 ^* O6 r
20. 
    
21.     //创建一个webSocket 实例
    5 ?' h! }" c4 O% f$ Z, E0 F# Q
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    0 f# a- H+ o0 _  K6 G* X9 `: u
23. 
    
24. 
    ' J  Q  t6 Z, \. S. @: b$ ?
25.     webSocket.onerror = function (event){
    1 a8 F+ N0 g' k& N
26.         onError(event);
    
27.     };
    
28. 
    
29.     // 打开websocket
    ) g2 j! \& M; _* k4 W$ b1 f; ^
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    
33. 
    3 K$ ?! b, Z9 v9 @+ u
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    : ?. v8 }3 B5 a& O; u" C
36.         onMessage(event);
    9 }8 i2 y  G% O. g+ N/ k
37.     };
    0 Q1 F  ^' W3 p# }% g
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    + O7 I' R3 N) ~- m8 E
41.         onClose(event);
    $ K0 ?& c0 w+ h9 g) p
42.     }
    8 Z$ n; S! f+ U: N. ~7 @/ c. d
43. 
    * v$ f% A$ R9 _* G5 D0 [! W
44.     //关闭监听websocket
    
45.     function onError(event){
    2 k, T, q$ m2 ~9 d0 |
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    * I% a5 T9 k$ M$ W# s8 v9 q
47.         console.log("error"+event.data);
    $ D1 z& q" j8 a3 p. T& [! _
48.     };
    
49. 
      a3 M1 h" Q0 f$ V/ |# E
50.     function onOpen(event){
    * Y8 W- b; |( b/ q( x
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
      R6 O0 p; g+ l9 z( ^& S' M
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    . O, p6 X6 V& S! W
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    . A0 N0 `3 x% n  K2 K& f/ U
64. 
    - W( A6 D! v, E. o0 j
65.     function sockState(){
    : X; Q% A7 s$ a1 |' x4 Q8 M7 r
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
      @2 c3 g( q; L0 U8 a
68.     }
    5 h8 a/ z/ X. ?3 X
69. 
    
70. 
    - N' I& y5 a5 k' D2 [
71. 
    
72. function start(event){
    7 X) ?) G# I6 f" Q" G
73.         console.log(webSocket);
    , _! n6 G6 R8 c- r* w
74.         var msg = document.getElementById('text').value;
    $ m) W! p& R! w
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    8 e+ ^5 {9 `2 V& ~
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    - O, U9 E; g+ N0 c6 R1 S1 N' P& S
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    4 X  ]: Z6 W0 z0 O7 C) n
80.     };
    1 ?7 M8 _3 i. F2 {( [# R+ Y
81. 
    # R! e0 i) V9 Z7 h
82.     function close(event){
    $ E* @, |; \) O1 D% d8 _8 @! o
83.         webSocket.close();
    
84.     }
    : Z. D! T" x6 j/ G
85. </script>
    ' E+ P  l' M" `, ?; R
86. </body>
    . ^7 b4 H) |6 J) V2 G
87. </html>

复制代码

# r, L- E1 M5 B8 X