php实现websocket实时消息推送

admin

php实现websocket实时消息推送

' z$ @2 P0 g. d  i( Y% L
SocketService.php

1. <?php
   
2. /**
   9 E0 U; i* P2 H" `4 J/ t
3. * Created by xwx
   * H. h; C! K! H$ l/ _- m7 X
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   
7. 
   : ~# P; W* t2 M: |, a, x! u0 P* _) v
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    6 }' @* h+ s+ t$ K% D
11.     private $port = 8083;
    
12.     private $_sockets;
    8 F* @/ `' j: ^* F5 y" L# |
13.     public function __construct($address = '', $port='')
    8 h8 c; R3 ]( I  U
14.     {
    
15.             if(!empty($address)){
    ! i4 R& J" O4 p4 o* O( U: Z. ], Z0 b  ]9 @
16.                 $this->address = $address;
    , q9 m( Y7 D4 z. i
17.             }
    ) ^2 Y  `. k' e6 W- x
18.             if(!empty($port)) {
    % N! t) z2 S) _; I8 P1 O5 V
19.                 $this->port = $port;
    
20.             }
    1 B; P$ v( B7 `9 n& F0 z
21.     }
    ; A  ?9 I& O; ^: a/ W$ m7 j
22. 
    3 ?: R; ~- g% g% [! A! w8 U/ u
23.     public function service(){
    
24.         //获取tcp协议号码。
    2 v& k( \' w, ~$ U' w* K; n5 m) T
25.         $tcp = getprotobyname("tcp");
    0 v# l. O3 t) i
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    & a7 _6 k! h9 f2 e! H* G3 \3 e2 i6 S
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    ) l! ~$ p* Z8 Q& S" g+ K% x/ ?7 Q
31.         }
    9 [+ M5 [2 H: D$ v6 X
32.         socket_bind($sock, $this->address, $this->port);
    + x+ o' g  m8 X1 J% y; T; ]! h5 Y
33.         socket_listen($sock, $this->port);
    - s' {8 z  n, x7 N/ D2 ^
34.         echo "listen on $this->address $this->port ... \n";
    ) z& p" w5 B' _* J2 {0 g
35.         $this->_sockets = $sock;
    , f' K" O* v4 K. F6 y
36.     }
    
37. 
    % [6 d& q$ V$ L! X: R$ \) u4 C8 u9 @
38.     public function run(){
    ' Z: w/ M7 ^/ @) o
39.         $this->service();
    , P, }5 h# c" m& U/ G
40.         $clients[] = $this->_sockets;
    4 ~$ Q5 E, u# R# w( ]
41.         while (true){
      k" a' q+ G0 f$ c5 y* ]! H
42.             $changes = $clients;
    9 y) v! W/ i( b
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");
    
50.                     }
      }4 G! I0 `1 r0 W* }  T
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    # U& t/ K- ~) N1 p) ?
53.                     //获取client ip
    + ?; @4 N* C6 y+ e+ @7 ]+ Q0 |7 ?  y
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    5 E- y6 C4 t. g* c1 p
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    # \6 Q5 \. ?' b8 w7 `( _% ^
58.                 } else {
    . R) c( B: k, N' h. c' J3 v
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    / |7 i# b9 i* w& B
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    , A+ j* a- ]$ @. b9 M
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    # [+ n+ g$ Z& d; M; {$ Q8 C
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    $ a' j% _: P: g, E6 _
67.                 }
    6 R! U% k6 \/ C- N
68.             }
    ( \7 s) b1 z& D+ O: y+ n
69.         }
    
70.     }
    9 G; H- O7 ^  }  l' H$ C! B+ ]4 [/ ~! |
71. 
    
72.     /**
    # S" F/ S; h) \' t: I
73.      * 握手处理
      y- P; D/ ^! H, h0 d1 P# J
74.      * @param $newClient socket
    & i! j) S1 `$ G5 n0 S% A
75.      * @return int  接收到的信息
    # W9 d7 S1 L+ R8 Z+ @) e# o
76.      */
    4 N+ z' g! K% p
77.     public function handshaking($newClient, $line){
    " L! m- G  a8 E# N) E( ^2 ~
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    5 q, n6 A% [/ u- p4 e
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    9 w( Q- X2 ]* k4 w- h4 {4 e& b
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    % W( o( d6 A/ V0 `9 I
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    5 c5 }! U3 f" V6 A, W- W
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    0 {) R( E, K1 }
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    $ }; J$ F6 h# e1 q6 V5 F7 W+ M
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    : T0 n- H6 x! E: r2 {5 Q
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
      B3 F$ i/ x  O, O' v) a( |/ m' X
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    1 f. `- L; f& @: i6 A1 `
100.     /**
     
101.      * 解析接收数据
       u9 ^" ]6 {% @% Z
102.      * @param $buffer
     $ I/ M8 p8 E0 ~! j+ G+ ?' f/ n
103.      * @return null|string
     5 v0 E! v0 u2 u, _
104.      */
     : H$ }/ y" Y3 {9 W& @
105.     public function message($buffer){
     3 _7 T! L" s$ l
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     1 i" C- ?4 y" G, J( ]" ]( e( I  X
108.         if ($len === 126)  {
     6 h, w, I- q9 a6 c" H
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     0 M1 |2 |: B7 c- k: k/ L  e
111.         } else if ($len === 127)  {
     ; {+ E' Q' F& ~4 R
112.             $masks = substr($buffer, 10, 4);
     , c( X- o: P. `
113.             $data = substr($buffer, 14);
     
114.         } else  {
     ; `2 l$ Z1 z- ?0 L3 Z3 Y* N
115.             $masks = substr($buffer, 2, 4);
     ! \( q. ?4 F. I/ T: |. j
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     $ ?' h, Y$ M# \! ~0 [& f
120.         }
     " D  E  M: ~9 P7 V' L
121.         return $decoded;
     
122.     }
     8 G7 t, B, J; c0 ]- ?% H- l
123. 
     
124.     /**
       I' d2 w# S: [# J7 A- M( f
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     ; C8 j- `7 S  e/ U) l+ l7 H
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     ; x' ]# y/ o. L$ I9 L
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     : h# e+ e3 c8 {
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     . a; }& p! m/ u. v# G
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     ' g9 f! d6 R" D: A. G; ^/ A
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     0 E! ]  i" q3 M& X: ?. s. ]
143.         }
     
144.         return $ns;
     & ?5 D& n1 m: h
145.     }
     
