php实现websocket实时消息推送

admin

php实现websocket实时消息推送

: y/ j% N$ Z0 `( |( G- V
8 [" v  G- b2 m% \6 WSocketService.php
+ s) X* t5 U$ T0 }! F

1. <?php
   $ D7 R# V9 V; ?8 H. W
2. /**
   
3. * Created by xwx
   $ z1 j0 y  |$ m( \+ E- u/ r* o
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   
7. 
   " J% M' ^0 B* Y" U; l
8. class SocketService
   ' X3 E$ X7 E: G7 s; z5 J
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    * }6 x) h. t- P2 i" p
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    , I/ `! U0 ~: S% j! E: `! a3 d
20.             }
    ' c! F' y" }0 D/ |0 O  b
21.     }
    $ }3 u5 H# U8 O0 J* K% S
22. 
    
23.     public function service(){
    # s3 w. Z$ r5 u6 b
24.         //获取tcp协议号码。
    % j4 Z" r$ M5 O# @% X' e$ A% N# q
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.         {
    9 e$ _% J' H/ A" D, f
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    1 v# L" r- \7 m- F& f2 Q5 \6 T
31.         }
    0 p0 ]9 A. c& W; C4 ?6 x7 n. h
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    8 Y- m4 t6 P" E+ L1 \- v( I4 v( z
37. 
    4 l, d8 V! ?3 u3 R5 r, c6 k
38.     public function run(){
    
39.         $this->service();
    1 g) c# C' b/ H  W
40.         $clients[] = $this->_sockets;
    8 `, Y& E9 p/ k  A8 D3 {* k8 m
41.         while (true){
    
42.             $changes = $clients;
    + {  O% W) o5 ]4 J$ o
43.             $write = NULL;
    " q- }' I3 b7 ^; M4 p* s/ ]
44.             $except = NULL;
    1 ~5 S0 K+ f7 c' B) a/ o
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    # Y! v% Z: U7 G( ]7 G
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    0 a6 c+ Z, @# F8 U" {
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
      a. P# s7 D7 M4 B' }, ~0 ^, t
54.                     socket_getpeername ($newClient, $ip);
    # u/ X. v( x( ]$ ^& p* O
55.                     $clients[$ip] = $newClient;
    $ V' S6 M) t, y, j3 r$ t- @0 T. Y6 [
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    ! _: f: y3 h; S7 Z$ ^8 t/ z
58.                 } else {
    % {2 _/ l& Q: ?) g
59.                     socket_recv($_sock, $buffer,  2048, 0);
    4 _3 ]) q" D- ]
60.                     $msg = $this->message($buffer);
    : D8 y: h5 y. y( ]+ {  u5 p; |$ `; e
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    $ _9 m9 ~9 P0 }  w3 z- |- f5 X
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    4 ~6 K6 I+ P; T6 e% p
67.                 }
    & |2 ]0 o9 T7 b7 }% b  U  Z
68.             }
    ! I5 X% O: I# c
69.         }
    
70.     }
    
71. 
    
72.     /**
    ! f+ {  I( N0 [  N0 x
73.      * 握手处理
    ! ?8 A' X; _* S) H6 C' _
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
      D  k3 K9 F, |" G. K$ h" ?
76.      */
    . k3 z1 a9 z1 j# |# Z
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    1 v% G% _( |5 j% o! ]- {1 T7 k
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    + e* L* h, d; ]4 e* v  i" V
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    * _) l. o% |* R7 n; x: S
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    0 @, H$ G2 l8 q1 g: N' ^1 S
88.         }
    # B* n. D# v. r& _6 I
89.         $secKey = $headers['Sec-WebSocket-Key'];
    9 i4 [+ @, ?$ _6 x8 t# R
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    7 Z$ N: A! a, k' L# j
91.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    
92.             "Upgrade: websocket\r\n" .
    ) l) Q) U" b* u) M. v/ ~9 v
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    
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));
    6 h$ }, M9 m/ I9 H2 I
98.     }
      |6 E; h8 X4 S4 ~  ?9 r6 r
99. 
    7 R0 k" o$ K3 L3 ~' H
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     0 J$ J! y. k+ R+ Q2 ]$ q! U6 t
105.     public function message($buffer){
     4 I9 I! W, X+ N" |% O8 m
106.         $len = $masks = $data = $decoded = null;
     + ~# f8 E3 _) k" p/ D
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     , O3 i  T6 m6 |4 \# Y! `2 ^( ?
109.             $masks = substr($buffer, 4, 4);
     ' D) d6 k' \5 c8 g( Y5 |* U
110.             $data = substr($buffer, 8);
     3 _- W9 ?6 A! X! {. T
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     6 p7 X! x$ u* s* \' ~
113.             $data = substr($buffer, 14);
     5 n% Z7 B+ u! T2 I0 b# L* W
114.         } else  {
     6 N* D% w; q/ i8 @- y" v* E
115.             $masks = substr($buffer, 2, 4);
     0 Y3 ]# K0 L' D: I; W: y6 M; Q
116.             $data = substr($buffer, 6);
     
117.         }
     ( u6 c' A( n4 N9 V
118.         for ($index = 0; $index < strlen($data); $index++) {
     ! ~7 c2 q8 v! Y% z  I" u8 m
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     2 h1 T) l, p5 l* {
120.         }
     % s( O. ]2 q" A$ k, |- K: x1 O6 P
121.         return $decoded;
     
122.     }
     
123. 
     
124.     /**
       \6 T1 G. \$ I! m& K
125.      * 发送数据
     & N" |4 o3 u0 U$ Q
126.      * @param $newClinet 新接入的socket
     2 d" o2 c; n0 X  y5 ~% `) J
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     6 H) z8 R: X5 E$ U6 R
129.      */
     9 i& {6 R, l) K  v! P
130.     public function send($newClinet, $msg){
     8 I) G6 P6 \2 f% R5 u
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     7 i1 T! ]7 k" K
133.     }
     
