php实现websocket实时消息推送

admin

php实现websocket实时消息推送


6 O7 a$ B! L; _; ~4 t, OSocketService.php
* Y. I  z$ V7 u) Z! U3 t

1. <?php
   
2. /**
   / G; n3 U6 n. M0 }
3. * Created by xwx
   
4. * Date: 2017/10/18
   $ Z" F1 n, P! `
5. * Time: 14:33
   
6. */
   2 o6 Y# d# W# ]4 x- s% b6 E
7. 
   
8. class SocketService
   ! x: g1 G, K5 P. T4 B' I  Y! g+ q
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    7 h. h: ?% L4 O! Q" \1 Y& O! Q+ }8 h! |" E
17.             }
    ! ^" V( e# ~- E" p- N! y# I. L
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    . x4 M8 H  N, F
21.     }
    
22. 
    
23.     public function service(){
    6 q$ J! |  u4 K7 z/ g  d, D
24.         //获取tcp协议号码。
      C$ Z2 c0 }# m) e  F/ Z5 L7 N
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    
29.         {
    : x- M/ ^1 r! |+ b& Z3 }0 a
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    1 O: i5 p* ?7 ^7 A! g, Y
31.         }
    / l" M3 t- r/ J0 N( e% R
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
      q! ^. @/ }# v$ G
35.         $this->_sockets = $sock;
    7 @) g4 o. _  B- g! m
36.     }
    7 k& G  u! u1 C
37. 
    : f7 r5 I# q, B; f; K
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    6 q3 \* Q+ y  g. V1 T& q( Q( q
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    9 R1 l5 D: {1 B* I7 ]$ @- n5 D$ \
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    $ V9 `7 K0 t  Z4 ^# ^
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    " ^, w( Y- l( u3 l/ p6 a
53.                     //获取client ip
    9 }0 N2 E  v: F/ \1 g8 w& ^& B
54.                     socket_getpeername ($newClient, $ip);
    3 ]8 y  \  n, P; v8 q) H, M' n
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    & H2 n& u. \# H& p1 O
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    ! O' m2 v6 A3 ^1 {$ p
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    1 ^2 v& L: k, C- L: z8 {3 E
63.                     fwrite(STDOUT, 'Please input a argument:');
    4 F  \. p' n$ M! }+ V  F
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
      n( ]) ]' r! _# \* L! E
67.                 }
    - E1 [! D2 {2 Q. ]- e; h. C! A
68.             }
    
69.         }
    
70.     }
    1 j: b9 s: e( g) l9 Q% H
71. 
    . o5 O0 G: J, S, ?$ \+ Y
72.     /**
    0 i" L& G: c' X
73.      * 握手处理
    ( g: m8 V2 x% B! e, C
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    $ P/ F- R# T0 l1 T' v2 A' g
76.      */
    * a! P4 ^. n% c2 t
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    # J: v7 s* k) R! k0 x8 [, H
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    3 x2 X" s6 ^1 m
85.             {
    ' t: i, @2 v5 s. s$ ]
86.                 $headers[$matches[1]] = $matches[2];
    5 \5 F9 e; }' y5 |* [& ?
87.             }
    & E- f2 S% s4 r' V9 F2 q/ C9 l
88.         }
    3 d, R+ b# L% l2 v  P* C
89.         $secKey = $headers['Sec-WebSocket-Key'];
    0 f  u8 i1 Z* q( h2 O0 b
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" .
    4 S) z& W2 [3 \" c
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    ' M! S. q5 e$ N; r0 }
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    8 o% m1 K& {9 l& b$ i# ^
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    5 h7 I4 Y0 H' @. R: y1 [8 [
98.     }
    
99. 
    
100.     /**
     2 ^/ X) r8 `* w" g4 @- l
101.      * 解析接收数据
     6 C0 h. |) v2 u) [5 A/ Y2 O; t
102.      * @param $buffer
     ; V8 `( W6 |) B1 j! ], D6 d
103.      * @return null|string
     ; G' ^. _( B( T" ]3 g: n. x+ K
104.      */
     ; @* ?7 F6 P  q% p0 Z$ V* G
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     , E; _, D- l7 \" _' s: o2 q
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     0 K" F: Q, o7 L! ~
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     # K$ f5 D( q- P- A. n! v4 E$ s
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     1 Y$ ?/ q0 ]: M7 b# Y+ t
116.             $data = substr($buffer, 6);
     9 d/ a5 w) X! o
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     $ P) o$ a& T! `* r3 L0 ?8 F$ U
124.     /**
     
125.      * 发送数据
     " a4 x2 V  S0 D8 R. Z1 ]4 {
126.      * @param $newClinet 新接入的socket
       j7 l/ Q- j! K/ p7 f/ i
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     ( C" s5 b7 ~1 z% y' G
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     : _+ m/ |, o% l# l- L& V
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     + l. r8 {8 z7 A8 C$ Z
137.         if (count($a) == 1) {
     5 E$ B3 K$ m0 E& d2 K. O
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     " c6 _( v+ \, r2 `5 ]
140.         $ns = "";
     
141.         foreach ($a as $o) {
     ! V, t* I# ^1 o6 B
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     
145.     }
     
146. 
     
147.     /**
     
148.      * 关闭socket
     + E5 o1 u2 r, }: }( E3 U
149.      */
     
150.     public function close(){
     7 n3 g, n% |0 k2 E, }7 Q4 N
151.         return socket_close($this->_sockets);
     * i8 z  W1 w8 W; K2 V3 R
152.     }
     
