php实现websocket实时消息推送

admin

php实现websocket实时消息推送

7 Q# t: E2 X# h! G5 v7 t
) ]% J* s* E0 f9 L  tSocketService.php

1. <?php
   ) A3 v/ ]5 j8 F# l5 Q' j+ ]
2. /**
   
3. * Created by xwx
   ! ~1 p$ r2 t1 z! I
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   ) E; v$ w& F. U7 \2 D
7. 
   ( ?! @6 {9 T, X2 T2 i% A
8. class SocketService
   
9. {
   5 Q; g$ X5 {: M; I+ e" I5 ?6 i$ v( C
10.     private $address  = '0.0.0.0';
    7 K' Z0 p# g* E3 q! Y: ~( }# o
11.     private $port = 8083;
    2 T9 U2 A; u7 O# P2 o3 T, Y
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    2 V5 \0 h! r9 n  m1 r5 s2 X) ^% p/ b
14.     {
    # {2 z  j- Y, ?9 A- a9 a8 k/ }
15.             if(!empty($address)){
    - u5 L' R% Q- D7 X  {% M* C5 V
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    % Y; b- K% J8 C
19.                 $this->port = $port;
    4 W9 ^6 l; f7 _8 Z; G6 g  e0 K
20.             }
    
21.     }
    & _% h8 t3 M4 l/ d
22. 
    2 ^$ \3 ]3 ?, e/ r
23.     public function service(){
    # W+ E" Q  G+ O; P% I6 z
24.         //获取tcp协议号码。
    7 j" [& h: P! [
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    6 }3 @; S6 V" M% ?9 W1 {$ p
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    # p" S  z: o4 m6 F8 Q# N5 f
29.         {
    : Y$ O/ J$ k' U, @  b) L4 P
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    3 \8 {  I1 A1 @, M: |' t; \
31.         }
    $ q1 ]- W0 K9 K
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    & `/ P0 w& P' r0 g
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
      ~4 f5 A  p3 J
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    / {- B# U$ u( t5 ?. q4 o8 ^9 H( @
41.         while (true){
    ) G) G' y% C6 P6 \
42.             $changes = $clients;
    
43.             $write = NULL;
    . D3 |% J3 n7 j/ E/ A
44.             $except = NULL;
    / ^$ _' o7 T( M# V- [, }
45.             socket_select($changes,  $write,  $except, NULL);
    6 s& y( s5 M$ ?( v* C. ~
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    ( Y* k: m' {% t* w; r% J/ U: N5 y
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    8 y" X( Z4 ^$ f) I
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    - K9 i3 e% v" V" o/ K9 E6 d
55.                     $clients[$ip] = $newClient;
    9 q* @9 q7 ~! a* e
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    / u9 N1 ^  P7 M5 Y
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    ) v  P, Q  R' V& S5 ^
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    ; t: S) {# e3 C+ W  Z
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    5 ~. C! e! D. w% y6 y8 p% N: N
66.                     echo "{$key} response to Client:".$response,"\n";
    8 z% ]  o! O0 k7 P+ g$ R
67.                 }
    + s% s& s% o$ `& S
68.             }
    ) q: `+ m& A6 U7 \* F
69.         }
    , s7 _+ k8 r0 Q% b
70.     }
    
71. 
    9 r$ H! K. m4 `0 B
72.     /**
    
73.      * 握手处理
    2 U0 W/ H. O8 Q( e( w* |! Q
74.      * @param $newClient socket
    " j9 L* x# u( `+ Z4 _" [, K, T7 Y
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    & |3 }$ ?; e' g5 p
78. 
    
79.         $headers = array();
    # l/ Z+ k/ H( e5 v/ e
80.         $lines = preg_split("/\r\n/", $line);
    ) L& [7 G& E8 ^7 f& Q. K
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    ( m$ R, d7 x! H1 I
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    4 W: t- Y" ~9 T' B. F
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    * H2 r8 Q4 L9 \& ^
87.             }
    
88.         }
    . Z8 o  r: }  T+ D$ p% p
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    ; n4 ~- u8 `" i9 E& G9 L0 C
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    9 X6 ~$ C5 Y. N" n, j5 c( E# i
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    3 ?) [! C' B7 z0 v3 |& S  D
98.     }
    3 C5 h5 L, n: c
99. 
    
100.     /**
     " l& |4 ~0 N! q" C$ E9 X+ \
101.      * 解析接收数据
     0 m3 @' O) e6 t  Y, T% M# f
102.      * @param $buffer
       ~; b  o* T+ `$ l0 W
103.      * @return null|string
     
104.      */
     # W2 F3 g  \0 z2 u5 j
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     " n5 Q4 t- w) p( X& `4 X3 p; a
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     2 w5 F: J& `2 g& w
111.         } else if ($len === 127)  {
     , c# m7 y# z' S7 W- Q9 ?$ |
112.             $masks = substr($buffer, 10, 4);
     ( d. }# o2 k$ s$ l  f7 k
113.             $data = substr($buffer, 14);
     - g0 v+ }  a* O& Z$ M
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     ) g2 D$ p, x) a
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     / F: [1 n4 Y7 X5 r
120.         }
     
121.         return $decoded;
     
122.     }
     5 @; ^: f; @! [5 R7 e, `0 f
