php实现websocket实时消息推送

admin

php实现websocket实时消息推送
4 R6 ]% E  q$ f$ ~; Q/ K( C
* j0 D- Q$ N: t& t% ^' O
; `) E4 V: t; l1 C. E& p& ~0 qSocketService.php
. c: R1 z* l0 o, D; F

1. <?php
   
2. /**
   8 k8 r) O$ W  e" H! T- U# H3 b
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   . ~4 ?! O. ~. v2 N
6. */
   
7. 
   2 k& V: K4 R1 V( i9 D; G
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    ; F4 V7 N0 G6 P. x
13.     public function __construct($address = '', $port='')
    3 o6 D6 W' `. x$ ?) ^( u
14.     {
    / M4 ]9 \" y& J$ j4 U2 _/ ~# X
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    , e3 `% R& k; l% a+ p  }" w, E
20.             }
    ! ~2 J0 \! R  c: Y1 w% v
21.     }
    1 k/ A: C! L4 z+ q
22. 
    
23.     public function service(){
    3 h2 N, M1 X& Q  A4 D( d# N
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);
    3 \6 }# n  X& H! g5 }6 z
28.         if($sock < 0)
    % z+ B1 ?' |  `5 H2 @
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    1 T1 h+ e0 H# m8 X. c7 K
31.         }
    . H* U& N# S: n3 U1 j# u
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;
    ( q' O" U* p* _! A3 r: y1 f
36.     }
    
37. 
    9 ~& k8 U" P8 p+ v; t3 _
38.     public function run(){
    / e5 l3 k& G: r1 H- A, ?* Z9 j9 \2 Z& }8 W
