php实现websocket实时消息推送

admin

php实现websocket实时消息推送


SocketService.php

1. <?php
   % Z' l( W+ \- ^2 x( Z% G7 n7 p
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   - `- X3 m6 ?% v/ `4 M# j
7. 
   
8. class SocketService
   
9. {
     u6 H# F4 y7 Y
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    ) j" U( v4 F! a- u% I, F, F0 _$ @/ a
13.     public function __construct($address = '', $port='')
    5 ?% l1 U  b' w! @  m4 o
14.     {
    ; a' Q, l! g1 D$ A! J8 }$ j, d
15.             if(!empty($address)){
    & u2 L+ }5 b" d6 ]7 ?* i
16.                 $this->address = $address;
    
17.             }
    $ d  d$ c' }" V$ M% j4 b5 [
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    
20.             }
    1 r! M9 ^- q4 t) c/ W$ G
21.     }
    
22. 
    ' z- p& m5 z& p. K% e1 T: u. e
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.         {
    # _$ {% k9 h3 i/ P; |5 z2 w( C3 N
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);
    
34.         echo "listen on $this->address $this->port ... \n";
    " O" o- J2 J: S( E4 Z% l
35.         $this->_sockets = $sock;
    & s; _- q7 Z5 u4 v0 w; D: E5 Y
36.     }
    ) d& i$ t, K- O
37. 
    $ G. x" ~/ t$ q% F, `) b9 m8 @
38.     public function run(){
      v; T5 z7 Z' c3 m
39.         $this->service();
    * P& N) f7 c5 l, U
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    * x4 P# r; V# J4 r' {
45.             socket_select($changes,  $write,  $except, NULL);
    2 w; j! `$ V) O' A
46.             foreach ($changes as $key => $_sock){
      g) z' P; e( _: E4 j; G
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    & X5 X0 A" u0 m
48.                     if(($newClient = socket_accept($_sock))  === false){
    8 w  f& ]0 p% K" n% o" L" }
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    8 Y( U0 i: C/ Q  O8 m
50.                     }
    7 T! U1 V' R) B: T4 [& y
51.                     $line = trim(socket_read($newClient, 1024));
    5 F6 A: K* |0 [* M3 W, ?
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    * l& E0 C5 \8 {$ R7 ?1 g' ~
54.                     socket_getpeername ($newClient, $ip);
    % F+ D& y7 f( _2 f6 A
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    4 A5 e  I. a  n3 I2 L+ u
58.                 } else {
    # x0 k# _9 _# p! ]- c% |# b4 C
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    5 f& n: U7 E# [
62.                     echo "{$key} clinet msg:",$msg,"\n";
    6 S7 z6 B0 X5 G# G, q
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
      z9 v& `: Q6 n1 A
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    & K$ S$ w, I( o7 a
69.         }
    
70.     }
    4 k0 c" V- S; L
71. 
    ; C4 q' i. B& ?/ `0 s' f" o& Q
72.     /**
    * q. Q5 ^' Q) K6 I$ v
73.      * 握手处理
    % `  s/ K  y8 ]( u: H
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    # G5 o4 A$ n  D" A1 K* ]! K; l
79.         $headers = array();
    , ^$ X% L/ b8 K0 e& K
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    * t* O# m; h) m! o) a
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    9 `6 c/ q" T: `: y8 j/ u
85.             {
    1 S( W: N" D& f
86.                 $headers[$matches[1]] = $matches[2];
    ' {! |4 \$ V. ~
87.             }
    1 n' w! k" {& D9 y% _
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    . K/ z) ~, v0 o" |+ \% ?0 A. o
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" .
    7 [5 a1 Z' ]+ c7 o) p% n. n
92.             "Upgrade: websocket\r\n" .
    , m9 P# C8 f$ H
93.             "Connection: Upgrade\r\n" .
    
94.             "WebSocket-Origin: $this->address\r\n" .
    7 ?6 }9 L5 [, g+ a% }
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));
    
98.     }
    
99. 
    
100.     /**
     5 n( L5 N* H; i6 A
101.      * 解析接收数据
     
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
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);
     / t+ S# i! y' I3 c% d0 K
111.         } else if ($len === 127)  {
     6 |: e7 ~2 S1 ]" b" M/ d5 Q  `$ b
112.             $masks = substr($buffer, 10, 4);
     - f! }8 E6 `- t" J  S
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     7 q) s9 _4 G; G2 V8 f
117.         }
     0 w- }; X, Z% K6 G' P$ e
118.         for ($index = 0; $index < strlen($data); $index++) {
     3 S+ P  j: S1 D! a- R$ ^' R4 m
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     # c) R7 A4 E" i0 G6 O4 s* M
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     % A/ c% S( y$ p6 S8 F. x
124.     /**
     
125.      * 发送数据
     5 y" g! k. Q0 u8 r, r2 k5 v
126.      * @param $newClinet 新接入的socket
     ( B+ ^) ?, T6 Y# E# N! F
127.      * @param $msg   要发送的数据
       R, Z& @: V& ]
128.      * @return int|string
     1 O/ I. }" c; W0 ]- S, i- W
129.      */
     
