php实现websocket实时消息推送

admin

php实现websocket实时消息推送


SocketService.php

1. <?php
   # j' j- M& T( S! Z8 \
2. /**
   
3. * Created by xwx
   2 [0 I. S7 m. g& b4 K% U
4. * Date: 2017/10/18
   & K+ s% K' Z; W# W7 x, G- V, h
5. * Time: 14:33
   % e' g) z0 E5 k6 l. A- \0 e
6. */
   : t" }& \  y$ i, k" K- W
7. 
   $ v- x8 c/ }  i9 C; A4 G9 Y0 V
8. class SocketService
   ( U3 D, I: z( f, K6 ^$ H
9. {
   ) {9 m) k* u; }4 G
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    ; w/ c5 P7 P1 k* |8 _; o3 J: _
14.     {
    / g# k$ d/ {( Z
15.             if(!empty($address)){
    ! t2 O! T( v( k: V: P
16.                 $this->address = $address;
    
17.             }
    
18.             if(!empty($port)) {
    1 ?; A6 q2 |+ B4 g  M; y. v% U
19.                 $this->port = $port;
    2 r  s" b8 Y* s7 h" f
20.             }
    4 v% ^9 B3 T2 w2 d4 t" z( t
21.     }
    
22. 
    2 C  `* z8 k; y: H. u* X, R
23.     public function service(){
    
24.         //获取tcp协议号码。
    2 i" c! |, w& j3 U6 s) H
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.         {
    
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";
    6 m  n3 G6 H4 w% h3 ]4 T5 }/ Y
35.         $this->_sockets = $sock;
    
36.     }
    , d" x9 _0 _/ G
37. 
    
38.     public function run(){
    ( @1 F' O8 v% ~# h
39.         $this->service();
    8 }$ {4 c) [  J0 Y
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    . x2 k! ~3 @* A+ |6 x& c
42.             $changes = $clients;
    
43.             $write = NULL;
    
44.             $except = NULL;
      r, Q- O3 M/ i# t
45.             socket_select($changes,  $write,  $except, NULL);
    " R2 e8 |6 e: `( g* ^6 Q+ D* A
46.             foreach ($changes as $key => $_sock){
    , U1 E  M* Y% V1 y  J
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    ( K5 C  w9 y  z7 r- F* Z- |; N
48.                     if(($newClient = socket_accept($_sock))  === false){
    6 n1 T+ b) q$ K+ `( F) G# k
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    6 ~2 `9 v% y* g5 ]5 a3 C
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    4 @& S$ _4 G, L8 a: q5 D
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    
58.                 } else {
      [5 ?$ O. D- b, d) q1 l2 x. m5 ~7 P
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    : Z) g, }# L4 f2 J
63.                     fwrite(STDOUT, 'Please input a argument:');
    5 {7 B! X, r" K
64.                     $response = trim(fgets(STDIN));
    9 b( I9 T9 Y0 W* |* _4 Z
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    9 S# w6 X( O' k7 M1 L6 ^( l; H
67.                 }
    
68.             }
    7 n1 ?( V% q0 D2 [
69.         }
    0 r- W  w  b/ ?, W
70.     }
    2 h4 U4 o, W+ x, t3 @: V( c
71. 
    
72.     /**
    / D( A- A& ?5 Q4 M" |3 h
73.      * 握手处理
    * j' E" a! }2 P9 d6 w+ ]/ x8 s
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    2 t4 U6 A! s1 H. q/ {# K; p
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    0 i0 s& n! E3 o  E8 u
81.         foreach($lines as $line)
    5 ]# J0 U! `3 T0 k; H
82.         {
    8 e' ~0 ~! a' [6 ?( h
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    ; B7 o. v0 V1 S& H! a
85.             {
    " c% N6 Q4 v$ O- F3 x8 _
86.                 $headers[$matches[1]] = $matches[2];
    7 z' L$ y1 H5 Y
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" .
    ( e& a, }! s6 Z: K( c
92.             "Upgrade: websocket\r\n" .
    
93.             "Connection: Upgrade\r\n" .
    5 C5 h9 ~( c' K2 {
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    ! f0 e9 Y# \6 l' N2 {7 V
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    2 U7 Q7 i; {. |+ }1 `
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    0 \2 M. S3 G! d; B
98.     }
    
99. 
    
100.     /**
     
101.      * 解析接收数据
     ( L4 ]' l) P! Q9 C  j! F  h) x
102.      * @param $buffer
     
103.      * @return null|string
     
104.      */
     / F! Q  V0 C: k. ~
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     3 I' ^0 F, q9 y" `
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     5 V% b2 {" w" f- z# k- U* T" l
109.             $masks = substr($buffer, 4, 4);
     7 A2 K: R9 \- h( {1 i
110.             $data = substr($buffer, 8);
     - g$ m9 Z$ l) D/ A, I0 D) }
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     5 H6 e' K/ V0 A7 k, A. z! R/ l
114.         } else  {
     + ~4 l+ U7 ]1 X3 V
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
       X9 Y* `3 W; O- J, E/ h
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     ( v* X/ Q  h; u2 Y2 K. F
120.         }
     ' x9 i; b9 v: |2 x8 `3 ]( Y/ @
121.         return $decoded;
     
122.     }
     
123. 
     ' T% ^# A2 s5 }) ]8 ^
124.     /**
     / H# `8 K7 n% U1 X/ s
125.      * 发送数据
     % Q' N1 J" p& e1 H9 W9 P
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     # P9 Q$ o; X0 \  x
128.      * @return int|string
     $ @8 p: W0 l. g- ]; w$ g
129.      */
     ; Q; m/ g' U& u
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     : \: l. W7 a9 H9 R4 ~. k
133.     }
     
134. 
     # M7 V4 X- R, L0 B  _2 K  s
135.     public function frame($s) {
     $ I5 v& f7 O( [$ Y
136.         $a = str_split($s, 125);
     
137.         if (count($a) == 1) {
     & I7 O1 {) {) V2 k( c: R, G, {
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     
140.         $ns = "";
     5 }( `. T  _! p& M  M( i
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     * m8 J" _9 u1 L3 C# _
144.         return $ns;
     ; U6 K  t# [0 a. Y' U' P( q
145.     }
     
146. 
     - U. b* V% D1 W  t8 @
147.     /**
     
148.      * 关闭socket
     
149.      */
     % f# v; q% y5 H: G- M/ C( _5 l; ?" ?
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     
154. 
     / l" Z6 H& s9 l. a5 K% A% g; J2 @3 B
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   * ?, P) h* j" X' K# @9 j0 F9 x
3. <head>
   
4.   <meta charset="UTF-8">
   ' M) T9 w7 M! |; a
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   6 U9 F4 P0 X/ `, w
9. <input id="text" value="">
   
10. <input type="submit" value="send" onclick="start()">
    / z  u' p& [& F2 j* m& \4 _- U
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    & F; E4 D+ ~/ l4 i. R; c
14. /**
    
15. 0：未连接
    5 r( z/ G1 U+ t% K
16. 1：连接成功，可通讯
    1 n! G1 }* S3 |) U/ W
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    " k' n# _* h  p+ F
19. */
    
20. 
    & j9 c6 Q% z' L% W! v2 B
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    1 P( @7 \; s6 b( w0 {) W; i
23. 
    7 q9 g# q' C" _& U
24. 
    
25.     webSocket.onerror = function (event){
    / s8 Y7 e6 K8 M- |! E& r
26.         onError(event);
    
27.     };
    * o6 V. q) l; O; I3 ~
28. 
    ; O9 Z& z- @! O) f2 R. W; v
29.     // 打开websocket
      W: s& {, @# P+ _4 ?' H: L
30.     webSocket.onopen = function (event){
    % ^6 p4 ^. i: T9 c
31.         onOpen(event);
    
32.     };
    & e! k1 z5 q$ m2 j: M# i8 [
33. 
    ; a3 x) c4 f0 ?( ^
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    & x" M8 d6 i: i: H" M% O
36.         onMessage(event);
    $ B( `5 p6 w2 n6 q- b9 K
37.     };
    * p  W7 e# |/ h! u/ |
38. 
    
39. 
    
40.     webSocket.onclose = function (event){
    0 `3 k$ y' H) ^7 v* m7 n
41.         onClose(event);
      z0 o6 p/ Z% y" S2 u" t
42.     }
    
43. 
    " O2 ?/ J4 I1 T- O" W8 D; W
44.     //关闭监听websocket
    
45.     function onError(event){
    
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    ; \& r* j! \, s1 z- x
47.         console.log("error"+event.data);
    
48.     };
    . o$ H2 R0 s- S6 B
49. 
    
50.     function onOpen(event){
    ' r4 N, f( A/ Q, O: Z. S1 ^
51.         console.log("open:"+sockState());
    ' S2 M5 }! `5 O9 a4 X: T* j
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    ! n7 G3 V( S, a7 }
53.     };
    2 K' G1 o5 B" M  S  d
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    9 r6 |* t" w1 @1 d  D  h
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    / m% ?1 o! w7 W! ]3 Y; P
62.         webSocket.close();
    
63.     }
    3 o' }. R! a9 e' s- S& S" N1 T
64. 
    , Z0 A& W( D6 [2 S* ?; V
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    . x, {9 D- I: ]) ?
70. 
    $ B4 i9 \4 M' G) g
71. 
    
72. function start(event){
    4 I* B6 `- f  F! {' e
73.         console.log(webSocket);
    / C* I1 C) D5 K% G; e$ Q9 b. M
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    : \  P9 ]' s7 G# L8 M
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
      E! c6 Z( `+ @1 [$ b, ?
81. 
    6 x) N% S& Z) i, ?: i2 l
82.     function close(event){
    - s# O0 z; M; z; e8 h& D
83.         webSocket.close();
    
84.     }
    
85. </script>
    " u/ Z3 z0 O! N5 t
86. </body>
      T6 d/ G( X* Z; {) ~
87. </html>

复制代码