php实现websocket实时消息推送

admin

php实现websocket实时消息推送

- u4 @2 Y# \( s
7 O1 ?* w, N- E1 aSocketService.php
6 p3 n0 p( Z) T% b# M% G

1. <?php
   
2. /**
   , t2 Q: Y4 ?. S8 [( u
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   4 I4 \  @$ J8 J- W' ~% h5 B5 h
7. 
   6 K* j) z1 U4 M% @$ a
8. class SocketService
   
9. {
   " Q7 r8 e8 Z! P4 m6 s
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    $ i' w' i1 `! s6 r
13.     public function __construct($address = '', $port='')
    % ~5 l, n4 F% K1 W4 ]+ L
14.     {
    6 c" b( u5 t0 E
15.             if(!empty($address)){
    3 r% D2 V& X/ z& j) n* K( \
16.                 $this->address = $address;
    
17.             }
    $ H4 ~0 D8 h  d4 m2 [' i9 b; r: V4 l
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    7 l) J, N2 E8 m  k0 Z
23.     public function service(){
    
24.         //获取tcp协议号码。
    0 C  h: y2 y7 J& D+ G
25.         $tcp = getprotobyname("tcp");
    ; _9 p, i0 W. i; k" U
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    , n  ^( F% l4 i. v9 o6 }: w* M
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    / I: {1 W2 u4 j) ~4 p
28.         if($sock < 0)
    # N7 E$ Y  w1 @' v8 ^# G
29.         {
    + \. k# j! H* _+ c" T" Y# s, Z
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    9 ^( _8 \7 N$ U# f1 ~) _$ i
32.         socket_bind($sock, $this->address, $this->port);
    8 p( A2 q7 x( m; m
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    ; v6 m# p1 W2 r
36.     }
    
37. 
    . ?- f+ [* `+ ~, K9 G- U
38.     public function run(){
    $ @' D, V/ i* w! [
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
      O  V. u' h' Q8 ^' A
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    , x! L. {& b/ E5 P+ \' F) M
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    7 P0 j4 y! L  D3 M1 d, m/ Y# f4 G/ o
52.                     $this->handshaking($newClient, $line);
    " r: {) `0 b; G. {8 j- V
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    2 |: k0 ~+ T: A1 w' h
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    , C2 {6 a, _2 ~" W
58.                 } else {
    , U7 Y" I' w, A3 f& D
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    - y$ C0 u! G3 p8 J$ R9 _
61.                     //在这里业务代码
    : z9 E; t% O5 ]( G
62.                     echo "{$key} clinet msg:",$msg,"\n";
    - m6 o  n, x* W* M, T/ y
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    ) F' ~; R# u# T2 H
65.                     $this->send($_sock, $response);
    , u& h+ e, W0 \9 L, O9 S! O3 n- E5 q
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    8 A+ N# {) G4 ~" w" a( |( [
69.         }
    
70.     }
    4 X# ~; q4 k4 Q+ r% U3 V
71. 
    * G1 J* v! N( M; B1 I) v5 s7 q
72.     /**
    + e3 w3 B2 M) q( O, k
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    5 P/ f" _# \  m
77.     public function handshaking($newClient, $line){
    ! E8 v1 U) A, G8 P2 k
78. 
    5 Z" F6 r0 J& p
79.         $headers = array();
    : Z' J/ _* Q, N2 Z6 A3 z
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    # \9 _! x5 c* w  {9 h& _) J
83.             $line = chop($line);
      K# c( W( j& \. H; v' ]9 J; Z
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    & J9 r7 E$ {4 M. f; d+ w3 g+ r  v
85.             {
      A: H- M7 I- Y
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    0 [5 \3 Q9 b! o# M1 X
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    + s/ b7 c& s' J5 f7 v
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    # j$ s& w, ~  j, b5 j
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    ' g# K) F5 |7 L: a. ?& O0 W
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    ; t6 I9 [" K3 |# p2 d
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    ) \1 B2 v' e2 H7 k
98.     }
    
99. 
    
100.     /**
     
101.      * 解析接收数据
     % d$ x. K0 d! t2 Y6 l. i
102.      * @param $buffer
     ! G" w+ W( i) Q0 z9 D) @( U
103.      * @return null|string
     0 {5 O3 G) G/ h# O3 U: C, v4 A
104.      */
     ; a4 w% ~7 y2 l
105.     public function message($buffer){
     , J: _  a4 Z7 t; r. B
106.         $len = $masks = $data = $decoded = null;
     : Q4 A8 ^/ B1 F# k' e4 v
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
       X+ g8 Y! T  K$ B) R
112.             $masks = substr($buffer, 10, 4);
     ; H4 v! ~9 F) }& t
113.             $data = substr($buffer, 14);
     
114.         } else  {
     , x! Q- D, Y+ f5 L1 |
115.             $masks = substr($buffer, 2, 4);
       w" p0 m: R6 T# R
116.             $data = substr($buffer, 6);
     
117.         }
     " Z7 o! T( a) q6 s7 ?8 S# r$ r
