php实现websocket实时消息推送

admin

php实现websocket实时消息推送
* M3 T* ~/ o5 n3 x: t" x
9 q/ g7 }- \/ H2 `5 P
SocketService.php
* {# d9 W+ q1 d/ U" ?: f

1. <?php
   
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   % y. e8 _5 A9 S3 r5 q0 q0 V* P' ^
5. * Time: 14:33
   7 B- v; S% a8 u4 g) s. Q0 G
6. */
   ( B3 K8 E/ Y' [' m
7. 
   * q. t2 x6 B# A$ @$ Z
8. class SocketService
   
9. {
   # s% ^, m* v: y& |+ j! y
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    6 N- a, R# N; a
12.     private $_sockets;
    9 H  @" r0 ?, y% H
13.     public function __construct($address = '', $port='')
    
14.     {
    4 _- \: ^- W1 s& U  V  X1 ^4 n. P
15.             if(!empty($address)){
    6 b! H9 U$ Y2 X' _* ]7 V
16.                 $this->address = $address;
    * O/ n4 {  {0 Z) q% x
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
      `9 e( r7 s+ P8 u4 @, w
20.             }
    
21.     }
    
22. 
    3 O0 O# t9 ]# n1 ^3 K
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    , p6 g. K( a5 t( ~, V3 Q
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");
    ' V1 N' k4 Z# V: n
31.         }
    8 J  `( Q8 O  C8 C$ G$ ?2 `
32.         socket_bind($sock, $this->address, $this->port);
    2 M+ p9 x5 ^: ~; M$ J4 u3 n
33.         socket_listen($sock, $this->port);
    0 c% F8 k2 X9 h( z9 Y, O/ H
34.         echo "listen on $this->address $this->port ... \n";
    5 ?. d( Q* }0 w5 L7 b
35.         $this->_sockets = $sock;
      }( C! x7 c# w1 F; z
36.     }
    
37. 
    $ ]) @, s- ]$ t# f/ a; E/ W
38.     public function run(){
    3 e# E: O- W- |) w' U
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    : w9 X0 a/ W6 U
43.             $write = NULL;
    5 p9 q8 i8 u- L# v  Y/ u+ j: r
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    % \4 V, V' `) k3 h0 ~2 m
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    7 q% H. `! s* z6 g, |8 d
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    & G# f: x+ r3 W( b; d- y
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    2 E* C2 o6 ]6 l1 m: V
54.                     socket_getpeername ($newClient, $ip);
    . A+ m( s" h1 Y& s4 u# {
55.                     $clients[$ip] = $newClient;
      Y, W) V  D0 o3 o8 @- @
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    - w1 y: f) I: l4 F6 E' N
58.                 } else {
    . U6 ~* C1 A, `; J. t
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    # ?, d9 F" ~; F! E, h8 U9 {' U8 l- o
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);
    - G: {9 m5 U( I$ h. b
66.                     echo "{$key} response to Client:".$response,"\n";
    6 I) i) V; j8 ^0 Q, W
67.                 }
    ' `% l  a) J6 q( g
68.             }
    % A* h3 q8 f3 @" f7 [) ?& Z
69.         }
    ; P# R9 [7 O1 i+ M6 n
70.     }
    
71. 
    ! `2 a" S' j! ~9 z: A
72.     /**
    . P2 S1 ]' ?0 R* Z& c
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    ( J9 q/ N" d# P! |* \
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    " V- [; n" I5 e/ b$ A: u! K
81.         foreach($lines as $line)
    
82.         {
    6 s  t- g0 N" o8 P8 s
83.             $line = chop($line);
    + G% @5 y/ {/ ^: e1 X
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    " e. e, q2 l5 Y
87.             }
    
88.         }
    0 I  O% ]& ~  u( T6 h  t: ^
89.         $secKey = $headers['Sec-WebSocket-Key'];
    " n$ J5 L! w$ r# v. u
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" .
    ; l  @2 q4 _/ U! |" }
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    6 z3 I5 s3 G8 g# z7 W
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    7 x6 \% l4 L' H, z6 I8 o' }
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    * g7 G0 e2 q/ L' w' m% a2 D, U
98.     }
    + ]+ q- A0 K& K8 @& e
99. 
    
100.     /**
     * W6 U* V. g( ^  Y) [/ ?
101.      * 解析接收数据
     
102.      * @param $buffer
     8 S0 F* l* S! G3 P- f& d5 K5 @
103.      * @return null|string
     
104.      */
       A9 m& S4 E3 \, @
105.     public function message($buffer){
     * T9 e" V8 ~+ k) |  v
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     2 I% r5 T+ e2 r# }$ x1 q5 y9 w
108.         if ($len === 126)  {
     5 e2 E. h2 q& z/ W5 a! E
109.             $masks = substr($buffer, 4, 4);
     ) `# K! W3 ?9 G" A
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     - b- o0 V/ r+ z* @& G' ]
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     8 e9 z. u1 P" m0 j$ n) H
117.         }
     7 i8 o5 x; V9 h8 \
