php实现websocket实时消息推送

admin

php实现websocket实时消息推送
( x6 p' |2 {8 s! [1 v& j
3 }( p4 ~  U$ t% A
. y4 ^5 C: e9 g  [/ X! ISocketService.php

1. <?php
   # l$ ~3 u) B! ^( u% ^0 R
2. /**
   7 l3 _3 e/ `- n, t7 d
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   # M$ L2 O$ Y- g7 v8 V
7. 
   6 Z& G- }; P3 M% o* J
8. class SocketService
   - Q' G, Z* N! h0 Q6 G% E' h7 v
9. {
   & l9 j. Y$ |7 g4 w' }1 a& ~
10.     private $address  = '0.0.0.0';
    7 v5 G* ]* O* K' B
11.     private $port = 8083;
    
12.     private $_sockets;
    ; ^3 k" j- h4 i9 P- J+ Z
13.     public function __construct($address = '', $port='')
    0 ^* o9 v+ x$ e7 D+ `  Q
14.     {
    & k8 X$ E+ c/ f3 n
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    ( u; N4 b, J' o+ W; P4 j$ |
18.             if(!empty($port)) {
    # r* ?" m* M4 Q. ]$ p) q# k; Y
19.                 $this->port = $port;
      d% H, K0 r( E+ \9 b; [; w
20.             }
    
21.     }
      e3 f3 ~) |) s# L
22. 
    
23.     public function service(){
    ; H$ E8 f0 X" f9 A- \) w
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    ; v9 B9 W& V" w7 r
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    3 s! J5 ^- E  Z9 I8 ]9 {
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    8 x; k  n9 X  \* `( j
28.         if($sock < 0)
    
29.         {
    4 D! p; U- l5 U  o" Y; @, e+ t) b0 q
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    , b  }, e9 ?2 C0 d+ \: c8 I% O4 X
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    % f+ R4 w! c: k2 V
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    1 j* h% o1 H, X
38.     public function run(){
    / f: L4 S) y% b* @1 G* \
39.         $this->service();
    9 i" r& F- H' {1 S) m
40.         $clients[] = $this->_sockets;
    , l# R4 [0 }3 O6 Y; |
41.         while (true){
    , e: p' ?9 \# I& n5 J7 O* e
42.             $changes = $clients;
    $ H3 A& a8 S% E' `( f. h. u0 o
43.             $write = NULL;
    * m9 M0 d* g4 l+ Y8 Z
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    / R. R, Y/ C  g! X7 |/ R
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    * o% Q" |8 U5 p
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    , E1 {' p: G' R4 M6 B
50.                     }
      n' _; P0 x& R0 {* P# l
51.                     $line = trim(socket_read($newClient, 1024));
    - f, @3 W5 Y4 h* b2 ^
52.                     $this->handshaking($newClient, $line);
    ; K( D$ L( B/ f( ]
53.                     //获取client ip
    * f, J' c5 o8 m3 i
54.                     socket_getpeername ($newClient, $ip);
    % F: V$ e5 Y  v! _- q* d$ y
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    5 ^3 T% _0 ?# S  ?2 k6 X
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    , }. D: g; L# l+ M9 m
59.                     socket_recv($_sock, $buffer,  2048, 0);
    7 \# |" G- B+ J+ U% G' o
60.                     $msg = $this->message($buffer);
    + m* ^4 h% P) B) \: V
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    . [9 X! }. d, _) v8 J, G0 h: ]" ?, }1 |
64.                     $response = trim(fgets(STDIN));
    8 C1 T1 D. l( C+ P! P6 e
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    . \, Q1 \: M$ @% R- ?
67.                 }
    * K) i$ N6 B0 F
68.             }
    
69.         }
    : j% L& t* c7 v, c. n- R
70.     }
    3 P2 V: c8 h! I. ]7 e2 g" j5 ]6 W
71. 
    ; p  o: F/ P2 Q
72.     /**
    " X6 }- L7 Q+ J9 R- x0 q$ n
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    ' |( h/ W  e$ I0 E
78. 
    
79.         $headers = array();
    ) O  o/ e1 N0 E- t# q1 P5 b: d
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    ; {  \0 @1 M# C9 a. [9 N, G. Y9 S0 s
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    - M% S$ W2 O# \" _3 ^+ E
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    4 H3 d; y# _2 S7 l9 d9 |
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    , {5 }8 ~$ R& C" L
92.             "Upgrade: websocket\r\n" .
    : p% d4 |, E' k/ t  A  e) M% P
93.             "Connection: Upgrade\r\n" .
    % [( d3 K# `" g
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    5 O4 U2 p& H  X9 @4 g
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    ! v/ \3 A/ {3 c4 b0 g/ X  h. a
100.     /**
     ! m0 Q. x4 p. L- o; W+ }
101.      * 解析接收数据
     
102.      * @param $buffer
     ' e2 s+ n9 D# A! C' \; i. C8 N
103.      * @return null|string
     6 C+ c; \- L6 B
104.      */
     & x, j5 v2 w* v# ]2 ^
105.     public function message($buffer){
     $ ?2 h2 C: s% ~& \1 _- A# S
106.         $len = $masks = $data = $decoded = null;
     ' y$ v: W9 {9 i  w* Z8 R! ^: ?
107.         $len = ord($buffer[1]) & 127;
     ) \7 _$ w9 j0 o2 p( X, y
108.         if ($len === 126)  {
     8 h' E+ }7 @7 ]5 n* t' P% W
109.             $masks = substr($buffer, 4, 4);
     5 p! Z' k! _8 \  C/ q5 F1 y
110.             $data = substr($buffer, 8);
     6 h! e0 y/ ~9 z! l4 z
111.         } else if ($len === 127)  {
     5 n* ]( m5 S, g
112.             $masks = substr($buffer, 10, 4);
     * }6 l! V6 G3 I3 W
113.             $data = substr($buffer, 14);
     
114.         } else  {
     / F7 ^! M# R7 P* ^
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     " o3 l7 H7 _/ i  F- p, l
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     7 G8 Y4 c2 r/ G
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     1 K# q' ?. q" y' @
124.     /**
     $ r/ e/ Y- M: S2 k1 J
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     . M: R& L0 T! F0 P
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     ! H8 L: B# V  t& ?
133.     }
     , F7 u. f/ t" ?5 M
134. 
     $ B! {  z; p" k+ k" c
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     " G, S5 [% {- W3 z
137.         if (count($a) == 1) {
     . P- i7 O& d6 a$ L3 U
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     7 i, ^" F# M; I! s- O
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     5 R" @; P% Q6 v! T
144.         return $ns;
     
145.     }
     3 P" y5 l  S2 F: q, i
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     ) R4 V% E$ ~5 ]  E. q6 p* G9 b) N
152.     }
     
153. }
     ) r. V! B  h7 r1 G
154. 
     . c1 a2 x* n9 S/ m( T3 }0 M3 w" j
155. $sock = new SocketService();
     
156. $sock->run();
     " N; @4 }" S: \# M) J
157. 
     * j' K4 U& V4 u8 g* i% P

复制代码

web.html
2 \6 T0 [1 U7 H7 _8 o0 F; p

1. <!doctype html>
   
2. <html lang="en">
   
3. <head>
   0 @3 R! ~( S* I4 G* h
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   4 q2 o, I  `! D  B+ v1 o
6.   <title>websocket</title>
   ( A$ l) G8 s9 e9 Y; s3 i
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   ; K$ w4 Y0 y8 ]
10. <input type="submit" value="send" onclick="start()">
      X3 c8 S% f9 O9 c
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    5 C. h3 _/ S- L' B
15. 0：未连接
    
16. 1：连接成功，可通讯
    , q7 s( J2 K# C3 H) ~" g
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    # \7 w2 O' f6 A" s( e2 I
23. 
    ( y. t4 V# r/ |
24. 
    3 X( k  P3 G2 v7 G$ H* v8 \( z
25.     webSocket.onerror = function (event){
    . Y: L* W' Y; g" Y, z8 I; A
26.         onError(event);
    & Q  F' |% Y+ u- X
27.     };
    
28. 
    $ c, A6 ]$ z4 w0 \; L3 \, ?
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    
33. 
    
34.     //监听消息
    , j, v5 n# G. ^& R- K
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    / {( V0 V9 z6 w! \" _9 L9 g
38. 
    : J1 [: Q3 v1 L4 E" C2 r' c( y
39. 
    5 ~1 R3 p# i* W" ]/ k
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    . r5 F. _0 @& v% E" w$ C& u
43. 
    $ y! l* x/ a, n9 U: V3 z
44.     //关闭监听websocket
    
45.     function onError(event){
    ( i+ `) i4 u2 [  _9 E6 w: D) d
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    & G; `- U/ E, C! g2 J+ \8 D
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    & ^" I  F4 n- P- _+ V# w
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    0 t( j: \  a9 U. g! B
54.     function onMessage(event){
    
55.         console.log("onMessage");
    . b2 B! M2 N+ J) l1 F
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    8 i2 M7 ]) K6 ~5 Z5 g7 R
63.     }
    3 u) X/ l- P/ a. U1 ?: [
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    7 X8 f, C" x" Z+ q" M
67.             return status[webSocket.readyState];
    
68.     }
    4 E  f) a$ a, E  J' c
69. 
    
70. 
    # a& z1 z7 b! T: ]
71. 
    6 V6 @. d  v9 w( |+ a0 Z
72. function start(event){
    5 N3 o3 V" a4 h- g& `. _# Q
73.         console.log(webSocket);
    - D* A( {! B4 p" {9 P: |- S- S% _
74.         var msg = document.getElementById('text').value;
    ) v" P  V9 b5 d3 j0 U' K" P% h
75.         document.getElementById('text').value = '';
    & K6 J6 w  j7 U0 c
76.         console.log("send:"+sockState());
    + y" o: |! @. [' ]: |% s
77.         console.log("msg="+msg);
    ! U! d6 l0 H2 d3 K8 ]
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    ' }: f/ d; k# w) X
80.     };
    
81. 
    
82.     function close(event){
    1 T2 E. [0 T" M9 l
83.         webSocket.close();
    
84.     }
    / j$ R; I9 K9 j2 ~
85. </script>
    
86. </body>
    6 o% e0 }2 w' L
87. </html>

复制代码

1 x; K+ b7 a- s) X& v