39.         $this->service();
    ) T) ]8 \5 {8 n7 ^; b7 p
40.         $clients[] = $this->_sockets;
    , m; H& o+ p5 o% ?. |
41.         while (true){
    " F% l8 a$ Y( N& s
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    ( ^6 e9 T; o0 c
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
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));
      t* c* q4 i5 U1 X' o
52.                     $this->handshaking($newClient, $line);
    3 W( ~8 N* Q5 ^( A
53.                     //获取client ip
    4 b8 I$ |" E% S( a1 R2 E; W2 ^
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
    1 J' u% M1 e( ?* u9 B
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    $ J9 J& D. Q0 [7 O( G6 {/ y
63.                     fwrite(STDOUT, 'Please input a argument:');
    ! A" C2 D* _# `( m- n
64.                     $response = trim(fgets(STDIN));
    1 B# r/ J/ [! U0 \9 _5 `" f
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    1 e0 X" }4 x4 ~! P7 C
67.                 }
    6 J3 W/ {5 o- p/ N: M. T9 q* C
68.             }
    & ^7 g- ^& e" f; c* C2 B1 o9 f
69.         }
    9 g! Q! ]+ h- S& M0 y
70.     }
      b: p  ~+ X  W2 p4 j, |- Z
71. 
    $ C0 R4 T- o, v. G' n& B0 N
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    7 F; w# e6 X, Q* D
77.     public function handshaking($newClient, $line){
    6 S* z& @( B6 j0 _2 y1 c
78. 
    % w' C/ W9 h- V; Q( i
79.         $headers = array();
    ' v: E8 }: N) ]
80.         $lines = preg_split("/\r\n/", $line);
    * l) W2 q2 k- {2 J0 x( M
81.         foreach($lines as $line)
    , D: F+ F1 u  Y' |
82.         {
    0 C# W7 S( ?3 F, A+ o
83.             $line = chop($line);
    ! m# @6 H+ T7 W- p
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    / |/ S- I0 [! r- k3 [: z
87.             }
    
88.         }
    
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" .
    0 u% g- L4 z" h
92.             "Upgrade: websocket\r\n" .
    ' B% v3 t2 ]  K( h
93.             "Connection: Upgrade\r\n" .
    6 h& m, u/ L$ Z# u" |! _! C
94.             "WebSocket-Origin: $this->address\r\n" .
    5 A( W7 G6 ?6 i: X
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    ' \0 g& ^( H& y
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    : I& V8 m1 X- i1 r* }
98.     }
    1 |& }9 |9 R. P
99. 
    6 F# S+ b. w+ |8 H( f# k, }. x
100.     /**
     
101.      * 解析接收数据
     # L/ l+ G0 ~( A
102.      * @param $buffer
     7 d6 }* m3 q+ {2 v6 Z4 V
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     - S9 m# _9 {8 `5 ~
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     " ~9 l9 F& G" o7 A1 \2 j& n; z
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     " q7 O" T6 u$ S) q
112.             $masks = substr($buffer, 10, 4);
     9 A% t! {  y1 J9 l; V
113.             $data = substr($buffer, 14);
     8 D" \" h5 l* @" q7 ~9 c* h" T
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     " p9 P( d( h8 o& \" M  B: J
118.         for ($index = 0; $index < strlen($data); $index++) {
     : J! F2 ^6 N: p0 B! |: G
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     - n: l9 j1 A: r3 a; A8 j
120.         }
     
121.         return $decoded;
     " a! U7 n) _5 T3 R5 B, [
122.     }
     
123. 
     * Q9 U. K: I$ m6 X1 F
124.     /**
       H, b* y: ^  w- h+ f# {  F. I
125.      * 发送数据
     6 j6 h6 f7 j% {
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     & m& L  E  D$ X4 B4 N+ f& h0 {1 {4 I
128.      * @return int|string
     5 w7 @2 }. {, A
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     - j* [( ^3 Y/ J7 i* g
134. 
     / ~' \! }4 m* V0 ~6 T* p0 b- K
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     4 [6 i" \- T' h7 b- ^" G; }
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     6 c# G+ C6 |- n& W$ f0 j3 ?4 w
140.         $ns = "";
     ! U; Y( a+ H4 h" P. K* z/ n$ S/ K
141.         foreach ($a as $o) {
     2 f5 r7 D7 `5 z& G6 c8 ]! A, C
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     4 Z* ^+ A$ h/ n; I4 p- ~
145.     }
     
146. 
     
147.     /**
     ( j, A+ O0 S; G7 ~
148.      * 关闭socket
     
149.      */
     5 [0 _! \6 t' j, q! _
150.     public function close(){
     % e7 e$ X' N8 h# a* s
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     1 H0 M" [! D. f  V6 Q% |  [" D
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     , t' \/ k1 I$ h  O* Z

复制代码

web.html

1. <!doctype html>
   / ~1 s$ R. j! z, Y+ P. r: P# l* |
2. <html lang="en">
   ! ~* r! q4 {& X" ?
3. <head>
   
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   - d) F  e, l8 E0 n) e. A6 I
6.   <title>websocket</title>
   
7. </head>
   7 Q- q, u, ?8 b- ^$ f( }9 Z
8. <body>
   , V& o1 U' ]+ y, _7 |
9. <input id="text" value="">
   $ Z0 U! z' G3 f7 w) I
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    + D7 _# `9 H  [
12. <div id="msg"></div>
    
13. <script>
    4 g+ |2 M: ?" W. k% A* L
14. /**
    
15. 0：未连接
    
16. 1：连接成功，可通讯
    & }6 g% p" G, L1 J
17. 2：正在关闭
    6 _5 w* z5 U1 ^- ^3 g+ R
18. 3：连接已关闭或无法打开
    9 I4 D5 y# z6 B1 x
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    " i; s- y$ E, C
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    ; e+ H( M2 z( g+ l
23. 
    2 s* |7 @! z0 ]& \
24. 
    
25.     webSocket.onerror = function (event){
    # K0 F7 O/ I5 `5 }; b
26.         onError(event);
    
27.     };
    
28. 
    ! C  I& L& M  p
29.     // 打开websocket
    ( t7 ~0 n, U: l8 ^( z) Z7 \
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    
32.     };
    7 |* ~! {$ H& C3 n1 D+ g
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    + K9 G( p+ ]& c9 P0 `8 O% F9 Z, @
37.     };
    $ x1 }! ~) N3 h& b0 p
38. 
    7 ^; g- N: r" X  ^7 E% U
39. 
    ; }( k9 ]/ ^3 P, y) C: C
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    
42.     }
    
43. 
    * N9 a2 ~' Z% O
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    - B8 G) z; u8 i6 L
47.         console.log("error"+event.data);
    
48.     };
    % J5 x% N& H/ \, `
49. 
    $ _! P) ^6 G% K5 s7 f6 P5 t7 l
50.     function onOpen(event){
    7 B7 H0 ^! r- ^- C& v, S
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    5 a/ B- q% ^2 w' P( }0 z$ c3 i
53.     };
    , X. r1 c( n# p. X- W2 k# V/ M
54.     function onMessage(event){
    + M3 v3 c" ~& _/ e4 F, T# Y
55.         console.log("onMessage");
    , q; _! o/ F% Q5 l4 Z' v1 h
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    ! r' c& E# @4 J. s3 e$ C' @/ A
58. 
    
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ' \9 |4 G& h* ~
61.         console.log("close:"+sockState());
    4 Z4 X! x1 T/ U! T
62.         webSocket.close();
    
63.     }
      k. A3 c+ m' v4 L) S
64. 
    ( _& b6 X% ]; c; L% p  ?& V6 W
65.     function sockState(){
    2 O9 j4 o2 Y& A0 J5 `
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    ( C' T& g( C1 z1 F$ V* b
70. 
    
71. 
    5 ]% I2 P1 E3 {. Z6 d. M8 x6 C
72. function start(event){
    * Y2 u* l& j' ~) Y1 |  X
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
      D* M* c2 T" Y
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    1 F6 P1 A3 _- I* ~, m- S) d
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    4 I; Y" E: C; o$ q# Z
82.     function close(event){
    $ B1 E# B0 U+ A* g5 l8 E$ {( y# W
83.         webSocket.close();
    
84.     }
    
85. </script>
    # R5 ~, J2 |3 q4 F
86. </body>
    
87. </html>

复制代码

$ ^4 ]% {$ b4 i% Q+ h8 Z- D. \