118.         for ($index = 0; $index < strlen($data); $index++) {
     $ t& U* S0 h0 c5 j/ d
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     " L" s2 {" h4 Q; g0 g5 @
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     . U' l" Y0 @: {' J6 _) K
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     7 k( b8 Z5 [4 a; E
130.     public function send($newClinet, $msg){
     + F  |$ C: G3 ~0 C
131.         $msg = $this->frame($msg);
     4 c/ k$ q3 Q. W. Q: z
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     1 ~( E6 _) k6 R8 a( M- q4 H2 s
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
       p1 E" T- F3 _- Y6 W$ L9 X/ t
137.         if (count($a) == 1) {
     8 C$ ]  B% T6 d5 E5 V
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     $ M7 V" S& O+ |$ `3 ~, g  N
141.         foreach ($a as $o) {
     1 x$ ^$ d4 O& V& R# G! f: U
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     , D9 a* a) W: d
143.         }
     ) s0 F* {3 Q2 k" o0 S8 \$ w$ J! L
144.         return $ns;
     ; _; a& F, k0 X* `1 [
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     4 X, a, t0 I; y
149.      */
     
150.     public function close(){
     / z- i% V2 q1 D' O4 W
151.         return socket_close($this->_sockets);
     - O3 \( H5 O* u( l
152.     }
     
153. }
     % `8 e" z8 j+ K; E
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html
5 F2 ^; F7 V9 P

1. <!doctype html>
   
2. <html lang="en">
   $ [( y' r* X3 d* M7 }) n& ?8 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">
   7 l) B2 G- t1 h8 Z5 W! K2 C( a" M
6.   <title>websocket</title>
   
7. </head>
   0 L, D  z& x' T, f$ R' Z
8. <body>
   
9. <input id="text" value="">
   ) @7 h+ q2 k- m" O% u9 I* ]" L
10. <input type="submit" value="send" onclick="start()">
    : }% z! y6 Y, u  \0 i
11. <input type="submit" value="close" onclick="close()">
    / @: \' p- X% q, G
12. <div id="msg"></div>
    0 t# r6 m, z" W  o
13. <script>
    
14. /**
    
15. 0：未连接
    ! ^, X, T  G, z0 K6 v+ I% n! T6 W3 R
16. 1：连接成功，可通讯
    % h" ^# U0 z+ W. q* y5 Y# M
17. 2：正在关闭
    " m% q0 E  ~6 A
18. 3：连接已关闭或无法打开
    5 k& v0 q- ^7 J; ^# E
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
      w) y; S) l0 }
23. 
    
24. 
    # ?6 m% }- N# Y0 d+ T* O- G
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    8 Y0 u( I2 m: C. E
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    " ^# y8 E0 D" m5 c! l6 d
31.         onOpen(event);
    " G6 H$ Y9 r. [$ z& s
32.     };
    + M; r1 m- \. H
33. 
    9 l- Z- E1 o# \3 n2 i
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    , `5 _1 D3 J: {
37.     };
    , @& v" n; g  k8 U9 }5 E1 C* J' y
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    : z" {3 @' ]; a- @' \: ]% H; z
41.         onClose(event);
    2 m3 n6 G. L4 s- K  k
42.     }
    
43. 
    
44.     //关闭监听websocket
    1 Z& n* o/ Q' @$ y: F% z
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    . ]. G, r4 n  x9 P% Q. T
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    2 F8 Y9 R8 i3 D+ Y7 u; Y
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    * f  Y2 z4 O- N3 X, U
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    0 {- X8 L- }# @) x& G8 h7 N- @
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    , y) l: N" ~/ @
58. 
    
59.     function onClose(event){
    " z# I% {& ]& a& R
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    # Y# x3 p, b; @+ j: O2 y5 C! _
62.         webSocket.close();
    % S  P; {: T% l* c
63.     }
    
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    5 l9 a: k. j: A' s2 ?
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    7 J; G0 X& I; s9 y1 q2 G
70. 
    
71. 
    
72. function start(event){
    8 F5 f: B# d+ ]& v0 d
73.         console.log(webSocket);
      j; k& M8 i$ t
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    * E$ w* Y/ N1 O3 A4 F, Y: i
76.         console.log("send:"+sockState());
    - H# r2 F1 ^- }
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    8 s0 ^" R9 Q" g' f
83.         webSocket.close();
    3 D4 x0 {1 _# w3 g" i' z
84.     }
    
85. </script>
    
86. </body>
    
87. </html>

复制代码

0 a! a  ?# N; P/ S3 V: s9 D5 e