php实现websocket实时消息推送

admin

php实现websocket实时消息推送

5 E9 V( m8 J9 `. q
SocketService.php

1. <?php
   
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   7 m! w9 A$ Q: @" u; y( i; w
6. */
   * z( a4 ]8 E2 U. j, e1 x  |
7. 
   
8. class SocketService
   / A8 |$ ]" `$ U0 g" }) U& M
9. {
   
10.     private $address  = '0.0.0.0';
    0 f4 T& e- g0 J) t6 y
11.     private $port = 8083;
    
12.     private $_sockets;
    4 k8 W! j3 d8 `( y# `
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    6 {' x1 x$ B) y1 `$ R  h7 f9 v
18.             if(!empty($port)) {
    ! w" i# p) M* D5 {% n
19.                 $this->port = $port;
    : L, N/ O! `# K* `, s0 }7 t. b6 s9 C  {
20.             }
    3 D, _3 c4 b1 q8 {2 P7 k! L$ A: f
21.     }
    
22. 
    , w5 m0 v% B+ V+ c. S" g, S/ C
23.     public function service(){
    
24.         //获取tcp协议号码。
    4 t& V3 A; P  L; a( h
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    / G1 b" s: d. h3 P% O2 R
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    ' e' e  }% }8 ~2 a+ i
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    / G1 b- M5 ^* m' m3 D
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
      t! Q+ E# {4 o) C$ W! X
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    $ |" Y4 r; h* D- _4 K+ ?, b4 b- u
41.         while (true){
    
42.             $changes = $clients;
    9 j6 [9 M( L( K
43.             $write = NULL;
    
44.             $except = NULL;
    0 t6 B+ ]0 _( C' `3 n# r+ ?& O
45.             socket_select($changes,  $write,  $except, NULL);
    0 `. T" G* B. e5 W1 ^" t- N
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    % y, y  D" j0 e. u4 g. c# S3 F
48.                     if(($newClient = socket_accept($_sock))  === false){
    8 ?3 f3 l& ]: C1 G; P0 C  C
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    0 D4 ^( e4 C; v+ y
52.                     $this->handshaking($newClient, $line);
    $ c8 m& I6 m' ^$ D
53.                     //获取client ip
    2 b6 [: V4 S; P5 ~3 L- d
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    ) L+ O+ I# \/ g# o2 k
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    4 o: a4 K9 Q/ V4 V
63.                     fwrite(STDOUT, 'Please input a argument:');
    8 V8 C' n3 O2 y+ r/ U4 E
64.                     $response = trim(fgets(STDIN));
    / \1 y& z7 [* v' ]) S
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    5 R- l' X. H( G1 \' \- t- B
68.             }
    
69.         }
    
70.     }
    
71. 
    
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    - `: o& G/ f4 a9 s
75.      * @return int  接收到的信息
    - D8 ~6 }9 n8 F$ O# s' B% ?
76.      */
    
77.     public function handshaking($newClient, $line){
    2 \6 I% e' i6 F. U' ^
78. 
    ; J% ]" H* r: ]& h" N6 e
79.         $headers = array();
    # ]+ r. ]9 B# G1 G; w
80.         $lines = preg_split("/\r\n/", $line);
    # o8 x; d1 n5 l% f: D" i" S
81.         foreach($lines as $line)
    0 d$ j+ K* E/ f4 I" o$ e
82.         {
    0 w  }3 N  s1 l: ]
83.             $line = chop($line);
    : N5 s2 w( m3 }* \0 f0 m- \
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    ; y0 Y5 F9 c( G7 ]: N) n# e- r
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    6 P6 d3 _  x+ A3 v( n( b; J$ {# a+ x
89.         $secKey = $headers['Sec-WebSocket-Key'];
    ( N, ]& |4 T7 H5 W" K8 w
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" .
    : \' o' o/ y: Q( m" _
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
      J  x- s( {* {! Y2 K
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    2 H+ w, ~5 W3 Y  S- k$ b( a- U& q
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    ' g- g9 D5 @# y
98.     }
    
99. 
    
100.     /**
     
101.      * 解析接收数据
     $ ?/ t0 D& ?! T+ B
102.      * @param $buffer
     % f7 |2 k. O6 a7 L
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     ' h6 U9 S1 j- H( m' U* A" {
108.         if ($len === 126)  {
     # s/ }$ I" p+ c  R  W
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     - H: n) ]! u" n1 u
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     ) w: h2 L/ f6 M4 l& h$ d8 J# p
115.             $masks = substr($buffer, 2, 4);
     ; Y2 A2 J& z! {2 X5 Z! G2 [' C
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     8 D% `6 Y" t) Q0 d" l+ [- M
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     2 j8 c, H6 l# T/ i. z
120.         }
     
121.         return $decoded;
     
122.     }
     2 S8 c! ?1 n  y: b* r6 h: m
123. 
     
124.     /**
     2 d) M5 ]" G* U  r( u4 A* @( K
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     * C' m: E/ T5 n) R$ \3 _) ]6 x
128.      * @return int|string
     ; _, u% [, Y% ~/ M5 Q  u3 o% a0 y
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     # M9 E5 T3 v- w  J! F
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     6 |6 _9 `9 M0 D) J5 a2 _% W1 c5 D4 D
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     ( {1 X" s# H7 s$ `. k9 @- ?2 c
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     ; H- i. x( Y7 ?) v' c3 Y- f
139.         }
     
140.         $ns = "";
     / t$ {/ J' C8 K! `
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     ' X2 J9 ?2 Q5 i- A/ H( K
143.         }
     
144.         return $ns;
     8 U% W# F, S' D+ ?4 s0 [5 l, g! l- e
145.     }
     - E# f* h, Q- [, M: k; j
146. 
     ! K, R. L) c+ Q3 ?
147.     /**
     
148.      * 关闭socket
     * ]: d/ n2 k2 A! p. H
149.      */
     * J) F. {# u) U' u# c2 h1 p/ P/ [& r
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     9 G. P! b, N1 h# M6 ]" Q
152.     }
     8 z$ t$ l& Y: P; s" M  n8 k! D
153. }
     
154. 
     : A  q* U. ~# n: D
155. $sock = new SocketService();
     
156. $sock->run();
     7 V1 c2 Y+ X5 \
157. 
     - E5 J: l% H1 x

复制代码

web.html

1. <!doctype html>
   $ X. _2 {* y/ p* I4 ^9 V! H0 c+ _$ k
2. <html lang="en">
   5 g' s9 @/ {  T- V9 J/ D
3. <head>
   
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>
   ; J" c4 d  ^. P; D/ i
7. </head>
   6 m5 q8 I  L, Q- \( }! k9 s/ z8 e
8. <body>
   4 {7 Y. G8 z3 b- T6 F3 Y3 Z7 r
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>
    1 I0 ?1 l: J. v, ^+ {7 V5 i. `5 r
13. <script>
    
14. /**
    " {- v+ c+ W- O0 p; N0 d( P
15. 0：未连接
    
16. 1：连接成功，可通讯
    # N) q: G2 v4 v0 G& C  l; A4 z
17. 2：正在关闭
    , W! H* [1 t5 e" Q; j
18. 3：连接已关闭或无法打开
    : _0 O  E. {  w4 q
19. */
    
20. 
    : H5 M8 f/ Z& w3 a$ u8 ^
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    - I5 B. i3 O7 o! [' ~
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
      Z- Y$ }+ O  t) M
31.         onOpen(event);
    ; R2 D6 m* A! |; P, Y1 Y
32.     };
    
33. 
    
34.     //监听消息
    8 k* }' _9 p& X9 @
35.     webSocket.onmessage = function (event){
    2 }2 f7 t, y. ]
36.         onMessage(event);
    " y9 M( l: ]. M5 ^9 g0 q3 c% k
37.     };
    
38. 
    
39. 
    * I3 e( L  ?  W
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    
43. 
    ; |' i$ G& @9 N* m' @$ V
44.     //关闭监听websocket
    
45.     function onError(event){
    : F' p. @8 B* t+ ?0 w) b" }
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    : s: i( l" Q, E' k' m
48.     };
    7 M& B3 L1 Q- c9 m3 |' i  Z" D  ]" o3 S
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    / U1 a* w8 ~$ F! h: V: j
54.     function onMessage(event){
    / c+ u/ Y4 n5 s9 y9 H
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    ' `% b" @' }5 O5 U) h& S6 [
58. 
    : [8 q/ K' @# c' u+ m2 d  K$ f
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    : W; N: B0 @# ~' f
64. 
    ( |4 Q3 S% U, n6 ]; X
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
      m& s. O0 P; g4 }# @/ P1 T
69. 
    $ s; g7 ~  A& p% Q6 A
70. 
    
71. 
    2 I# y' F9 d& d" C/ [1 \
72. function start(event){
    
73.         console.log(webSocket);
    . g: }* }" g3 R  H2 ?
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    0 o/ O( Q% T8 r2 m: o/ L' P' [
76.         console.log("send:"+sockState());
    . X" @1 }# U0 x( j3 D8 M/ G/ n
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    # n( C+ y) D* o; e3 }
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    0 I/ ~2 h: Z9 G& E7 ~- c; a
85. </script>
    
86. </body>
    
87. </html>

复制代码

, f# f) b# \7 f; i0 ^

, ?1 {2 d& I6 B$ H  r9 O