php实现websocket实时消息推送

admin

php实现websocket实时消息推送
& L& F& A& o3 Q9 y$ y

SocketService.php

1. <?php
   ' v; X! P& e) F/ |
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   5 V: @3 `6 b  I' j& d
6. */
   
7. 
   
8. class SocketService
   9 ~' U' s4 u+ y# }# }0 M$ @
9. {
   
10.     private $address  = '0.0.0.0';
    + v/ @7 c# H& n- |
11.     private $port = 8083;
    
12.     private $_sockets;
    : K3 |' g$ }2 V9 w
13.     public function __construct($address = '', $port='')
    4 k$ K) E# d, t  h, H
14.     {
    
15.             if(!empty($address)){
    ( K, {! _  |1 g/ m( A8 n
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    0 n4 i- V: t: Z
19.                 $this->port = $port;
    8 e, L) a2 i% |# T: b) b4 i/ ^
20.             }
    
21.     }
    , K) y. B6 m% C$ T; a3 \
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    6 }! I( ?1 o! R# T/ J& E
25.         $tcp = getprotobyname("tcp");
    
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    " o. n; A# V5 e! S4 F
28.         if($sock < 0)
    " w, m4 c: S) s1 r# x2 b& u6 u4 K
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    % C3 ~( i7 T) k
34.         echo "listen on $this->address $this->port ... \n";
      k9 c& W8 v3 p0 o3 V( k# T: C
35.         $this->_sockets = $sock;
    
36.     }
    , z- d- Q% c# ^: W) c; d
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    4 c' s& ]# U  D* n1 n, G- T
41.         while (true){
    ; H1 ~/ N, P) ^2 y( r
42.             $changes = $clients;
    . B/ L; ~  ]) Y( M& [; D
43.             $write = NULL;
    
44.             $except = NULL;
    / {; w5 r) t- v
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
      F( t- F6 Z' \# Q1 o/ G$ O+ u
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    ' `0 @1 G) h" v$ G% ~2 f
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    % d0 w. N9 o8 g) s8 Y2 T
52.                     $this->handshaking($newClient, $line);
    4 P8 s  A/ ?7 W- E6 b$ b
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    4 S- C6 z+ Z" r1 q8 A: {" G+ A8 r
57.                     echo "Client msg:{$line} \n";
    4 |' k1 p3 {% s) V5 y
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    $ S( y. s) B5 W* s/ Y
62.                     echo "{$key} clinet msg:",$msg,"\n";
    ( K; W$ W, w' _" a; [: E
63.                     fwrite(STDOUT, 'Please input a argument:');
    8 Y4 ?! Y4 @5 k& `: C+ t( P) `% ^
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    - i3 o7 c* ?- R
66.                     echo "{$key} response to Client:".$response,"\n";
    2 d+ t. ?7 P( Z+ {( ~3 z" e2 i
67.                 }
      F6 D% f, ?+ I) ]  A9 Y# |# ~; @- O
68.             }
    5 f# I4 ~0 P+ |# Y
69.         }
    
70.     }
    
71. 
    5 R/ h3 E$ Z; Q# X
72.     /**
    
73.      * 握手处理
    ' g2 V. w2 F8 k. M4 i
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    ( W( Q/ w# m! `8 d) j2 r$ U6 {
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    7 F( c1 ?$ l* J& ^
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
      j# r* @4 D. T( e9 m! Z  `6 e
81.         foreach($lines as $line)
    8 I% }8 }) O) Z9 ?; i
82.         {
    % ?6 x# O7 g: ^# O; w: ?
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    / z  U# N5 ~! P# A! I6 v
85.             {
    5 G& v/ t2 a! C3 E
86.                 $headers[$matches[1]] = $matches[2];
    ' X& D9 W. _" W: D1 A
87.             }
    
88.         }
    ) s* r2 {7 ~0 i3 ~
89.         $secKey = $headers['Sec-WebSocket-Key'];
    
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" .
    . N0 z7 @; g+ M5 Q8 k: I- X2 O
92.             "Upgrade: websocket\r\n" .
    5 j% g( w4 s& j* T( m; r% R$ R
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    " Q; O! |, W' `/ o7 X
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    " M: y0 H2 X$ g! Q7 p! ^
98.     }
    % B$ A0 F3 g& d  F4 }0 o
99. 
    
100.     /**
     0 Y" }4 I" {0 @( w6 _' K
101.      * 解析接收数据
     ! x5 \" Q6 ~( c5 \
102.      * @param $buffer
     
103.      * @return null|string
     9 a( j* r/ @1 p  _  E- F. R
104.      */
     
