php实现websocket实时消息推送

admin

php实现websocket实时消息推送

' ^( B8 o: O+ d1 q
, U' I4 n- V4 }# `  _( T' ]: g4 lSocketService.php

1. <?php
   
2. /**
   8 i7 O" M0 }5 m  b& U
3. * Created by xwx
   
4. * Date: 2017/10/18
   8 O0 C# W, E: L3 V4 M7 L, J- g
5. * Time: 14:33
   
6. */
   2 }% L( w, N. i# q5 z- Y
7. 
   
8. class SocketService
   
9. {
   , F0 H! C3 j2 q  q
10.     private $address  = '0.0.0.0';
    ; N1 z* A9 K( t% k- U1 _
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    " m5 `9 u* r6 O! F/ S8 @
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    + N# f; Z& }1 d* R
20.             }
    6 ]% ~- s( x1 z& I" |0 G
21.     }
    
22. 
    + V) a' s; K2 Q7 X, w% o
23.     public function service(){
    / [: H3 V. P. h* x
24.         //获取tcp协议号码。
    2 {" {! c. Y% B, ~& }) e
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    " Q7 N& K) e. W* ?
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    ) N1 o, T6 d* C. p/ g
29.         {
    ) t# Z3 H2 K# M
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    2 e1 k6 t) ~* g! T
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    ; K) d2 ^  I$ R% Z- q" }
34.         echo "listen on $this->address $this->port ... \n";
      I% r5 c3 f( r, \4 G, }/ F
35.         $this->_sockets = $sock;
    / W- P; \. U4 b5 J
36.     }
    
37. 
    
38.     public function run(){
    . W+ T" |4 [1 V" U
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    & V1 X) h/ s6 J+ d7 L
41.         while (true){
    : E+ x' A- ~; T* l: H
42.             $changes = $clients;
    . s: H. s/ }4 F: }9 j2 m# y9 L9 i8 v0 }
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    7 ~0 M4 ?& s/ n4 {/ w! e9 \
46.             foreach ($changes as $key => $_sock){
    0 T* j9 F/ V) q- G7 I
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
      z# x4 e5 \* K' V" U
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    # Y5 z: r; [7 f9 I/ b3 ^
52.                     $this->handshaking($newClient, $line);
    ' S, h( W7 X: I& V
53.                     //获取client ip
    : _8 l- D, a" n& ~: j% b6 ~
54.                     socket_getpeername ($newClient, $ip);
    + I; K+ B& S! P5 c; U
55.                     $clients[$ip] = $newClient;
    6 z$ F; Y. V9 D1 z5 v4 |, @" y- I
56.                     echo  "Client ip:{$ip}   \n";
    3 F' Q' ?  P' ?9 K. q, P
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    $ n7 @) D1 [# @' }  q  f
59.                     socket_recv($_sock, $buffer,  2048, 0);
    - D* Q, `% R6 `* r. x' j  |: {! S/ n: H. X
60.                     $msg = $this->message($buffer);
    % e7 U. P* H0 C; V) I# D& S6 v
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    9 B- Z! _+ i' b
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    
69.         }
    
70.     }
    
71. 
    
72.     /**
    ) G+ |7 x6 L7 f
73.      * 握手处理
    ; e7 G6 e/ F/ n* M. P
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    ' A  L2 w+ B7 ]' k) w  X* j" A
77.     public function handshaking($newClient, $line){
    
78. 
    - \+ k. d+ B" i, w# R
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    4 L1 i- m7 X8 o* L
81.         foreach($lines as $line)
    
82.         {
    & y1 G* t8 y8 W/ t, e* U
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    8 S% c  D- v* F5 G0 @* M
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    . A) o$ \! @3 C  C4 `# a! a
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    . E/ I5 {9 ]) @# M* r- X. k
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    : {- Z; S6 t* m7 f, w6 c0 t
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    # G6 ~5 ^7 a5 P# O
98.     }
      D* l2 x& j5 w, M, y
99. 
    ' ~# y+ I% [, Z
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     * Z- \' Q0 ~8 A  A6 y3 Y6 w
104.      */
     + y9 g. m2 B7 G, F/ R7 X# z8 w
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     8 L1 H% A' I, P5 e
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     7 i3 ?6 o) n  O9 w
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     & I8 Y* ^: d- M- X$ v- _9 P
113.             $data = substr($buffer, 14);
     % r4 p$ L4 X; g" ?: a& R* o1 v
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     9 d! Q) a: C* }. z  n1 ^
116.             $data = substr($buffer, 6);
     / T) D9 N$ c  X) H, i: H
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     * u* h, r5 w1 z, o# }- K  `7 Q8 n
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     2 {0 _; i( _2 b# V7 b
120.         }
     - }  U# e3 @3 K
121.         return $decoded;
     
122.     }
     - A; X" G6 A; g( x
123. 
     5 }4 H/ ?2 C) h9 ^; o4 Y
124.     /**
     
125.      * 发送数据
     4 b$ D: i( G; P+ D! Z$ O# O& f
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     ; k5 [# u: d4 k9 Z8 q/ }7 Y
128.      * @return int|string
     7 _# b# Z8 [( z- Q0 M% D1 |
129.      */
     
