php实现websocket实时消息推送

admin

php实现websocket实时消息推送

) }% C' ]- H3 Y+ q# t9 P( h
SocketService.php

1. <?php
   ( t1 a; |) e' V( H2 n
2. /**
   
3. * Created by xwx
   ! h  u- w/ X& y. Y
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   
7. 
   9 |9 L5 O  m2 [
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    4 E* _* p0 W0 p$ I4 b  R, J, J
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    9 P" p7 c( [6 D7 i0 O; E
14.     {
    
15.             if(!empty($address)){
      t3 o6 w9 L7 C: A5 m
16.                 $this->address = $address;
    
17.             }
    # V% J8 u6 X* |7 e- L
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    ; u, \% I! v8 b
20.             }
    2 b! l# z. a. I( J8 t
21.     }
    # e9 _7 Z3 b1 S" q" s
22. 
    
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    : F8 K, @( o( k' u7 u
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    + ^0 t# B' I" E4 x8 v1 F
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    - ^: ~. `8 C5 i+ D) y
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    2 ?1 }5 A9 ~! w. Z, L: h5 }" i8 O# v4 _
31.         }
    - H. i) t! z5 u4 w0 m
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    ! F- {( [, s" i
35.         $this->_sockets = $sock;
    % j. F0 K7 ^, C0 x* {8 h3 N1 o
36.     }
    . S7 g6 |! q' H% g, w0 G2 u& r, |
37. 
    
38.     public function run(){
    $ o+ b% Y  U% N4 u& Y+ c8 h
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    % z& `4 y) a' n7 W- {! _4 g
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    " {  k2 E" m# N3 N1 a
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    & _# Y7 ?. [# s+ {; v: [* p
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));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    2 M3 R1 m' c2 `& s! o* U4 U  c
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    3 n; m- F. H$ F# d0 [
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    ) `$ S. F0 |7 `; ~
59.                     socket_recv($_sock, $buffer,  2048, 0);
    / G: z% `8 a$ b, A4 d
60.                     $msg = $this->message($buffer);
    7 D. q* A7 _8 u
61.                     //在这里业务代码
    ; X8 p( `; d/ Y$ }. Y# g
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    ; q) \; L9 @# V- \+ q0 f: [1 Y
65.                     $this->send($_sock, $response);
    7 B; U& H+ ?* F. Y- l
66.                     echo "{$key} response to Client:".$response,"\n";
    8 i* R. l! |. u, q4 B0 J3 H
67.                 }
    
68.             }
    
69.         }
    
70.     }
    
71. 
    " c, P1 R, }7 X, v3 k
72.     /**
    8 R% u/ j  u" O' ]: |
73.      * 握手处理
    0 o. y9 x  O  x6 G
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    ; C9 B6 F' g0 g2 s
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    ; `+ u5 |8 r; w: C, d% ^1 i
81.         foreach($lines as $line)
    
82.         {
    
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    + ~6 U$ u3 x0 O4 S, e
86.                 $headers[$matches[1]] = $matches[2];
    * P' k. e% ~) J* _6 x+ I, K
87.             }
    1 s% ]+ O8 n4 z* b" V) i
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    & h9 E( D" p. N0 |6 L( \+ C
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" .
    9 o. W: L6 S- y
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".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    
99. 
    
100.     /**
       r% I) S- U9 E2 M4 e4 i0 ~$ y
101.      * 解析接收数据
     
102.      * @param $buffer
     # d* v8 K3 b3 Q' I+ l! z2 }
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     & l  b' r7 c9 a- k0 v* G
106.         $len = $masks = $data = $decoded = null;
     0 s8 R9 Z' d0 Y  B7 [
107.         $len = ord($buffer[1]) & 127;
     ! t/ ^% d7 A, `" H/ R
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     ( F' r+ v& ^% S0 W( I8 j9 {# r
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     0 ^- f4 y7 A8 l: q
114.         } else  {
       H& U8 c1 \# A$ q
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     $ Q0 I# d: X7 F7 `6 C
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     0 o. G; `2 w; A& O2 K
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     $ S8 `% D% i$ V' C1 S! U0 M2 A* g
121.         return $decoded;
     
122.     }
     
123. 
     ! F4 W( ?" p& _
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     
128.      * @return int|string
     
129.      */
     6 J9 E* N$ \- Y5 b( J/ X  O
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     4 Z4 V: m2 }" M  j: k
132.         socket_write($newClinet, $msg, strlen($msg));
     # z3 t, h- B+ w$ c4 a2 G+ a
