php实现websocket实时消息推送

admin

php实现websocket实时消息推送
. x$ L5 h7 ]* e  O/ `* p3 h& U1 K

- |; ?6 H: T3 n0 h# ~! SSocketService.php
: _4 d; D0 X5 d

1. <?php
   
2. /**
   
3. * Created by xwx
   - M! S3 F6 ]$ x! Z
4. * Date: 2017/10/18
   
5. * Time: 14:33
   . Q. R3 X6 h; D* U" n' \/ w
6. */
   # c% U. ^9 c' @6 u! Y" j8 z9 h8 I7 z* R
7. 
   % r1 c& p* I9 w
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    ' x9 s9 P' \0 x
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    ! ^5 o- {8 C8 V  U, h! B3 S
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    & b6 Z, K: H# w" N! c0 U" f, u
17.             }
    
18.             if(!empty($port)) {
    : q' T" S7 [. H+ z8 T
19.                 $this->port = $port;
    0 p; r2 A$ j4 A& p! E: x( `
20.             }
    
21.     }
    , o- @4 |% F* W2 T9 h
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    * m9 x' \+ o: o0 k
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    ) i6 @( N9 c5 {' _* [
28.         if($sock < 0)
    0 l% L- R2 P$ r$ D% J" X
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    : w1 E1 v0 D/ b+ l7 k8 u- a
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    6 ?6 _, z9 C& Z
33.         socket_listen($sock, $this->port);
    + ?% ~0 a$ n' P, \! t
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    3 t0 U% g% l: o6 F! v: P
37. 
    
38.     public function run(){
    ) M! ]) o5 }3 [  D
39.         $this->service();
    : m$ F: g: w; }- {: i- m  x3 S* |* W
40.         $clients[] = $this->_sockets;
    , W# ~% A& ~$ S2 ]/ [, c
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    ; W" E( y, Y' ^" Z4 _
44.             $except = NULL;
    ( d4 U4 f/ [) s) h5 p3 }0 W
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    8 d9 O/ W$ R7 f: |
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    ' [$ \7 q+ U6 Q6 M
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    & [* f$ ?6 N  ^/ E- _3 \: S* n
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    / M/ Q4 K( Q' T5 m1 T
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    4 Y; Z4 |0 m' h6 y4 e* u* C$ ~8 [
56.                     echo  "Client ip:{$ip}   \n";
    % u- r/ t0 @% s) w6 }2 `
57.                     echo "Client msg:{$line} \n";
    ! W, h9 B& L: `! R. G% j* [9 A
58.                 } else {
    % [7 }* S: z# ?) t
59.                     socket_recv($_sock, $buffer,  2048, 0);
    - i# U: A- j; c# n. Z' d
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    ; {  K' d, {' j! D# {
62.                     echo "{$key} clinet msg:",$msg,"\n";
    7 E4 z$ H! _* Y6 Y1 T
63.                     fwrite(STDOUT, 'Please input a argument:');
    7 Z3 k7 R3 }) N
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    / i4 `5 B& g7 T! G  e1 f
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    
69.         }
    
70.     }
    . W" L' p7 u! v/ {
71. 
    " H; e+ @5 S$ x4 t2 c" M
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    " i, h9 b& _+ y
77.     public function handshaking($newClient, $line){
    
78. 
    : C- d; s1 o$ z! b/ s% s2 K
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    6 A! b: r' E0 h
81.         foreach($lines as $line)
    " G3 l" P- z7 q: E8 ?8 l
82.         {
      b  W3 O& |2 R0 W; A: h; t  w
83.             $line = chop($line);
    1 a; {, j2 I% P/ x& f1 b  F' F
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    # P. r8 n3 t6 T. y7 N/ z2 _7 a( v
86.                 $headers[$matches[1]] = $matches[2];
    7 C2 R( J- ?1 P5 f4 F: k9 g, A* k9 t
87.             }
    : i2 j6 b$ w0 j9 `9 ]; f! O; Z
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    ! f1 [0 z9 ]+ e. i
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    7 f! f5 H. A2 Y# C3 p* N2 c8 \
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    : ^2 ^# I4 Q0 Z: }1 l; y: U
93.             "Connection: Upgrade\r\n" .
    ; M8 a9 x2 @" w% I. ^* c
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    6 b( ^8 v: B* G. Q7 o
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    & o8 t3 R7 B5 s
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    % w& f3 F/ r2 O3 U
98.     }
    
99. 
    " ?; F: N8 q, i
100.     /**
       h3 J( ~9 ?% p* f9 S/ v; k
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     2 t7 C+ n8 O9 r- B2 [, R+ F
104.      */
     5 W  f! ^! \6 P% O2 `+ X6 A
105.     public function message($buffer){
     6 s3 f9 N2 T- F+ w. H* B: I9 R, X' E
106.         $len = $masks = $data = $decoded = null;
     " K4 f  m6 c0 K, t" j' `4 p, W: K
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     7 M- ?$ a7 x0 l
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     0 F9 Z* K7 w: i" l8 z
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     2 ]* A, s3 ~, h7 `$ V
114.         } else  {
     . o! ^- `- v5 d. k5 V9 m  F- J
