php实现websocket实时消息推送

admin

php实现websocket实时消息推送


$ r; s# W/ X# s% u. w- S4 d% |; |SocketService.php

1. <?php
   
2. /**
   
3. * Created by xwx
   & S# Q  D. v  G
4. * Date: 2017/10/18
   + r, Q/ L, R4 C) }* F# M
5. * Time: 14:33
   
6. */
   4 U) t5 E7 }- T% K8 [6 @# U  i' Q
7. 
   " O9 \9 I9 @& \+ b
8. class SocketService
   & J' T3 U4 Z9 d: Z/ h, j* o4 R2 k0 r
9. {
   
10.     private $address  = '0.0.0.0';
    & [2 z! O! n! O$ \8 v/ d# V9 d
11.     private $port = 8083;
    3 j+ ~0 E' O1 A
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    5 Z. T+ r( q# M4 Z: N
14.     {
    1 g  L6 A% g# y/ z  p
15.             if(!empty($address)){
    : p5 W8 j* |. [* [+ _
16.                 $this->address = $address;
    . G6 F/ z- F" I& ?  L$ ]; G
17.             }
    
18.             if(!empty($port)) {
    & Z2 E' h: c5 K- K9 a, j6 L
19.                 $this->port = $port;
    2 H! K$ m4 y# n7 a# s; H
20.             }
    
21.     }
    
22. 
    ; P4 k' s5 P7 D* o7 ]) R
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    8 g6 X% {  c4 w. ?" f& W. C$ {
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    * T* m7 c! x& F! E  |! O# S+ P
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    0 x% y1 ?8 z3 a  a: d
28.         if($sock < 0)
    
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    ' e) L+ }/ s5 z" E, m
31.         }
    
32.         socket_bind($sock, $this->address, $this->port);
    
33.         socket_listen($sock, $this->port);
    " d  D* B* U/ z* w0 Q# n
34.         echo "listen on $this->address $this->port ... \n";
    # m& J' I6 x. \4 N, ^1 r: o9 Y
35.         $this->_sockets = $sock;
    
36.     }
    + N8 p# v+ d0 z3 D/ @4 g' t
37. 
    
38.     public function run(){
    $ ~8 P! j5 x/ h% ?- V
39.         $this->service();
    0 K6 D5 d. l& w
40.         $clients[] = $this->_sockets;
    . p8 d; [' s0 E: s5 e7 A
41.         while (true){
    + e+ d3 V. ^$ x" q$ K  K
42.             $changes = $clients;
    3 h1 z9 j3 |! K8 ?% S( U" L
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
    6 k. Q4 z5 o) v0 V3 p! @0 E5 p0 O6 i4 d
48.                     if(($newClient = socket_accept($_sock))  === false){
    
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    4 X/ N$ F- n5 K6 a4 q
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    ' a# m' C3 u) h0 T& E/ u
52.                     $this->handshaking($newClient, $line);
    4 `' A9 L$ j2 @# c4 h( x
53.                     //获取client ip
    8 W8 ?& ^* L5 ?  e1 X0 N& V
54.                     socket_getpeername ($newClient, $ip);
    
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    5 e, z( p2 F* M' `# H0 \
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    . M: u0 z% n! `8 R% [
63.                     fwrite(STDOUT, 'Please input a argument:');
    + K- }2 l: Z  R3 Y
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    ; H) O: J# n9 L6 a% T( P! q$ M6 d
67.                 }
    6 ^0 k6 b" c# `; Y) n! A: u
68.             }
    6 v9 {6 U. p  R2 X$ q5 R
69.         }
    * s% C& k) ^6 H3 X
70.     }
    
71. 
    
72.     /**
    
73.      * 握手处理
    5 K7 D- m$ w) ]3 j2 C
74.      * @param $newClient socket
    : s+ p, C+ s( h/ V4 L
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    * v+ W; A3 b# B$ N
78. 
    
79.         $headers = array();
    
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
      C/ o  G3 k$ v8 h& _
82.         {
    
83.             $line = chop($line);
    ' Z' w, [7 Y7 s3 j& B2 A' N
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    ) D# C' _2 x( W  Z& R7 Y' F' L' {) J* `
86.                 $headers[$matches[1]] = $matches[2];
    + l2 Y- l0 B* s
87.             }
    
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    , v: B- j( ~  d0 j# ]+ M
90.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    ( k; b  k3 P7 V& m" `7 [+ x
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".
    $ [! ^) |. t9 S; w3 e
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    1 u' a  Y. ~0 d! i3 N8 [* b) N: f5 ]
98.     }
    - T! ~3 w0 f! g* Z
99. 
    % |* N2 W5 d. }2 R
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     0 f* B& A. _% e+ u$ |# g5 K
103.      * @return null|string
     * X1 e4 S5 V" l- A  J, u( p
104.      */
     
105.     public function message($buffer){
     : F( v* {8 t2 G6 Q- P
106.         $len = $masks = $data = $decoded = null;
     4 X* ]% y4 s) X, b/ F" Y  Q
107.         $len = ord($buffer[1]) & 127;
     # X: Z9 x! c5 w, m+ }' R; l
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     ; o. o" q  U8 A& p  c% W' m
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     6 G$ ?$ i* ^) [! a0 j2 }& u1 n4 b0 S
112.             $masks = substr($buffer, 10, 4);
     8 n( _& T7 T, k
113.             $data = substr($buffer, 14);
     
114.         } else  {
     7 C" ~  ~( C+ N+ \+ _2 f+ _
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     1 L9 t( W* F" W6 a
118.         for ($index = 0; $index < strlen($data); $index++) {
     
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     8 C, `' H$ E" P9 M3 `1 o4 f+ h  V
120.         }
     & `( Y3 }/ O4 x8 a& Q7 q* q
121.         return $decoded;
     
122.     }
     % l) `3 A+ a( o8 U2 i/ Q
123. 
     : f0 i, X6 k0 f# Z
124.     /**
     * l2 P0 e# B/ N6 ?# h& X( s: p
125.      * 发送数据
     $ ^# f: Z( M0 Y  k
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     & d6 ]; z- T3 F$ q6 X
128.      * @return int|string
     # y5 }6 C. [9 z& I# w/ ^
129.      */
     
130.     public function send($newClinet, $msg){
     ! I& ^5 S9 D, ?' b5 k7 |
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     9 i+ M/ r2 U* g0 z3 b: Z
133.     }
     
134. 
     
135.     public function frame($s) {
     2 t; ~2 m, C" P; c5 m4 }
136.         $a = str_split($s, 125);
       `5 `2 S" ]! w9 p
137.         if (count($a) == 1) {
       S9 ~% l. Y2 ~# T9 u( N
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     ; R, ]) I2 v( e/ Y' ~3 ?, r9 q
139.         }
     
140.         $ns = "";
     4 q7 ^; S% V; c
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     : E$ Z- U1 I3 v* M* E
143.         }
     - K( E) }2 @1 Y# Q# a* p
144.         return $ns;
     & ~2 t* `2 ~# j; L2 I/ v' O" I2 B
145.     }
     " s, V* @) M' S
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   / D# n% X. K! @) }
3. <head>
   
4.   <meta charset="UTF-8">
   ' ]% ?! A. d* L6 R7 Y4 T
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   ' `. v8 s8 i- u
6.   <title>websocket</title>
   0 A# z0 H8 V/ C
7. </head>
   : T: X0 N6 i7 J2 T( N
8. <body>
   
9. <input id="text" value="">
   ' l# k* q% a1 u! B- z# M( {( N
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    7 T8 s4 s2 l7 [' G
13. <script>
    $ C' P+ i9 N, P; X% G6 l
14. /**
    $ U" y. \& Q. ]: m  W
15. 0：未连接
    ! e! m8 P: i: ?; F; d. g
16. 1：连接成功，可通讯
    
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    + v  J8 c# N/ o( g+ u: F- X7 Z
19. */
    % F: g! w9 m4 A% d
20. 
    
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    % o* P7 u( n9 C# {+ A6 [( @+ @
23. 
    / w7 j% K8 w1 B0 t' r  g' F; O
24. 
    
25.     webSocket.onerror = function (event){
    * o% q' T( C  [9 v3 H7 ?
26.         onError(event);
    : b8 ~0 w1 r* f7 O
27.     };
    
28. 
    
29.     // 打开websocket
    - |& v. B6 j/ h
30.     webSocket.onopen = function (event){
    
31.         onOpen(event);
    ( u/ p2 n& p; {# F# H: O
32.     };
    * X  {4 M( W9 G7 P
33. 
    1 G: x; h& q) V/ @$ b; V  |7 d
34.     //监听消息
    , k" e* k* n! i
35.     webSocket.onmessage = function (event){
    ; Z+ ^6 W) K$ C& c$ K- k; f3 u! `( S
36.         onMessage(event);
    
37.     };
    5 q# w2 x- v$ e( q7 x  L0 x
38. 
    # S* Y0 J, X& X0 f" F1 ^5 v
39. 
    
40.     webSocket.onclose = function (event){
    9 ?1 V5 k- M$ n. e9 e4 t
41.         onClose(event);
    
42.     }
    # u( p7 k7 g2 E( S, I
43. 
    3 |, s+ U' a- n* k
44.     //关闭监听websocket
    / N5 _/ [# L0 \# e, X
45.     function onError(event){
    " z0 e" F0 J7 i6 [8 r/ m: r
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    ) V; j# [6 W) Y/ F. O: F; }  K8 M
48.     };
    8 J6 G  t+ ^1 B1 i1 Q6 k
49. 
    
50.     function onOpen(event){
    
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    1 G; }6 J, y( X0 _' }' u
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    4 s6 k4 K! w9 X5 O2 h5 ?
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    + e* p' g9 E( S6 C
61.         console.log("close:"+sockState());
    
62.         webSocket.close();
    
63.     }
    
64. 
    ' x! K; l$ w$ _' V! w
65.     function sockState(){
    1 V" z9 c: v8 S- I/ _: c. I
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    4 l- V5 Y8 }. T
68.     }
    
69. 
    
70. 
    
71. 
    % q( I7 I5 o8 v: q
72. function start(event){
    
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    - e5 _7 X3 _; G" n
78.         webSocket.send("msg="+msg);
    . p2 s& C+ K! J$ O
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    . W& ^% l* [( ?5 X# A
80.     };
    ) ~8 M7 z* t0 y! @* a
81. 
    9 G2 L* r6 {' L- w4 g6 t
82.     function close(event){
      b, I8 `4 y% }8 {1 J
83.         webSocket.close();
    
84.     }
    
85. </script>
    
86. </body>
    1 w) b2 t8 O) ?8 w! ^9 n
87. </html>

复制代码

2 K  L1 \2 i4 D6 q* `9 _
+ y4 f5 q1 @. R( X# y6 B, o