php实现websocket实时消息推送

admin

php实现websocket实时消息推送


8 D2 Y6 M; x- ^( _  Q. ESocketService.php

1. <?php
   
2. /**
   
3. * Created by xwx
   : ^( o2 ~' n  }' M; g+ f
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   
7. 
   4 C( X1 J( Y+ H4 d% B
8. class SocketService
   
9. {
   - a- d' j" g* O; u
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    9 q6 L; |. M& J  `, M8 F
12.     private $_sockets;
    ' F5 I( p* U& B* W; p! ^  u. Q! N
13.     public function __construct($address = '', $port='')
    
14.     {
    , ?$ @$ {3 a4 X! B
15.             if(!empty($address)){
    9 b% l$ a, k9 o5 u9 r4 O# C
16.                 $this->address = $address;
    / ?" R% G) Q- t! G5 V. O
17.             }
    8 k7 R, C6 W. a2 p
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    ) y! @# L  S8 n: i5 f
20.             }
    3 ^6 I. K6 C, K9 U# d
21.     }
    ) X+ ?# |0 N, s& b8 J9 L
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    
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.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    4 x, B% d  n$ o' w3 v/ ?
33.         socket_listen($sock, $this->port);
    ' x! h" b* x6 n$ W
34.         echo "listen on $this->address $this->port ... \n";
    # [: l) F" W0 m( ~7 @, H7 z' ~" f5 a
35.         $this->_sockets = $sock;
    
36.     }
    $ m. [. N0 X2 Q5 c
37. 
    9 m, b" V, J6 _, z
38.     public function run(){
    8 M6 \' a  s' ^! m# a& Z- F! q. ^
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    ; k' H; W* d3 p1 [
42.             $changes = $clients;
    ; W; j( \1 O( [) L, c3 a4 V
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    # x) T9 b* t* }6 _8 O
46.             foreach ($changes as $key => $_sock){
    + V' T! K' w$ u9 Z9 G- r
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));
    3 K/ Y1 y% h- V9 _% P
52.                     $this->handshaking($newClient, $line);
    ; |/ B) w( {9 }7 l! A
53.                     //获取client ip
    ! h; j; t% T% U# B' n, ]  p
54.                     socket_getpeername ($newClient, $ip);
    5 ?0 j' V0 e& i
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    . A* G& Z6 |  L7 t" s$ f. |
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    / Q9 h% R) E# g4 r
60.                     $msg = $this->message($buffer);
    0 n! U- r8 {! H7 D( `# Q
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    2 `/ a# G+ a  ?
63.                     fwrite(STDOUT, 'Please input a argument:');
    & S9 }" }4 a& ?! s. Y
64.                     $response = trim(fgets(STDIN));
    ) M) `* m9 a8 y4 n0 T  I
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    8 q* x+ ^7 f* E4 |7 @1 P
67.                 }
    
68.             }
    
69.         }
    + n$ S+ k0 M# X- S; b8 u: J1 ?" f: H8 d9 `
70.     }
    4 W% [. d3 s& k3 o0 }) S
71. 
    
72.     /**
    5 j& {- r! h6 Y( _* n
73.      * 握手处理
    % s+ e6 j, q- F0 ?; p9 X* y
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    . ^+ a) V, E/ C0 \! v
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    / \* e( e% R* W
80.         $lines = preg_split("/\r\n/", $line);
    0 Z' {" y3 H$ @, A% |
81.         foreach($lines as $line)
    , b7 [' {' f- G# ]* G+ t
82.         {
    ! }7 i& L7 j7 Z0 n& X, y! c
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    / O, u1 D4 |- M9 e
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    $ l! p5 t5 C' ?# J4 ]/ a" F) \' p
89.         $secKey = $headers['Sec-WebSocket-Key'];
    & x3 a' i  T' j/ p! S8 P
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" .
    
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    1 D, L7 ^  [, {& ^) l
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    * p8 H8 F! [3 D" U2 W; ]9 j' X
98.     }
    
99. 
    8 A- {- F; f. e2 K
100.     /**
     : ^; q  `, W% _
101.      * 解析接收数据
     ) h9 i, k  r. \4 U
102.      * @param $buffer
     5 b; \( V- c% x% H2 p* ]+ e# Y
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     & z; ?4 N3 A$ C+ N
106.         $len = $masks = $data = $decoded = null;
     . I( Y7 V4 X4 c4 _2 I3 I
107.         $len = ord($buffer[1]) & 127;
     6 D! t/ g2 q8 D0 q& {  M4 C
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     # D" K) P- x, S- v6 y/ Z
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     & v; {& w/ k. p9 y% N! c
114.         } else  {
     2 @4 N" A/ k2 |
115.             $masks = substr($buffer, 2, 4);
     . o+ {. V8 J* u$ K8 [
116.             $data = substr($buffer, 6);
     
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     ! r6 @& {! J. z- T7 p0 F
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     3 q: G% ~8 c9 A$ P; r
120.         }
     . ?) Q& a; o, A2 T5 a
121.         return $decoded;
     
122.     }
     0 M; P8 ?( R4 s% Q1 x
123. 
     7 V$ d8 _" `9 f& r* L: E3 j! `
124.     /**
     
125.      * 发送数据
     * @1 p: A) g7 ~1 r2 z# F
126.      * @param $newClinet 新接入的socket
     " Y" M; c  z$ @$ D
127.      * @param $msg   要发送的数据
     ( B4 _8 e. t. r4 u- d- o
128.      * @return int|string
     ( x$ S) I4 @: U; v
129.      */
     
130.     public function send($newClinet, $msg){
     . g- g1 R- d/ D* |# l: B4 a& `
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     # F/ ?0 e, g; J- r6 O
133.     }
     3 _  d# N6 D* |- X' ^0 W% h$ p3 ~
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
       ~8 X! n8 O- `8 U# v* D
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     - a: ^1 v. _& H: d; c
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     ! r* {2 p5 w" v6 E9 T' k
143.         }
     
144.         return $ns;
     & F- M. R( ^. H3 C1 u7 F
145.     }
     
146. 
     : l6 h0 W$ J: x  p
147.     /**
     
148.      * 关闭socket
     * Q3 }6 C6 _. d, h
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     5 H; P9 B# o2 P% |
152.     }
     + x4 o& Y9 [8 k0 j
153. }
     
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html
- j3 ?. ^6 F2 U, o) \/ N' _7 G

1. <!doctype html>
   * V3 @% J; g& v5 p( f
2. <html lang="en">
   + K9 x: e9 B1 ]
3. <head>
   3 o% X5 b7 q- O5 D# P
4.   <meta charset="UTF-8">
   9 b) o# e; x: l# n: ^
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   % g3 g/ \& w% @0 _9 ~
7. </head>
   ' k6 P- [7 n" {* ^" Q5 k
8. <body>
   6 D/ e, g7 Q- M8 U
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    + q/ S8 C7 B; M. q9 q( `
14. /**
    
15. 0：未连接
    , b: j, i- ?7 J* S- e8 K+ ]0 ]
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    ; F- _+ D8 K* w4 \1 U
18. 3：连接已关闭或无法打开
    4 x# _/ {6 r( [$ p& b. c9 `
19. */
    6 |  `) V# B8 u5 K
20. 
    + k7 t! T: g. D: ~. \8 U8 C
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    ' q; |6 |* C' S( L
23. 
    
24. 
    9 `# x% C- g+ o* X) Z4 C$ u5 r
25.     webSocket.onerror = function (event){
    $ T3 m3 H4 S+ L# t1 P9 t! v
26.         onError(event);
    3 P) B+ [: u6 u' @& B
27.     };
    " h+ b: z" b% a# u
28. 
    
29.     // 打开websocket
    % l* n( l5 n. t! Q" U
30.     webSocket.onopen = function (event){
    " r: t. b1 n, C" K. R2 v
31.         onOpen(event);
    
32.     };
    
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    ; J, l1 L$ \. L
36.         onMessage(event);
    
37.     };
    
38. 
    0 c. |% g. `/ l3 ~& {1 _
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    " V# P1 _4 S% ]( J+ h; H" f
43. 
    
44.     //关闭监听websocket
    ) z4 P9 E" o, H0 ?
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    , m+ i( F; U" x
47.         console.log("error"+event.data);
    , r% R  d% j7 u" K' `
48.     };
    3 d" Z0 w4 Q: r" y/ v