115.             $masks = substr($buffer, 2, 4);
     % o3 |' e0 g# m
116.             $data = substr($buffer, 6);
     / k- J7 P6 z# H) D' k) F
117.         }
     1 e1 o" L* G/ c6 Q$ l. H
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     0 f7 e% m: h, l: K5 B0 {
121.         return $decoded;
     1 z0 l- Z$ {! x% G9 R) j; v
122.     }
     9 n* v; x" R2 B2 w0 t
123. 
     
124.     /**
     
125.      * 发送数据
     0 b" i8 _/ k8 L. v9 K5 J
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     * H8 f- s' e& ]0 Y4 J' W4 C# \
128.      * @return int|string
     1 s$ `7 E$ c4 _0 b# d
129.      */
     6 n- q3 s6 ^# ^3 a# K  J# O" |
130.     public function send($newClinet, $msg){
     0 g# I3 [1 r- P& {
131.         $msg = $this->frame($msg);
     3 z6 O! b5 R1 s
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     " D* n6 ~- k" n3 o- r: M. ?; U
134. 
     
135.     public function frame($s) {
       M& o1 x1 l8 `  l6 d, D, `
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     , Z) R, c4 ^0 D
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     ! q4 g- }5 l( y) \7 F- t& C
141.         foreach ($a as $o) {
     ! Z# P, y0 e- y% U# s+ K
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     3 s& V' w6 f9 A+ u9 W
144.         return $ns;
     
145.     }
       ?1 f& l/ T$ F% P/ h2 V
146. 
     
147.     /**
     & Q- G' [2 K% C! r8 y; x; @- M
148.      * 关闭socket
     8 j8 B- e0 D" Q6 Y8 L  a; F
149.      */
     " E) U( s3 Z; r3 u" y3 H
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     & G  {( r  Z8 ?; t: E
154. 
     1 A: q: ]2 |+ E9 c. j) X" v
155. $sock = new SocketService();
     , i, I( w* a, a
156. $sock->run();
     
157. 
     0 D# K% x- d# l  o% W6 K

复制代码

web.html

1. <!doctype html>
   ( P+ }6 Y$ U" ]$ j
2. <html lang="en">
   
3. <head>
   
4.   <meta charset="UTF-8">
   . P7 I# }/ z% {" V* }. V: c( d9 r' }
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   # {- O4 P+ b0 ]6 r0 P2 g3 N+ o! f
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>
    + ^0 d2 `9 N! `( o9 u: E
13. <script>
    : E3 w8 g* P  A
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    1 U& N! E7 P6 P, f# y
19. */
    
20. 
    8 y6 \4 L. m. }! \1 h( W. k9 m
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    2 d: l. m& E# D" n- s( C
23. 
    " t' n' ~. M( \1 {2 y4 U0 a+ v# Q
24. 
    * O& a4 k/ r- ?" `0 F2 M6 {
25.     webSocket.onerror = function (event){
    ( D& h) M4 Z& n! p, k% P
26.         onError(event);
    * x% e% V' ~$ u4 m; I4 C( l
27.     };
    6 j* o/ i8 k# _$ n. l
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    5 l5 V8 A# D  c, B% i
33. 
    " s5 {! E* j8 u- }5 {
34.     //监听消息
    $ G* z  N: W# m$ J" @+ d; {
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    $ c) o* `" c$ A! {9 j
37.     };
    
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    . ?1 R' L2 Z5 A
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    
50.     function onOpen(event){
    ( h5 ]7 [; F2 j0 @, U
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    ; N) a% P, a6 ^$ k4 J# u( M3 [
53.     };
    % J( ]/ r/ M$ U7 D7 d' \/ |/ G
54.     function onMessage(event){
    
55.         console.log("onMessage");
    8 r2 Y0 ~" f) P3 c4 O* C% D
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    $ T0 V6 H2 N) _; n7 {' V0 p
57.     };
    & h" _! K. Z3 a+ d
58. 
    ) W. p, `, T9 s2 S
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    / I: E) A6 _% J% |$ i/ b
61.         console.log("close:"+sockState());
    & M; z! E, Q) q2 W( s$ M- x
62.         webSocket.close();
    
63.     }
    
64. 
    # {* t# M) I4 c) K* r& h! _: x
65.     function sockState(){
    1 W$ L* T8 u) `3 C1 o: N
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    0 R! L8 y/ D1 b  G6 y
68.     }
    
69. 
    
70. 
    
71. 
    
72. function start(event){
    ! X3 S" L, H$ S8 R0 f
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    ( g3 F: Z6 ]8 N$ r
77.         console.log("msg="+msg);
    8 I4 s" D% R( f9 a
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    ( L: M( j  u6 K7 W- `
80.     };
    
81. 
    
82.     function close(event){
    ' {! R9 q' [2 w4 p. H- W
83.         webSocket.close();
    - `/ s, r1 V$ h# i
84.     }
    & Q8 R' b% N4 T0 z% M1 k  e
85. </script>
    
86. </body>
    ( W2 Z( k% t/ H3 h9 L
87. </html>

复制代码

3 M7 j/ l) M1 B& J' a6 g6 Q* H! j% W
5 w9 g, E8 g1 R# j