130.     public function send($newClinet, $msg){
     3 p9 ?; K, I* y' h/ T  K: c" N0 W  B
131.         $msg = $this->frame($msg);
     8 i1 G2 c2 {0 r& A, C4 Q
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     & a% R& t6 ]; j! r6 l- a, j- j5 K
134. 
     3 z6 N" \! _' A/ u& |
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 = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     & {8 @( P4 l7 ]1 Z5 c2 V" G
145.     }
     
146. 
     0 Q' L+ s$ [' X$ @9 J* Z5 ~
147.     /**
     - y* I% S- U9 Q# d' X6 A. {
148.      * 关闭socket
     + V% w: O0 W4 Y* E+ v: I# x
149.      */
     
150.     public function close(){
       u4 b% i0 z& j' h$ c4 ~% j+ ]3 M
151.         return socket_close($this->_sockets);
     $ i* e2 S. Y6 q
152.     }
     
153. }
     / ]! x2 a# j; _$ u9 A* h$ v
154. 
     $ r4 l. X$ g9 ?0 Z8 x
155. $sock = new SocketService();
     3 A: v& Y' u! M
156. $sock->run();
     
157. 
     : @1 O2 }; a" m; M

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   * S- e/ x5 Z( ~: u! R' I
3. <head>
   
4.   <meta charset="UTF-8">
   ) Q3 ~, Z4 ]1 U; H7 N8 \2 y9 a. U
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   9 ~) ]4 F9 g; s+ _
6.   <title>websocket</title>
   7 U: h) Y2 H# B, o
7. </head>
   , J+ ?9 S9 Z+ I0 h# o  q
8. <body>
   
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    * l, t0 s5 v' V0 C
11. <input type="submit" value="close" onclick="close()">
    % J) G4 y0 e+ k3 d# b  s
12. <div id="msg"></div>
    
13. <script>
    0 f  k( k3 J# G) q) T
14. /**
    ; |$ f3 ^7 F& w8 a  x0 o
15. 0：未连接
    ) @0 L3 }& y/ R  ]! u3 p! Q
16. 1：连接成功，可通讯
    3 _; j% y, o7 D0 L( ~
17. 2：正在关闭
    4 E7 K' t" F$ z% K; G: }) G5 o
18. 3：连接已关闭或无法打开
    
19. */
    ' N, t' ]+ Z4 j0 u# d
20. 
    8 h. ]" Z) n2 W/ T" d% s
21.     //创建一个webSocket 实例
    - N; M$ M2 M* }# g0 ?! l% o
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
      P# M6 _& e8 U  T
25.     webSocket.onerror = function (event){
    9 B( |% P- J* ~
26.         onError(event);
    
27.     };
    6 s& q% ^" [/ w: L; O; J+ n3 S3 f
28. 
    ( P; u4 c! k' A! k8 G9 U
29.     // 打开websocket
    7 ?9 R" n- ?6 {- J" ~
30.     webSocket.onopen = function (event){
    " y/ B" K& r7 p8 A6 x
31.         onOpen(event);
    - H! ^; L/ e  @
32.     };
    $ `6 ?) D& r: {) J' Z
33. 
    2 ]( ?$ D' p4 D+ R
34.     //监听消息
    6 V- P- |: O1 b; J$ E/ S
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    , K# n5 j; S2 v$ X0 D
38. 
    / ~$ _  I0 Q* {+ ]
39. 
    
40.     webSocket.onclose = function (event){
    9 ^& q- b& ]- M
41.         onClose(event);
    
42.     }
    
43. 
    " p4 R7 A& n/ L& R% g! b
44.     //关闭监听websocket
    
45.     function onError(event){
    ; F4 e# ?% C* v' u: J# r
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    7 z- g8 B) K5 m) h% X" F
49. 
    + g2 D3 V" U% l5 R
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    + e" R3 J1 r$ a; F+ {
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    1 _! ]0 {  C* {7 Q
54.     function onMessage(event){
    ' Z# ^, b4 _( H3 w2 f9 D8 v
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    # `( o3 l% \9 H
57.     };
    5 f5 `2 _, W- r
58. 
    
59.     function onClose(event){
    / Q/ N0 Z3 T9 `% Y
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    / g9 B$ B; ?1 V5 F. c. K+ x3 X" j9 K$ H
61.         console.log("close:"+sockState());
    3 t( y" `/ V; m+ O# R
62.         webSocket.close();
    
63.     }
    
64. 
    ( d! T$ a' J' h* B# V
65.     function sockState(){
    ! z# `' J; C/ V& M! r3 H0 O- H' D8 _
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    # f9 E$ u, u1 U; K$ t1 v
67.             return status[webSocket.readyState];
    
68.     }
    , H2 {, b( P1 n) ^; o: g8 T! n
69. 
    6 ^: G0 v/ |- |2 j8 m
70. 
    
71. 
    
72. function start(event){
    ) r: N& S! p5 c' s, K
73.         console.log(webSocket);
    5 W7 Q3 t, U8 S) r5 B& h( q8 P8 j. Y
74.         var msg = document.getElementById('text').value;
    2 U+ x; a7 {$ n2 p
75.         document.getElementById('text').value = '';
    8 l  \+ K. }& O, H7 ^4 z" n8 y( ?
76.         console.log("send:"+sockState());
    - @! {; A6 c: }0 ^, ]
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    + y+ G. o' Y' W: g
81. 
    
82.     function close(event){
    8 G  H+ o& M; _& k
83.         webSocket.close();
    
84.     }
    ; e: F- v1 ?, V- L
85. </script>
    ' p, V$ X* Q5 o, K3 r
86. </body>
    ! v5 K0 t6 p8 E  m; S. S# g7 h0 b1 O
87. </html>

复制代码

8 w8 u, }6 m9 M# j4 G