153. }
     " I& ?4 _* K$ y2 V/ [$ a
154. 
     
155. $sock = new SocketService();
     5 T* R. p/ d8 S4 a, s# _7 U
156. $sock->run();
     0 d7 l; `& a. |9 ^* M8 Q
157. 
     : z  H+ ]! `7 i: b) x8 @

复制代码

web.html
! S8 \) w- }* H4 i8 [4 K4 Z) s% K$ N

1. <!doctype html>
   
2. <html lang="en">
   5 i$ X, i5 s/ x, H
3. <head>
   
4.   <meta charset="UTF-8">
   - C5 @" Z7 }$ @# Q& E+ a! d/ d
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   # G1 ]: I+ U0 @+ K% q# _
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   / \  h2 `2 D% i: h2 K9 T/ |* U9 {
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    3 m5 w7 C, [( F1 h6 v* b9 z% s7 ^
12. <div id="msg"></div>
    8 R# L1 X% I8 K
13. <script>
    + Q# N" ~7 M# ^6 t  x. Q' c
14. /**
    
15. 0：未连接
    + ]& [8 q/ k1 k3 Z
16. 1：连接成功，可通讯
    9 c! |4 ]/ J' c# N
17. 2：正在关闭
    0 @% D/ N" B  _& u! ^. s' T, ?' L. @
18. 3：连接已关闭或无法打开
    + v4 n* K- m- _6 r: B8 J
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    , C4 I! B& \) H! p; i
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    % E2 s  C5 V+ |4 x, s! T
23. 
    
24. 
    ) u0 C* b" t0 t
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    $ [4 ^) q$ b+ n9 r6 R
27.     };
    5 L, ?7 n- z9 r4 K# |5 N
28. 
    2 Y1 G1 d& R1 z2 {9 i  `! k5 {9 u
29.     // 打开websocket
    " T, x/ z* b5 q8 N2 U, e9 u
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    8 m9 d+ v" w' \
33. 
    ; K  H" u* r. d. _6 w9 P
34.     //监听消息
    + S6 d% {3 B0 P
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    
39. 
    $ p, r$ f/ m# r4 b$ h4 f
40.     webSocket.onclose = function (event){
    # d8 _2 x8 B2 {5 t! @8 A
41.         onClose(event);
    
42.     }
    
43. 
    ; o  X" c$ I5 f7 g- e
44.     //关闭监听websocket
    
45.     function onError(event){
    3 i: [- |3 x+ y: O5 H
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    7 W5 `) b1 H" x# n; }' y2 H) L
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    + L" z3 v7 N4 U( Q; t: V
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
      j" z! A* `" T7 x1 U7 n, y
53.     };
    1 |: U$ r0 v# f' j" ?8 Z$ ?. S
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    9 s/ G, `1 _* D, q! ?. ~% o% O
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    " j$ A# M1 n& n% L% q8 j  r6 ^& c
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    % F: ]# V* ?" d9 u8 V3 v; d& n7 X
63.     }
    ' _5 @& G6 m. X3 @6 e
64. 
    
65.     function sockState(){
    ( x$ V* v6 r1 x
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    6 T0 G( F0 w8 C- O0 X
69. 
    8 D, Q6 t$ ^8 \: k- h
70. 
    ' ?8 K4 ~8 Z! ]4 Y4 n& H
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    ' c% ?) _& h0 g
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    , F; f$ l2 }3 H/ V9 U
77.         console.log("msg="+msg);
    % v( b/ O8 P& p
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    . e- m$ K1 Q8 ?/ o% l5 c
80.     };
    7 w! G( c; f4 }  ^
81. 
    & L: i! k( j, O6 H) i7 I: y
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    9 B: L  ~% c. f8 ?. P6 e. G
85. </script>
    + {, v9 r- J! l# x: H% v# Z
86. </body>
    
87. </html>

复制代码

3 \8 k- ?* i+ L6 V2 l7 J" D
: r. s3 ]) J7 P- F" b1 V4 T& y$ l
2 p6 @: _8 O$ U( J6 v