php实现websocket实时消息推送

admin

php实现websocket实时消息推送


, m, m8 |0 U# G5 a% J/ NSocketService.php

1. <?php
   & Y1 l; Z$ J+ i3 n, Q
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   * s8 M7 `- x4 E. F% @
5. * Time: 14:33
   & A8 n, z* j2 z  U( u3 U
6. */
   
7. 
   0 |$ b  Z8 |* U; j1 E& p  P0 s
8. class SocketService
   2 c! A" d# M2 @4 s: T9 Z1 G* n
9. {
   4 L( ]) W/ z0 H
10.     private $address  = '0.0.0.0';
    4 u5 i. y, T+ z+ H+ O+ F+ L
11.     private $port = 8083;
    
12.     private $_sockets;
    " [8 o/ ]* l1 @9 D) ]8 w6 [2 F
13.     public function __construct($address = '', $port='')
    3 C# ]% T/ j* k) a# {
14.     {
    + m( ^+ z- F7 C( ?1 b' s4 _
15.             if(!empty($address)){
    + C) I+ `. V) A9 V
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    ) Y# ^# N  f  _" r5 J3 f9 u6 p6 ~2 c
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    0 T0 l% o3 m" @9 h% T
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");
    
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    # _. F4 w6 K+ u9 _* i* f# {
35.         $this->_sockets = $sock;
    - V' b& ]* @: n: v
36.     }
    : W) w7 a/ w# c1 m" o" k% [
37. 
    
