php实现websocket实时消息推送

admin

php实现websocket实时消息推送
* P4 G; L# [' t$ d% h7 D2 k
* H; {; ]- T5 E( l, |+ Q, P. N
SocketService.php

1. <?php
   
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   , e% p' L$ V3 _
5. * Time: 14:33
   
6. */
   
7. 
   / ^* C# M: `0 p( ^/ N8 l3 b
8. class SocketService
   % \  g7 _) {4 x* v7 D3 ~- ]
9. {
   $ e. @, G+ k5 S. }
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    7 G6 r- K* x# p! T. w8 k
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    4 e! `3 q7 {2 b) s6 S. b: w- E3 t+ V  U
14.     {
    6 @# c9 R" Y  A! ^* N
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    ! ~$ x/ o  W( z! l% X& u$ I0 b+ i
18.             if(!empty($port)) {
    " ^. _' ~: I0 {  n. C+ ], D- k
19.                 $this->port = $port;
    7 r. y; W$ ~- q# |6 [0 c
20.             }
    
21.     }
    
22. 
    4 D0 M, Q% {) M, g* W
23.     public function service(){
    # x# C. L/ [! W* F* h) a
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.         {
    6 C4 {5 F: f) Z6 v# L2 D
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    9 X7 I- Z& I0 R) \; R
31.         }
    + v% m$ T3 m8 T9 C0 i3 R& m) B
32.         socket_bind($sock, $this->address, $this->port);
    1 t3 I. u0 H: ~. e3 f
33.         socket_listen($sock, $this->port);
    - `8 g* ?- q& i! b) n
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    ( H! i  l& N4 M
36.     }
    2 y( w; W( N* |6 A# M
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    2 y4 t) [1 g; C' @, s) o( a/ b
42.             $changes = $clients;
    * A& ~# x: y1 v. S
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
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");
    7 q" O8 K; u6 [
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    2 b3 c; S" F4 N
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    / i; T1 C8 ?& H4 z
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    ' ?0 ]7 r5 u) z/ K* g  ~$ X
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    6 V; r9 \4 E9 N9 z( a
61.                     //在这里业务代码
    * x  ^4 j, Z$ w
62.                     echo "{$key} clinet msg:",$msg,"\n";
    6 e0 y0 H0 p1 s3 K$ }
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";
    
67.                 }
    
68.             }
    
69.         }
    
70.     }
    
71. 
    
72.     /**
    0 i  o8 Z- V! c2 p3 [1 q+ K
73.      * 握手处理
    
74.      * @param $newClient socket
    9 y5 j: T7 R2 i; S$ J
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    " T" s' c- X, b" f: ^
78. 
    
79.         $headers = array();
    $ W4 ^+ _/ Z& c# K; v+ W. S1 v0 Y/ R
80.         $lines = preg_split("/\r\n/", $line);
    $ G! |1 t* i5 z
81.         foreach($lines as $line)
    9 Z4 v1 n) t/ o2 U/ m+ k" o$ d! |
82.         {
    0 \& w8 p$ V) o9 b& g: C; f
83.             $line = chop($line);
    * G" S4 e6 z/ m" F7 `4 e
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    6 E; A7 r( H; f8 `# R) P- y
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    , m  w# s0 @3 g+ h% X
89.         $secKey = $headers['Sec-WebSocket-Key'];
      X1 }" i# C1 e
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    ) }8 s0 R, S* i, a, }$ w3 D" j( U
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    $ g5 H4 R" P# p) O9 A
92.             "Upgrade: websocket\r\n" .
    % Z: ?' m1 b, Q4 d" W& {% c0 k
93.             "Connection: Upgrade\r\n" .
    : X5 a! M" }3 ?% U. _# F& l% 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";
      h8 m/ K. ]' @3 d7 {. i* |% Z
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    
100.     /**
     $ w& E6 K4 V: Q6 @
101.      * 解析接收数据
     6 y& k* H3 _& P! {: x: h/ r5 ^
102.      * @param $buffer
     8 y1 F; Y" V0 ~; Z/ }
103.      * @return null|string
     4 B" l1 w+ P3 r% I" C, q3 B0 q- ~
104.      */
     + R% F# @* }  b3 C