130.     public function send($newClinet, $msg){
     6 R- V1 j- Y  l
131.         $msg = $this->frame($msg);
     5 C9 x: x, q0 b# C) Q$ |9 y& I
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) {
     ; z/ N# V  D) |% A4 l/ X# r; G
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     , H- e+ p. p6 ~7 Z  [0 D
139.         }
     
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     7 E* g, V" o: a/ W& `+ G; r& k
143.         }
     
144.         return $ns;
     
145.     }
     
146. 
     & j& u$ `6 o/ W  X
147.     /**
     ( c+ S- ?5 F9 I- l: u  U6 n4 }( h
148.      * 关闭socket
     
149.      */
     ; U: E! \9 k1 B& g& S* W  _; O
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     
154. 
     
155. $sock = new SocketService();
     + i8 _. ]% W8 C& g8 A" g
156. $sock->run();
     
157. 
     ! K# g6 a  W/ w+ m

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   
3. <head>
   6 o3 V4 q6 h% h
4.   <meta charset="UTF-8">
   " S$ A0 E+ G- ]$ F; h7 y% c
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   * s# L' v: C' ]7 ^+ K8 }! T
6.   <title>websocket</title>
   7 G8 t8 w9 s7 T
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()">
    0 U5 o2 y) i" c/ p4 ?% L
12. <div id="msg"></div>
    ; _9 J+ T8 ~. o" p- B, S
13. <script>
    4 Q  y& S: L* o+ D, |  g
14. /**
    7 B5 o2 m" K8 k4 I; q  C
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    1 K6 F4 N3 Y8 J6 g# a# p
18. 3：连接已关闭或无法打开
    
19. */
    
20. 
    " q: K9 t5 V  u' B0 |; K- J
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    2 V3 ^9 N% L$ s) V! w
24. 
    
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    # ?/ V8 @" C; |0 m# Q" T# F, i
27.     };
    
28. 
    3 F0 t9 H# G% n1 c9 J( {
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    - p3 H" o7 p9 p/ e
32.     };
    
33. 
    0 R% j/ B2 l! p# o
34.     //监听消息
    $ m# f" h4 j4 k: M; F. T, b! L& ?
35.     webSocket.onmessage = function (event){
    - S* ]" L8 J/ a- @7 v
36.         onMessage(event);
    
37.     };
    ) r! F; a+ d9 v8 ~3 C' q
38. 
    
39. 
    . w' R  e( H+ O; a7 k
40.     webSocket.onclose = function (event){
    0 }3 ~. A. F0 V) b
41.         onClose(event);
    ( {" i# B% ~* z8 c0 t6 T
42.     }
    * J6 V6 q: {: m( ^
43. 
    . l2 P8 M/ ?( y7 P
44.     //关闭监听websocket
    ; p2 T$ o* \; r3 n9 v
45.     function onError(event){
    $ L% z0 `% l5 m% _1 X% I4 t) O% G
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ( j9 ]* Z9 a# W" D
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    2 Z3 {* `0 u7 l
50.     function onOpen(event){
    4 [5 h) o+ b7 Z5 L& w/ [
51.         console.log("open:"+sockState());
    4 f; I" E' P( V7 n3 Q- H
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    ' ?  q# \, ?% u2 }! P
53.     };
    ! Q- d# X5 ~7 O1 ]# ]
54.     function onMessage(event){
    / q' }) u) i& c: ?% O
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    . z4 E, x4 h+ h, O
57.     };
    + A8 J) W, @3 X
58. 
    8 i; H) P- d* h' Z1 u7 h
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    5 I+ N. L, j+ s' h- n
62.         webSocket.close();
    % q1 @- P8 v9 d: n9 S- p) s
63.     }
    5 n- W0 t6 t/ B) |3 A/ O# s
64. 
    ) L0 z" Z" w$ x, }
65.     function sockState(){
    & F& }9 t& w' x3 f4 Q
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    + ]0 Y6 y7 |4 o, t8 X
68.     }
    
69. 
    2 @+ c6 |: C( n5 b
70. 
    
71. 
    
72. function start(event){
    9 R: C5 `2 S. l9 r0 O+ ]
73.         console.log(webSocket);
    + m2 K' r- J6 l5 r/ B0 |: z9 E
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    9 o9 s: w% G0 \6 ]: V
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    6 z$ Y! P1 p/ R$ n
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    # M4 f( Z; _8 Z1 U0 Z) C
81. 
    ) o$ k0 `' b# u5 a" ?
82.     function close(event){
    9 w# D7 N# i- m/ ^
83.         webSocket.close();
    
84.     }
    ! Q; V* w+ ]% P. g$ n( b- w1 W
85. </script>
    
86. </body>
    8 s, J5 _& Q0 q9 g$ e# L0 M8 Z
87. </html>

复制代码