134. 
     
135.     public function frame($s) {
     / ~# M' J6 p# O) Z* q
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     % B( R% S; w8 w
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     % ^3 u0 {% e& D
139.         }
     * ~* S/ X' c8 I
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
       u9 V( j5 x6 p4 Q
143.         }
     4 R, T% W# a+ N! J& R5 a) @9 ~
144.         return $ns;
     # k- a+ B9 N) d" {* M" q& ~, q
145.     }
     
146. 
     6 ?- v4 K1 E' u
147.     /**
     7 w: b* Q6 y2 ^7 T. o3 Q, @
148.      * 关闭socket
     
149.      */
     + w$ M2 v# Q& T& V' x* r& y
150.     public function close(){
     0 z% ^) ^, C+ |' E: c" R5 I
151.         return socket_close($this->_sockets);
     " w  _! W: \1 z+ j9 k( h
152.     }
     . O0 H! m3 [' G: `. N  Z
153. }
     
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     + u4 I7 t1 Z! ?% n6 B* C

复制代码

web.html
- Y" I  u' z3 V+ ^: n; H

1. <!doctype html>
   
2. <html lang="en">
   7 y/ v9 V! G0 ]6 w7 Y# Q
3. <head>
   
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   # {+ c& H% Q3 c' Y' V
6.   <title>websocket</title>
   * \5 t* {1 |7 l4 S' E& e
7. </head>
   7 ?3 a- @4 x" S+ a6 k
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>
    
13. <script>
      m( t9 h3 q2 j# ]$ d$ j6 X
14. /**
    : _/ Z- A# s3 j
15. 0：未连接
    $ u4 I/ A4 c0 i+ X, C8 M$ i
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    * G" l. `- _! J, Q9 `" m0 g! w
19. */
    4 p0 P0 |1 }% ]* O6 _
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    ( U7 K7 A& I4 o
23. 
    
24. 
    . a& t% [% [% ?1 J, s
25.     webSocket.onerror = function (event){
    + A- Q9 [8 G  @8 S, \6 Y# g0 V
26.         onError(event);
    - }* E/ F: Z# n  i) i8 Z
27.     };
    
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    , s8 r: r  u, D; d9 \
31.         onOpen(event);
    * J: i, i' K! H$ [
32.     };
    
33. 
    
34.     //监听消息
      x2 S# i* I/ f1 {* S
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    , ]5 D) o+ l2 [
38. 
    9 q8 L+ x5 i2 r7 h
39. 
    / C7 f) Y$ ^3 K
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    ; `) D, ?- z7 A# t/ P. Y6 n
43. 
    
44.     //关闭监听websocket
    6 c7 ]; |' W; U
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ( l4 ?6 [' o* ?* q
47.         console.log("error"+event.data);
    
48.     };
    / ^9 D3 b, D$ {: L
49. 
    ' d  b3 L; g' h7 ]  X/ U8 s
50.     function onOpen(event){
    , l8 |# N* a& v- j0 }
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    # \( D2 J' J5 p' i+ N
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    9 X5 B* U0 M/ ?0 e8 i0 B5 g
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    ) N0 Z2 E- r0 n, z
57.     };
    " d% z$ X# D6 |" |. z1 }! q! d
58. 
    - I8 L$ D0 e, a( b
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    & |/ v- g3 R$ R; F, L. b* P
63.     }
    ! t* r$ c: v+ Q
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    7 x+ W( W' g7 i0 t4 C4 S( x. E( i
68.     }
    1 h( f2 K7 b" s
69. 
    
70. 
    
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    1 U8 C5 Z, W4 U5 ?9 G
75.         document.getElementById('text').value = '';
    # X$ t# b/ }  E5 _9 t+ H
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    ) [1 ~8 Z0 ^; V4 q0 w$ p) b/ m
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    # ~" r/ Q: R% p: J
82.     function close(event){
    
83.         webSocket.close();
    
84.     }
    
85. </script>
    3 g& T. U2 |- t" J' G: S3 n1 A
86. </body>
    
87. </html>

复制代码

7 v* e. h8 |" [. {/ B+ E