38.     public function run(){
    5 E. a/ T( a5 Q9 T6 _" L! V
39.         $this->service();
    ! g) p! m$ ~: Z* i) e3 R* s
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    2 L; v# F  u" Q" O
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    4 `3 N  N) o( Y) s: ^) n$ ~
48.                     if(($newClient = socket_accept($_sock))  === false){
    * ^- f; Z. F4 v  @, f
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    7 w* q7 y! Y- j* M5 e/ c
52.                     $this->handshaking($newClient, $line);
    4 g+ s4 E9 F1 K4 V: B/ X4 C
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    : O0 ?5 K, h4 a* _9 Q
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    4 o. C( @% H& |  B5 T, ]( L
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    ) w7 d0 N; n4 T/ q
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    ; J8 p1 _4 m1 Q  u
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    3 H6 v) Z# M1 u- _( |3 W
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    - @1 @) V1 s, n7 w+ b  T. l7 |
68.             }
    " ]: {/ \, a, q, ?, E; @
69.         }
    % Z1 [, y/ j) n0 U$ k/ T8 E/ l9 a( L. B
70.     }
    
71. 
    
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    7 K- k+ Y  _, u. L
76.      */
    2 t6 a7 L9 H6 t) K. E9 S
77.     public function handshaking($newClient, $line){
    1 G* a7 C! d. @4 I$ I# i7 a
78. 
    + N5 f( R( w; f0 H9 G8 r3 z3 H
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    0 _" P, v  m8 U6 n9 D
82.         {
    
83.             $line = chop($line);
    / j' _& h8 K1 E$ ^0 D9 h$ J
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    % b6 j" u6 K  L6 {5 ]$ n
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    ' o  }  t8 E. w- E- E9 h. k
87.             }
    " m% Q; P. ?( Y( Z- D, `/ l" @
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    ; @: f7 @# K* w2 v
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    & n9 T5 m9 G" h  f
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
      e: U' q4 N1 L
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    6 H3 B! d, X1 P) O
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    ! K, \4 u! Z9 }- ~( B* Z2 Z
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    ! J9 z( r/ c% B! B, E! {8 H5 K0 K" H
98.     }
    $ V: {$ C; t. N
99. 
    ; ~! W) k( q2 O& y  Z4 U2 W
100.     /**
     5 ]1 O$ D& B/ a5 ^" l# q( _
101.      * 解析接收数据
     # x8 z; U" e8 g9 g8 i2 @1 C2 E
102.      * @param $buffer
     5 L9 B6 N9 ]& o+ d/ B
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     * X9 k0 u4 b4 {7 U; W
107.         $len = ord($buffer[1]) & 127;
     2 V  T, L. p  D$ I% U
108.         if ($len === 126)  {
     3 N! O( X' z  ^% ]2 |. k$ {3 d0 R
109.             $masks = substr($buffer, 4, 4);
     / o2 v0 F7 V& c  ~( i# O9 }9 ]
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     % {- r# k9 p( n6 Z
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     & }/ ^6 Q+ R6 d5 M) L. s3 ^
115.             $masks = substr($buffer, 2, 4);
     0 Z+ `5 e5 l; L! I0 f" }9 n; C
116.             $data = substr($buffer, 6);
     
117.         }
     ' g5 B- R0 L+ R# ?, i& h8 l
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     ) B+ R2 e2 p2 _( M: H
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     ) M% n3 M1 I( }( {& `- O
124.     /**
     
125.      * 发送数据
       y3 q, j( r, D% I, V. [( O; V
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     - H' h9 k; c6 L8 U- j+ D. |1 S% b
128.      * @return int|string
     
129.      */
     0 w0 y" s' }; l/ j0 N
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     " j  ~  h3 E% a. c' \% B$ P
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     2 ?5 _6 h5 R; X
143.         }
     
144.         return $ns;
     
145.     }
     , m9 P; D, K7 C0 V8 e5 z
146. 
     
147.     /**
     / [. b5 g2 B  x6 L: _- f" ?
148.      * 关闭socket
     0 _) ]' R7 ~  l* l! N9 j% S0 W: p
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     " Z' f: {& {, V/ R7 g; `$ B9 H% T
152.     }
     
153. }
     . n2 Q' t6 C. x% b
154. 
     
155. $sock = new SocketService();
     & j  R  s9 Y* }+ {: r" W
156. $sock->run();
     6 }8 y! n4 n5 v& ?4 t  _4 b
157. 
     

复制代码

web.html

1. <!doctype html>
   $ f+ Z/ l+ F0 M5 @4 h7 m
2. <html lang="en">
   
3. <head>
   
4.   <meta charset="UTF-8">
   ( l( N4 D% F- h8 u* H: a
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   7 w- }( Q) t/ \
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   8 J) D0 Q" `' ~
10. <input type="submit" value="send" onclick="start()">
    3 p1 d# A# Z" F: r. Y9 O
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    & e9 N: ~5 |6 x9 M9 f4 k+ C
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    
19. */
    3 r; C  i4 E7 f! o* Y! \  G
20. 
    
21.     //创建一个webSocket 实例
    & X- f% H  m- f  _* F, ?0 l$ {
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    ( C% Y2 Q& ^. r6 \
28. 
    $ ?7 f3 {9 C, X& u+ ]/ w: R
29.     // 打开websocket
    $ L2 \6 O0 F" e8 P3 R: u2 F6 g
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    ( X+ t; o# q  P
32.     };
    
33. 
    ; h7 [! M: o% L1 F4 X: J8 A2 _
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    5 |8 `; P- _5 y2 M
36.         onMessage(event);
    
37.     };
    / F2 l7 m+ X7 d4 H7 R' L
38. 
    
39. 
    ! e  f4 _' t0 ]8 E' h2 P
40.     webSocket.onclose = function (event){
    , Q9 I4 i; X+ I5 {1 q. ^
41.         onClose(event);
    ; C- O/ M( {; E# B
42.     }
    : U7 T/ |6 w+ U3 n
43. 
    3 b0 a# N3 w2 w7 u* V
44.     //关闭监听websocket
    0 z6 b1 k2 X+ v; e2 k
45.     function onError(event){
    " t2 \/ Z) u: W6 C  G! n  i9 b
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ; U1 `0 ]; m4 W( I
47.         console.log("error"+event.data);
    2 d1 k+ Y4 s) i; A& i
48.     };
    " j- H2 X. A# o
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    ' X- p. O3 Q3 R0 {! J# w# g
53.     };
    
54.     function onMessage(event){
    1 D! A+ R7 T% i! e$ W$ t! K
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    
59.     function onClose(event){
    0 l/ h' ?; C+ c' \" {
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    : W, p# j9 r! o* R0 A6 g8 s" ]
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    1 J: _. V0 q4 |# m, a( {
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    3 V3 d- O/ S* S. C6 [4 u
67.             return status[webSocket.readyState];
    + r3 q- z% o. Z0 I; o
68.     }
    / w) Y8 P" f" O: F, N) x
69. 
    
70. 
    
71. 
    
72. function start(event){
    9 `: f) z/ M: [& V
73.         console.log(webSocket);
    6 ^. w- v. `7 |- Y# D! n8 f9 x& f
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    8 g% @3 B1 D( V' k6 X
80.     };
    
81. 
    
82.     function close(event){
    0 m- b- R' X9 P( h
83.         webSocket.close();
    
84.     }
    : t- z- M, ]8 [, ]
85. </script>
    
86. </body>
    8 L) D9 a  V2 A4 ^3 b+ `: x# y- W; Q8 J
87. </html>

复制代码

% s5 N0 a, P% Q8 v2 d7 g" ^. U/ M
5 K- A0 f6 @6 b: R+ J; H7 U
) q; c. t; J$ ?; V