49. 
    4 r3 e/ _1 i6 }9 Y9 P# b) I7 F
50.     function onOpen(event){
    5 J, M. i* e# B
51.         console.log("open:"+sockState());
    - r" @9 y' R. w6 R$ w! u
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
      a: S) H8 H0 v' |+ p
54.     function onMessage(event){
    ! Z2 q0 {4 U, |1 A
55.         console.log("onMessage");
    ) e( R8 q* X& J1 Z) F
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    ' n2 Q$ q" Q% Z- }& r
58. 
      ^6 ]7 I4 d" z7 j6 W5 ^8 t
59.     function onClose(event){
    ( D/ c' {% F$ Q/ S
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    % X9 M/ B; h$ m% @: F, |% _+ O
61.         console.log("close:"+sockState());
    1 i6 D2 s; }, p) E3 m6 z/ F
62.         webSocket.close();
    
63.     }
    / T& Q% r7 M( J5 Q. d
64. 
    / s, g; {6 {; r3 g/ m
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    + T2 _9 ~5 O- \$ f) c6 T+ l4 o
68.     }
    
69. 
    
70. 
    9 d1 S- O  n$ Q1 h
71. 
    ; \. I5 E: h) m4 R# g% U1 L
72. function start(event){
    7 I' R5 e8 f+ V* Y$ z
73.         console.log(webSocket);
    ! ^) r  B* I3 }2 P; `
74.         var msg = document.getElementById('text').value;
    % f9 y. y1 S9 w9 q, R3 }, d
75.         document.getElementById('text').value = '';
      ~! b) q3 F9 y4 \/ m- d) A  {, B/ A
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    : z& s( K3 }0 Z+ A, Q* e% Q
78.         webSocket.send("msg="+msg);
    # k. t8 h- I# W2 k. H$ v7 \- b
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    1 p# C: `4 G4 y
80.     };
    * x: n. i9 y& X7 |+ z
81. 
    . y+ }. Y) G; x
82.     function close(event){
    # A; I/ v% `1 d) v$ T; R
83.         webSocket.close();
    # A0 O! E7 r0 W2 `' M! k
84.     }
    ' w2 U, G/ k& d3 d$ Y
85. </script>
    
86. </body>
    
87. </html>

复制代码

) T8 L# i; d5 |* ?/ k