123. 
     
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     9 Z; v/ z) m! v1 j0 `: r, T% v
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     " d  i& s4 q2 |# j% |9 E- T5 g
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     : k1 c6 O8 y# s
133.     }
     $ Z2 W+ W1 V7 ]7 M( h8 ?' r  T
134. 
     , u- p. m: \- G3 u1 t8 s
135.     public function frame($s) {
     " D% o7 d0 |' {9 w1 A$ Q" O' i" |/ }
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     1 J( z" d' L2 }# T6 y! {
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     4 k1 h4 R0 Z3 I/ X
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     + N3 _6 |: ~/ W- h3 O7 M" ~8 z( ]
143.         }
     
144.         return $ns;
     
145.     }
     5 \' r0 d. H+ ~( L  \- W
146. 
     
147.     /**
     * p- l( {' j) W# x
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     " M& b3 S. ^; m
151.         return socket_close($this->_sockets);
     
152.     }
     & B" b/ y6 ^0 S, [) W' r: s
153. }
       J5 Z4 J& P2 e$ i
154. 
     9 C4 n- m! |5 v" e' L
155. $sock = new SocketService();
     - x& k2 z# A" g5 d
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   4 B; ]+ O2 `7 d
3. <head>
     m1 I# l7 z9 W. r# J9 R
4.   <meta charset="UTF-8">
   " B1 B, B9 G" ~0 S* K, H6 @8 [
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   1 o; B0 V3 {+ \7 B; ]" n
6.   <title>websocket</title>
   + t) G. O( r# q3 q& B9 F
7. </head>
   
8. <body>
   % |% U3 v4 a2 l/ R' I; j
9. <input id="text" value="">
   + ^7 A1 N9 a# @4 t4 I, O7 O- z' x+ Q
10. <input type="submit" value="send" onclick="start()">
    * d/ a. m- M* C* J+ w9 G! V& U
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    0 i1 i% `, j, U; w+ H0 F
16. 1：连接成功，可通讯
    ' r; q' {. ?* @
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    , C2 d% y5 ^! H* n0 w  F. g$ V
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    # r9 ]3 l9 j' N$ I- q
23. 
    ( A% F* B' C5 g5 L8 b) ^
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    
28. 
    : l% n! P' N9 G0 F- f
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    * \9 I' M& t' F9 q) F  Z# e
32.     };
    2 r, c0 _% r$ V0 {3 {0 |5 I
33. 
    / _$ u, T1 v) e$ Z
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    
39. 
    + a" B% Q7 J# ]) Q* G5 x1 a% R7 ^6 d
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    0 J/ X) S% P: Q) I
42.     }
    
43. 
    & G- m, W0 H. Q$ s
44.     //关闭监听websocket
    7 V, g4 w9 B( r9 [+ v; y( ?
45.     function onError(event){
    . R7 n# w7 F7 g  W" J& Q4 A
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    9 n/ A+ L/ D; h; o
47.         console.log("error"+event.data);
    2 R/ z! P1 y! \/ E% O7 E+ u: C
48.     };
    " u3 P8 ~' K4 n' ?: G
49. 
    % `$ w3 {, G1 v  e
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    2 H+ ~& M7 x/ e  V4 b
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
      A0 Y; [& ], M0 {' I9 q9 e
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    2 V) V1 p3 F$ ?" e- R
58. 
    " A$ @( H: m3 y+ F% Q* h
59.     function onClose(event){
    4 \3 {* T7 }( f/ k5 r4 w* L
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    ) d, q6 T5 S: ]2 Q) Y5 u  _( P
62.         webSocket.close();
    8 z% ^; r1 p% Y- W, \0 C
63.     }
    
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    4 T1 X/ `' W0 c: g( x5 R, h
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    . o6 G+ E# K2 |5 u  u  D
70. 
    
71. 
    
72. function start(event){
    5 ^6 p- {1 m& y! o
73.         console.log(webSocket);
    2 q! l. _; o2 K7 z
74.         var msg = document.getElementById('text').value;
    % S. m, P& V0 ?
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    , Z4 Q) H' [# n" s) h
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    1 u$ }0 u. n) J. J. q) M
80.     };
    
81. 
    
82.     function close(event){
    1 I# g/ p% @5 p! y5 c
83.         webSocket.close();
    
84.     }
    ( T5 ~6 m- B7 V' y  P  G( S
85. </script>
    
86. </body>
    
87. </html>

复制代码

" g) S6 K3 W, u2 Q
8 T- \! A$ c9 r  Q3 L
4 y/ g0 p9 h! Z6 k, l% t" q