php实现websocket实时消息推送

admin

php实现websocket实时消息推送

2 K9 P2 k+ ^0 k" c
- y/ c3 s. k# rSocketService.php

1. <?php
   / I" X. B, H5 I/ A( E
2. /**
   4 P" E1 p1 u8 U+ E5 h4 [3 v
3. * Created by xwx
   
4. * Date: 2017/10/18
   7 g) _# |3 e  Z5 {2 r
5. * Time: 14:33
     @+ r4 I, i0 I7 y! |% s
6. */
   * \# p& b" K! L+ I, q: y; `3 a! p
7. 
   5 j5 E7 F  }' S* Z+ K- d6 d7 n
8. class SocketService
   4 h7 f  I  B: O/ x6 M3 X- N0 q- _1 c2 L
9. {
   
10.     private $address  = '0.0.0.0';
    7 g# _8 Z4 k; V( m8 @
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
      {7 |( k9 y; i0 E3 t# {. |, u
14.     {
    4 U' B& e9 L* x) ^: v2 L( j
15.             if(!empty($address)){
    * A3 y, o" s5 c3 ~' j* V$ V. u& \
16.                 $this->address = $address;
    
17.             }
    5 e6 Z+ C# X3 f+ I2 y  }
18.             if(!empty($port)) {
    , O6 x' R, x; \: {; g7 c. s, k
19.                 $this->port = $port;
    
20.             }
    
21.     }
    
22. 
    
23.     public function service(){
    0 e$ l6 D4 t( m( m
24.         //获取tcp协议号码。
    & |7 N; H4 g" c) B+ f
25.         $tcp = getprotobyname("tcp");
    7 u' Z( g# ?& c0 Y% H. ?/ a
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    3 J1 Q: r4 k8 R" I& H7 E% o
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    6 p7 w$ R8 l# T% f
28.         if($sock < 0)
    
29.         {
    6 K  O; |8 V3 L- 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";
    
35.         $this->_sockets = $sock;
    
36.     }
    % U; g# v2 |7 C* Y
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    ! D) L4 G6 Y$ y1 J9 |0 K1 T
41.         while (true){
    9 \5 S  i: F6 w- _9 O4 a
42.             $changes = $clients;
    2 P7 U* b1 P+ d
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    ' f6 _7 |6 s& d/ f
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    ) ?! U& I6 w' ~/ J
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    4 c! J1 x+ P: k' s, V, j0 N: E
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    + \( a$ M* |6 ^: h  N
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    0 H0 V- U% k" G6 \# F6 b0 R
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    6 w5 u( l* s; K( L4 B2 u
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    0 F6 ~8 q# m, n" i# z* V8 w7 Z8 N
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    
68.             }
    1 {! I4 H2 P6 n& t+ v
69.         }
    & Q8 A# [9 H/ f5 f8 ]+ M
70.     }
    
71. 
    ( s1 ~) O" x. \8 @# ]
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    / l4 c. I9 M9 V1 b; t
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    * D+ g# y2 o; h1 H
78. 
      R: }+ E8 Y/ J
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    * I1 F; {& z  @& X, c/ l
82.         {
    
83.             $line = chop($line);
    ' ^  R+ b" K* C7 I3 V2 y
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
      c  j1 e3 M& F
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    " R& s$ C! C. a8 B* ]
87.             }
    7 K8 }* u" e4 ]* K& V
88.         }
    2 ]4 ?9 _# {+ ~5 B7 S2 c; b8 @
89.         $secKey = $headers['Sec-WebSocket-Key'];
    ! E, O$ }/ O8 t2 b: d2 l/ \# M
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" .
    
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.     }
    / r. B- C$ V+ ]/ r: a2 B+ D) N! {
99. 
    
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     . F; e& l0 b6 a. X; t: K& v
103.      * @return null|string
     
104.      */
     * h  Y3 G/ [& H3 B2 ^
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     ! x5 T; L: t8 ]- o
108.         if ($len === 126)  {
     8 p* o, }+ j% E1 H: A7 q* E3 I/ Q
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     ( A% K" [4 O0 K+ g
111.         } else if ($len === 127)  {
     $ y8 l2 K  S/ x6 V9 l1 Y  ?
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
     ( _4 X/ @& J' s0 S% N6 q" N
115.             $masks = substr($buffer, 2, 4);
     4 u4 ^6 w+ R1 x) o# Q0 ?
116.             $data = substr($buffer, 6);
     9 D$ d: d/ m) O! K
117.         }
     : n- o$ p3 d1 r7 d6 {( E7 N0 N; \3 y
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     6 _; ^- Q. p) I# E
120.         }
     
121.         return $decoded;
     
122.     }
     7 h# P/ b: v5 R6 V' P' u) m. Q
123. 
     4 X! i0 N& g7 F5 {$ l8 Z
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     * N$ U# X& Q/ K3 [, x
127.      * @param $msg   要发送的数据
     9 G1 x* x6 g% |
128.      * @return int|string
     
129.      */
     ; }; U. c2 \3 M* p7 b5 ?0 @  x