146. 
       ^4 H9 o' k( m0 S9 Y+ K' U5 o0 i
147.     /**
     
148.      * 关闭socket
     
149.      */
     - g7 _6 ]3 Y) l+ o; I
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     & |; M( c) @; `$ x7 Z& f, m5 H/ p
153. }
     . y  D: `/ Z7 W- M
154. 
     
155. $sock = new SocketService();
     ) L8 O( ?9 k( q, a
156. $sock->run();
     " M0 I: P) {4 U% k( ?6 X
157. 
     ; |8 `6 c, l3 w8 u/ I, @- c- @8 h

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   * H4 @3 x6 X0 C5 Y6 d" @& [9 N
3. <head>
   
4.   <meta charset="UTF-8">
   8 {" T  u$ U: J$ o" ]
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   ; V; U5 C6 ^6 D$ L
7. </head>
   
8. <body>
   9 ^+ V  `* q, y. k- U" ~6 c+ b
9. <input id="text" value="">
   - j. `7 L8 m6 z" a
10. <input type="submit" value="send" onclick="start()">
    & j6 m0 S/ x" g6 V
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    8 K  q2 o8 b& ]1 M, y! P2 D! P
14. /**
    6 d( C  w5 ~5 R1 ?! O
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    5 x% s$ K3 p/ V
18. 3：连接已关闭或无法打开
    4 ]7 k+ E1 F) U8 I% n
19. */
    6 M3 I* {" X7 m8 \) x2 P5 r  |: J
20. 
    ' o  `- ]1 g& [4 W9 o# u
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    , x" n, C: b" Q8 `4 C
26.         onError(event);
    5 U! \5 G" ^3 ?) {9 R* W
27.     };
      s: y% h1 ]! ?, ~
28. 
    " E' S5 ?  {- D: g% c! v
29.     // 打开websocket
    ; g7 X! }/ u& d) `& j6 K
30.     webSocket.onopen = function (event){
    $ a0 T5 v7 u9 B8 |
31.         onOpen(event);
    
32.     };
    
33. 
    ; I' P" r0 x2 J5 X4 `4 u0 Z& ]- `
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    3 i4 y  P: h2 z! {! \
39. 
    " l- t( ^; \  G1 y4 ~0 M
40.     webSocket.onclose = function (event){
    * ~4 c6 A( n3 F. y) f8 S8 P9 k) J+ z( x
41.         onClose(event);
      X, w% n5 Y2 A- A9 a8 p
42.     }
    % u/ o2 O4 X: ^7 |4 i6 b
43. 
    
44.     //关闭监听websocket
    8 T0 Q! w( y  \0 R
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    6 c8 T- V! L; n4 H/ z7 w0 ?4 c
47.         console.log("error"+event.data);
    
48.     };
    4 L0 f5 d) y. G( s, o5 ?
49. 
    
50.     function onOpen(event){
    ' x7 |3 V" S& u- Z2 V9 }
51.         console.log("open:"+sockState());
    4 @' N' M/ X' i" b; z  R6 T
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    $ B' O! s8 r/ D7 C
54.     function onMessage(event){
    % ^# q% s* w( x9 M8 J6 C* W
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    2 t+ y$ O) r' o5 b" S+ D
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    5 B5 Z! _6 U( u6 G: `) _1 Q4 J
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    3 e; {$ K' Q( s8 s( ]
64. 
    
65.     function sockState(){
    $ G# H2 d" a3 z. f1 N
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    5 E0 R, {6 Y& r/ n9 a
68.     }
    
69. 
    
70. 
    
71. 
    
72. function start(event){
    5 l/ `( }4 B0 F8 o6 s3 n
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    4 ^! ~) l/ y8 f/ s3 v, v
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    2 `& s9 ~$ M* e5 e. m- I" g. U% ^
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    $ l7 m4 Q& g' H9 O+ [5 A9 u
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    4 i; ]! R4 T) E+ J
80.     };
    
81. 
    1 m/ f4 ~8 o# O+ o" T% |) h; w/ V
82.     function close(event){
    
83.         webSocket.close();
    + I1 b: U/ C, s, C9 P
84.     }
    4 I0 Y( w! |# A
85. </script>
    + ~1 r, M7 W  E6 b+ k* d( C8 ]
86. </body>
    
87. </html>

复制代码

' k/ B' H7 z* C: F2 x0 W
$ o+ @% ^7 d$ j" K