118.         for ($index = 0; $index < strlen($data); $index++) {
     % ]1 ^" f8 H$ W! @5 R) J. N
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     $ u0 [' ^7 h: S
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     
124.     /**
     ; f  g( G1 X; H$ A. k
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     + x: T) i* \) S+ c7 e0 z! @* z
127.      * @param $msg   要发送的数据
     % |; x, {7 }: g  O4 K
128.      * @return int|string
     
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     : L4 M1 N3 a  V% ]+ |- P/ u5 o% K
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];
     * |* T# N' \* L$ X  T
139.         }
     6 S3 _5 @1 S  K" C3 S: p0 H' P
140.         $ns = "";
     
141.         foreach ($a as $o) {
     " r7 a  x" a, f+ U, A9 V
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     4 `6 B5 y% ^0 t8 ?  `4 w+ ~  T/ l
143.         }
     ; ?8 s" D( ^- |5 M
144.         return $ns;
     1 j1 i7 _. O- ^
145.     }
     
146. 
     1 D: N$ j5 N4 \1 @
147.     /**
     6 o, z2 c5 t# u* H4 {0 s
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     " k, _0 J& p2 ?+ w# J' d, @
153. }
     
154. 
     
155. $sock = new SocketService();
     ; F8 Z7 C  i% p3 ]
156. $sock->run();
     - |% E* ~% a8 \8 r
157. 
     

复制代码

web.html
& b0 ^3 Q% `9 K0 e, q1 E+ n

1. <!doctype html>
   3 T* X6 j& ]! G
2. <html lang="en">
   
3. <head>
   ( g, G: |1 A  ~2 G: h+ D' s
4.   <meta charset="UTF-8">
   * S8 f4 w  r4 T
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
     }- t! @5 x- M' |0 W3 \
6.   <title>websocket</title>
   : N1 C! S( x& N0 F2 ~% T
7. </head>
   
8. <body>
   3 t4 {& s( V* t# {
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    " e# ^: I, [) c* I8 k
12. <div id="msg"></div>
    ) b( u! I8 N5 T# B& V2 Z
13. <script>
    ' H/ f8 t1 f0 A$ C& N/ ?2 ]7 ~% t% l
14. /**
    % s' l$ K; H* r  E
15. 0：未连接
    
16. 1：连接成功，可通讯
    $ ~1 U! c) H7 n0 Q+ I9 b" i
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    ) c) S6 m( W, e: h% n0 ~, Q
19. */
    0 s4 Y0 Q2 E) L# A
20. 
    + X8 s! |* o4 K, ?9 L
21.     //创建一个webSocket 实例
    6 r, H" ]  N% s+ n! q1 B
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    ; A0 h+ ?6 t0 L4 o- G1 ^" w$ v
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    2 u. d$ c& s; @/ e0 D: G3 T
28. 
    5 \0 g, j9 |, d! s& f. H) i) E. H  i5 N
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    : }. b/ U  L5 q3 g3 S. q- r
31.         onOpen(event);
    
32.     };
    
33. 
    
34.     //监听消息
    3 ?  `, _& _- b) D( P
35.     webSocket.onmessage = function (event){
    . W5 t8 \  r4 P$ l
36.         onMessage(event);
    / y8 S0 z' H, M% ~& m
37.     };
    4 t7 n1 s: J) e5 ]* @
38. 
    ) v) ]# u, Q2 x& }( L& w5 a" V
39. 
    
40.     webSocket.onclose = function (event){
    / i* K* b- r6 l: ?. {7 v3 b; ]
41.         onClose(event);
    ; b$ o2 S! w9 l* d0 g
42.     }
    
43. 
    
44.     //关闭监听websocket
    . l( H$ L$ C# Z5 ], t
45.     function onError(event){
    + m: [& I6 E, s# a4 w: A
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    2 x# B; @2 i; M
47.         console.log("error"+event.data);
    % i5 p3 f0 j; v, f+ Z7 R- n
48.     };
    
49. 
    3 Y4 O8 P* Y. y/ }6 V0 R" V* Y
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    % k3 R* b0 v. t& l& S
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    * N, J0 f+ s5 h2 O
53.     };
    
54.     function onMessage(event){
    3 A& l) F% X; M  F  b4 n
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    7 V1 v1 V6 J2 m+ a) |9 c
57.     };
    , A/ y, D. k4 ?( Q# K6 L
58. 
    5 h6 S& S; X- Q
59.     function onClose(event){
    " q3 R- M: `2 W7 a& Y
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ; N3 Z9 c# u2 ^% e
61.         console.log("close:"+sockState());
    . Z# s5 W" p! g5 [" \! X) x
62.         webSocket.close();
    
63.     }
    
64. 
    - a( ?) @% n3 z# P+ P) T
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    6 f4 `% }+ P0 H+ o" ~4 h: l: }
67.             return status[webSocket.readyState];
    $ c, u$ }3 G0 C9 a
68.     }
    + E3 T' Q+ |. i  Q2 L( L9 O
69. 
      `( w/ ~- y0 n. s/ N$ K
70. 
    / }! N# `* R/ C$ Y' m
71. 
    - x' m  o# o# m; A
72. function start(event){
    ) `! {. Z1 q$ M# p( Y% Y4 @  m
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    / S! \( W# k8 j. j8 O* w
75.         document.getElementById('text').value = '';
    ; _# j+ }( T* a
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    ' Z4 x7 M+ W% s. c& g& _
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    ( @/ G+ @5 O% M. t& W3 I
82.     function close(event){
    & X. L5 E8 X0 B" ~+ l
83.         webSocket.close();
    $ w% F  T6 S! K3 T/ g3 l
84.     }
    
85. </script>
    
86. </body>
    
87. </html>

复制代码

. M' n9 S1 D/ B) B

8 ]) H6 i+ f" k0 L, F