130.     public function send($newClinet, $msg){
     ' {( M- c) ?8 e$ J4 [5 B
131.         $msg = $this->frame($msg);
     " N& @0 P& O) I  T2 v- D
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     
134. 
     
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     ; c9 o; l: @; W
137.         if (count($a) == 1) {
     % l; O' b9 J3 j
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     5 Z; X9 w0 u/ B3 V: A
139.         }
     8 v+ [9 E% ?- W/ Q
140.         $ns = "";
     0 p6 u1 H0 T! _$ y, T& |" D
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     / Q& V9 y; q: j3 G7 E  g: \/ r; w
143.         }
     
144.         return $ns;
     " h: C: B% h( U& D1 p$ y
145.     }
     
146. 
     ! W) m5 P# k0 C5 c2 Q3 o. |/ c
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     2 t6 _. V- Y3 ]$ Q' Y) k5 ~* B" V
151.         return socket_close($this->_sockets);
     4 R* j, h' z4 z- g& j9 {3 ^- q: S
152.     }
     % Q8 f4 U4 ]  h6 v, g* T
153. }
     
154. 
     6 ^+ i- y3 A* {$ G( m
155. $sock = new SocketService();
     * ?4 \# G0 c6 z6 l; \
156. $sock->run();
     $ G" Z: R1 A" p* A7 w9 T9 Z0 G
157. 
     * Y* K0 k7 u; z/ u' X, N; `

复制代码

web.html
* ^% U5 K  O( [$ ~& R, B& h" Q

1. <!doctype html>
   $ e6 j- i% E4 P3 q# s+ Y/ X4 r1 Q
2. <html lang="en">
   
3. <head>
   
4.   <meta charset="UTF-8">
   4 L5 I; h# g; |6 a6 D
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   8 a0 r4 p: }! E& |' s' E
7. </head>
   
8. <body>
   
9. <input id="text" value="">
   4 K* s9 X6 _4 A) m
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    & H8 k: s0 |$ x. ?& o3 _
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    8 {: h( s9 f6 g4 v! f$ v5 Z: h
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    8 M5 v% d3 [6 t0 J: D
24. 
    8 P& e7 t% Q5 N
25.     webSocket.onerror = function (event){
    ) ?" C! {* o/ g7 B
26.         onError(event);
    
27.     };
    
28. 
    4 E: A$ s- D5 Z% [# U
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    7 N0 t, u! q! n" q) I9 Z+ s" E* k
33. 
    9 ]0 |: \4 g0 h5 J  S
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    ; {: D8 A. S* t
36.         onMessage(event);
    : o* \; X4 H; x3 ^) G
37.     };
    
38. 
    ' ^& K( }' u1 I: C" w, X$ M1 {
39. 
    
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    ) K- ], ^3 d( x5 [2 q2 ]
43. 
    
44.     //关闭监听websocket
    : k% q1 i( |, i3 ~: w
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    
49. 
    
50.     function onOpen(event){
    ( P* p7 x! X( l8 }. g( b$ C' b
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    7 j, t$ T) a' J/ u) X) |
53.     };
    . O0 h* k5 A7 [8 p
54.     function onMessage(event){
    9 y& ~+ E4 _( K- g
55.         console.log("onMessage");
    : ?/ m$ J9 r- U) r- \( N# r
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    : J" y2 |  t; ?- |/ x
57.     };
    
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    & D- H: p7 L+ a- j
61.         console.log("close:"+sockState());
    % c4 n. Z; E6 k" ~! e+ b
62.         webSocket.close();
    
63.     }
    
64. 
    ! Q$ F3 Z  K$ \; _  G( a
65.     function sockState(){
    * A  P: `( t1 ]' |( v+ O9 R
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
      `- }4 {) a* Q; ]$ I
67.             return status[webSocket.readyState];
      ?3 J1 ?: ?+ b' ?8 t% R
68.     }
    
69. 
    ( k9 F* p, n* t$ n& n4 i( ~8 q
70. 
    ( o# b* [: C$ \" d# J$ h
71. 
    
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    % d/ W- A$ F0 h0 w1 F" v% y7 g1 a
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    $ B; \& i+ P4 R# R! d9 M
80.     };
    
81. 
    
82.     function close(event){
    6 P) Z6 B  D( z4 `$ B2 Z% |
83.         webSocket.close();
    " |7 I5 v/ w4 E# L7 k, D
84.     }
    ! D) f) V2 N5 ?9 P
85. </script>
    ) h2 g/ y: ~& U6 x
86. </body>
      F4 t' O3 X, C
87. </html>

复制代码

: e& P! y7 ]+ h) ~+ t& X
7 q% ~/ |3 I  j# Z
0 D  ]1 @% Y: G! i$ b( E, F- u