105.     public function message($buffer){
     " g+ `+ L! j( Z( y. Y3 `  Y
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     1 c2 I+ ^2 b1 c# _
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     " H& h7 h. E5 d- c
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     * f, Z3 n6 Z, M. t, W1 P+ g% ^" M0 ]
118.         for ($index = 0; $index < strlen($data); $index++) {
     ; W. ]$ g! P" d! f
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     $ ?5 H+ \  a# f! t
120.         }
     * N0 p# w- B$ i. {1 g4 S' _
121.         return $decoded;
     8 ?9 \0 P  i% l: R- u
122.     }
     
123. 
     
124.     /**
     ' X  I& j7 p6 `1 I7 ~3 C$ u+ C& w" [
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     6 C! u$ K/ s+ b& Q
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     # Q# P" w1 }( R, I$ }% a
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     + Z4 ?/ {1 M1 R" h! p4 n2 w# W+ s
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;
     
145.     }
     
146. 
     ( D. j+ U' J( k) X4 t, q
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     6 V) G$ r" \) u
151.         return socket_close($this->_sockets);
     
152.     }
     - j6 n8 ?; R1 [
153. }
     , P8 m) {9 d0 K
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     1 E0 `' c! Z- k# U! n( z+ A8 a2 a1 b
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   5 o! O5 [8 Z0 H* o
3. <head>
   $ L  H4 s$ z' p) F4 F% f1 O
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   
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>
    ) k  `  O% J$ w
13. <script>
    
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    ) @( D3 X& C$ t5 p
17. 2：正在关闭
    + K3 l5 [% K* p2 B4 Q0 G! L
18. 3：连接已关闭或无法打开
    ' m9 G4 e3 j5 W3 r
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    3 r8 i' A) r7 r
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    - X! n% Z( Q+ o" E4 V4 z% w( ]4 d
24. 
    ) g8 `: ^% x8 G. L8 x
25.     webSocket.onerror = function (event){
    ) C1 ?4 M$ j2 e7 ^
26.         onError(event);
    
27.     };
    
28. 
    / }2 A' t, E* Z5 {/ e0 X
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    6 D7 h5 W4 h+ b" d
32.     };
    5 W0 Z: x7 g' j3 N
33. 
    + I0 E, y# P& F$ d% F; g1 J4 y
34.     //监听消息
    $ T6 N) x$ `% \' E
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    5 T8 ?/ a8 t0 c3 L4 I6 N
39. 
    9 x) T5 m8 o, @0 t% M2 H/ }& J
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    ; m7 N$ O$ X9 K" {% Z1 S
43. 
    
44.     //关闭监听websocket
    
45.     function onError(event){
    ; R2 x/ b% T; R: R  r/ r
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    - ]% Y' E; B9 y: D
47.         console.log("error"+event.data);
    % d; f1 K5 E' a% T/ R5 @/ b0 [
48.     };
    
49. 
    
50.     function onOpen(event){
    $ J: T  m' x* A" t7 t, T5 a; i
51.         console.log("open:"+sockState());
    : X6 e& J3 I, t; C0 ]* V
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    + c$ u: Z; g$ ~  e4 _/ `
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    6 t1 Z. T0 i& e
57.     };
    ( M: }, k- I; P8 s+ E
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    * O1 ~# Y3 S% h; Q/ G6 Y: k
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    3 w; m/ f4 C# H/ n- i5 [2 x
63.     }
    
64. 
    2 r! Z# }  F0 f
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    # H$ Y7 c6 V, `( C
68.     }
    
69. 
    
70. 
    
71. 
    
72. function start(event){
    * @4 k4 X  s4 B, V0 m
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    4 y& ?0 e3 O# r+ B
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    6 _: B. A& z1 K0 s) S
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    9 `. D) z& J6 `6 C8 C+ Q" r
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    
85. </script>
    $ ]9 @% @) S# k
86. </body>
    ( k' I6 O9 L% r& g
87. </html>

复制代码

1 t# o0 m3 }  R! z; C9 s, l, ?
+ g. n2 F( Y* l% d% O3 Y