105.     public function message($buffer){
     : f4 {9 _* M! O0 j6 h
106.         $len = $masks = $data = $decoded = null;
     - g/ {" {/ c9 }2 a% a8 f
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     ! x# T8 V% F/ R$ I( A! C
110.             $data = substr($buffer, 8);
     * P7 E  L# F! y0 R* v3 h
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     ) ~# g2 q" @: x) C/ X
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     # [6 }" v. Q& M
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     & [1 J. j. J1 q3 o$ f* a7 G$ d
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     ; W* S* g3 @+ q( [: ^
121.         return $decoded;
     ) ?: g3 T# k/ R7 S; o- o* C5 }
122.     }
     7 F2 n3 J( I; M/ R# N% x8 C) ?& D9 o
123. 
     
124.     /**
     
125.      * 发送数据
     & M5 }! s- C$ Y
126.      * @param $newClinet 新接入的socket
     ( i$ _7 t% F" }0 ~
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     0 z* h) c( c% I9 d( X0 N
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     3 u9 F# v* [* k/ w: Y, q
132.         socket_write($newClinet, $msg, strlen($msg));
     : V) }) W- L$ G  V8 w/ V
133.     }
     
134. 
     . I; A6 a0 ]8 A, ^" x" x" L) m
135.     public function frame($s) {
     & b" I& C/ C+ ]& ?) y* B
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     + _0 q% T5 s/ c2 X
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     , l* f7 ?! ?7 ?% {! \$ g, c) K9 K
140.         $ns = "";
     
141.         foreach ($a as $o) {
       V  M$ n4 F- N. V0 B8 m3 z
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     ( H; {% R* B2 w% z0 Z& z# V
149.      */
     
150.     public function close(){
     ( \- }6 ^6 m6 f
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     ( H, Q: g/ [( |0 K* ~2 B6 F
154. 
     
155. $sock = new SocketService();
     ) A" n; u- ~, s4 E
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
   ! W, S5 R. I* o0 L; G, L
2. <html lang="en">
   6 j& ]3 i7 O5 X1 K! L
3. <head>
   
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   5 o' U! Q( d/ |
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
     A' O# _8 t: G! @9 I2 G* G
9. <input id="text" value="">
   ' A5 `% `) V: n/ F, a/ S5 Z
10. <input type="submit" value="send" onclick="start()">
    & e  D5 w& Q) G
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    ) w5 K( E  o* f% f$ ?
13. <script>
    6 D' w# b' M. Q& b& A
14. /**
    
15. 0：未连接
    / H, n8 b$ m8 N, O: F
16. 1：连接成功，可通讯
    ! C- N; b+ Y- [7 K, A5 S' z4 ^
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    
19. */
    ! c! G8 H" M  j
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    $ t+ L; y0 O7 W$ m# q
23. 
    - W( c& X  E, v4 [) T: H2 ~
24. 
    
25.     webSocket.onerror = function (event){
    + ]2 e; L: ^" `
26.         onError(event);
    ' [* _% m7 E1 O1 i
27.     };
    0 d1 D1 W3 V/ V" H3 X! c8 e
28. 
    & B: a- j# d/ G* G& O* p( S
29.     // 打开websocket
    " Q* @( A9 g. N
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    ' Y0 R. c# y1 o4 E  }* _$ R
32.     };
      Q5 v4 _3 `% d
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    & a1 c2 c" B0 P% I0 N) g
37.     };
    
38. 
    + o# q* e/ L% M) X
39. 
    
40.     webSocket.onclose = function (event){
    & x- s& m9 e0 w( P2 v# S
41.         onClose(event);
    
42.     }
    9 p  P' j, y8 T
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    ( f5 c9 R" Y4 p8 u3 l  c
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    ! T! {* G; Z; n/ P& N2 ~' b
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    , `  ^- ?& R* D! O( w
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    ! v& ~6 l5 W5 F" [3 o1 C- g$ w; i
54.     function onMessage(event){
    
55.         console.log("onMessage");
    + M1 q! `( w- N, B, e; i
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    ( T0 K" j( j0 i/ s7 D7 L& {
57.     };
    ' K% {2 H" ^' A0 z0 B
58. 
    5 V& w' u& d4 o2 m! _  ?
59.     function onClose(event){
    0 X  }# a# b3 x
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    $ ?8 u7 R& n7 T! g3 \( u- p) g1 M& a
63.     }
    , O9 r+ l4 c6 E4 m& u
64. 
    
65.     function sockState(){
    9 {+ ~& u7 B" |; B) _' c5 A
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
      [' m$ b8 g+ h" o; F
68.     }
    
69. 
    
70. 
    * q7 W( X; I: Z  ]# Y9 y
71. 
    " r' Z' x5 j# E) x9 b8 V+ D. ~
72. function start(event){
    . _: g! H! n  i6 A
73.         console.log(webSocket);
    ' w+ b3 n" A# f3 r
74.         var msg = document.getElementById('text').value;
    " u  M- ]- l' _
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    - f7 Z$ G4 v  w- r% Y
77.         console.log("msg="+msg);
    , p$ n) M- K" s# T% r
78.         webSocket.send("msg="+msg);
    0 y( l2 f: y" m( u6 v
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    ; v, b) P; d3 R5 W
80.     };
    
81. 
    ) A3 H" e& r5 |6 |+ o% C  w
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    / h3 p. g5 @! O
85. </script>
    0 n1 g) z7 g; b3 O6 t7 B2 A
86. </body>
    / o: \: f3 @& D2 p) r: ]+ Y
87. </html>

复制代码

5 s. ?# _+ \; p% u: ]2 N9 [
7 G; o( t; C3 A$ o6 m# o
2 p& F1 {, Q3 ?6 Q: o+ R