133.     }
     / N  Y: {8 o7 d- o
134. 
     ( ^3 Q  E( ~# H" p, y9 X
135.     public function frame($s) {
     4 D& j8 P3 j* j
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     3 ~5 d5 P7 X; f! l" j
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     3 t- U4 I8 p: Y' m) M" i  N
143.         }
     / x- _" y! `3 v# S& ~
144.         return $ns;
     4 P) e2 p4 R6 _: C
145.     }
     
146. 
     + b8 @% ?% j4 G2 N$ N) m
147.     /**
     
148.      * 关闭socket
     
149.      */
     ! F# M) D! F! K0 ]2 D6 U
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     ' `- y: {, g% y! f8 H* o. [
152.     }
       b2 H# `, v/ |* G, D$ a
153. }
     : w  U: G1 v1 e' p) ^  t
154. 
     2 y0 k5 G7 u# e$ z/ j
155. $sock = new SocketService();
     5 W) S3 A4 w6 A+ \5 \7 T
156. $sock->run();
     
157. 
     # Z- I5 h# l6 B. H* `; {) i

复制代码

web.html

1. <!doctype html>
   1 L1 e, a( c, |* F5 a
2. <html lang="en">
   6 Y2 @; U! I: z5 I7 b' g' _
3. <head>
   
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>
   % D, Y7 E* u6 }: u6 Y" z
8. <body>
   ! E5 `8 H$ p, s* Q# f# V1 X- m* f
9. <input id="text" value="">
   ( U- P5 }& K" T# e7 X
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    , e: [4 q2 x2 h3 f, [( G
13. <script>
    3 P0 R2 C1 c' N$ P) \
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    , q1 `9 B( z2 l* z  t
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    8 N* z8 U& R5 R8 m% ^1 Y
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    ' C) ^5 ~0 a/ T! M3 |
28. 
    
29.     // 打开websocket
    ; P! F7 x+ C8 Z5 M& x1 A1 w
30.     webSocket.onopen = function (event){
    - t& Q; u' y) h+ C$ Y% d
31.         onOpen(event);
    
32.     };
    
33. 
    
34.     //监听消息
      v1 h: s/ X1 P$ f- i, F
35.     webSocket.onmessage = function (event){
    7 B' k0 X+ U7 p  P. Q6 j8 @) m
36.         onMessage(event);
    + A; {# C9 [8 L% N- T; a6 H
37.     };
    
38. 
    . Z$ R: R! |! d( D3 o$ K$ U  V
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    $ d4 R( G! j! q/ O
43. 
    / C5 \9 T; B4 b* l5 T
44.     //关闭监听websocket
    6 r6 N' @4 [8 u/ J" `4 U; ]9 t$ y& l
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ) H4 g4 @# k% V; g) D
47.         console.log("error"+event.data);
    : J& S0 `0 ^* d3 d" B; y. b9 o% x
48.     };
    % l  m# I0 v+ |1 ]  [% Q% z, g& `
49. 
      F3 F0 o2 Z- b" n
50.     function onOpen(event){
    # F0 `* F" ^6 P" I
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    9 E( r  ~$ t( Q6 L
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    
59.     function onClose(event){
    ) u3 h# E: x. Z3 {- P) k5 ^
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ) u' l0 l# I2 f+ {
61.         console.log("close:"+sockState());
    % P  ~7 K0 ~2 Q/ o8 h# E1 u. x
62.         webSocket.close();
    * o) ^( |' X* S# L
63.     }
    
64. 
    , ]- d: @1 N* j- C
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    - \% @0 W- u" j. E" V& w
68.     }
    
69. 
    
70. 
    
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    6 F8 ?- U- {) P2 c- m
75.         document.getElementById('text').value = '';
    , E2 q* K2 J8 M1 O
76.         console.log("send:"+sockState());
    2 q3 g, i; P; Y2 Q
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    6 @) c# v+ V( F6 e* y/ S% z- a5 i1 H5 i
81. 
    
82.     function close(event){
    & y8 _4 d5 R+ Y+ h  A: A
83.         webSocket.close();
    
84.     }
    
85. </script>
    , g; Z7 f; [3 `# r5 w- Q& e
86. </body>
    
87. </html>

复制代码

& F) f* O1 C8 {) o

: S' z3 G  i& Q) t+ L