php实现websocket实时消息推送

admin

php实现websocket实时消息推送
8 \- Z6 a* F9 m' \

7 ^/ }: ?* |' U  fSocketService.php

1. <?php
   6 K/ }5 W* M$ M' o) j$ f
2. /**
   
3. * Created by xwx
   
4. * Date: 2017/10/18
   * U/ y7 D$ V- f9 w+ v2 A
5. * Time: 14:33
   $ k, `5 W2 b" s" B0 ~; G+ y
6. */
   % }) y8 B4 y* T- B; O7 L+ u! r
7. 
   ' u/ B# {, G' Y7 L, ?$ y5 c5 I/ L4 m
8. class SocketService
   
9. {
   " C2 ?3 y0 [! E) X' o
10.     private $address  = '0.0.0.0';
    
11.     private $port = 8083;
    
12.     private $_sockets;
    ( r2 h& c9 e* P" v9 }
13.     public function __construct($address = '', $port='')
    3 i; b8 J. }4 W. v0 d& ]$ A0 v
14.     {
    
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    / \: f3 p. p5 x
17.             }
    
18.             if(!empty($port)) {
    " d( q' }! z& M
19.                 $this->port = $port;
    
20.             }
    ; N6 @( R* y( V- a$ w
21.     }
    - R; e" s- H7 c' v
22. 
    % J. c6 ~/ ], z# g1 o' Z
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    0 F" x6 f* s6 v* ]3 v
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    ' n+ v& k' X; c. S3 y7 w' H3 l
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    
28.         if($sock < 0)
    3 Y# Y, o+ W! M; n
29.         {
    % j: ?) ?, J8 F5 y8 H. S( u
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    7 V2 E4 y. b2 j5 X( z/ V' D$ o
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.     }
    5 u6 g5 M7 P7 u# u# m. b
37. 
    # \* Q7 L1 w# G' }) J! ]# S) e
38.     public function run(){
    / Z: N. \; u5 o/ k$ z' o8 ]3 U
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    3 f2 u# ^! d, K1 @5 b  n
41.         while (true){
    2 J: q% ~3 V( D9 f' B
42.             $changes = $clients;
    1 R5 S, r9 D1 _! H8 y7 F- E& L* D
43.             $write = NULL;
    
44.             $except = NULL;
    9 l: d) h& T6 g' p: P7 d- ~
45.             socket_select($changes,  $write,  $except, NULL);
    7 B! p9 Y" L* z& X3 r
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    . V9 `* ~8 S' f; b
48.                     if(($newClient = socket_accept($_sock))  === false){
    ! T' C: \: Q* c3 I% Q
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    * [& Q' G. q* |& z- c8 @( n
53.                     //获取client ip
    + |# B) T) Y8 e, W) a2 ~/ L
54.                     socket_getpeername ($newClient, $ip);
    " j( i# D7 q# ~
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    * D6 x3 Z& d, {( Y9 L0 @
58.                 } else {
    ( c# I( @. F4 Z. i
59.                     socket_recv($_sock, $buffer,  2048, 0);
    
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    
62.                     echo "{$key} clinet msg:",$msg,"\n";
    
63.                     fwrite(STDOUT, 'Please input a argument:');
    ' H* l) g; k  r5 u& r. q. G- ~" {
64.                     $response = trim(fgets(STDIN));
    # i+ O; ^- |! y) B; O
65.                     $this->send($_sock, $response);
    # B% J9 U. N$ {/ l* M# ?
66.                     echo "{$key} response to Client:".$response,"\n";
    
67.                 }
    4 @; N' i. T! U( W* g0 _
68.             }
    
69.         }
    . s9 E5 Z) Q$ l3 l( E1 L  t. W
70.     }
    % u- w1 m' e7 W
71. 
    
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    " V( n; o- w0 Z2 I
76.      */
    ( e4 x0 A9 H% I  |6 N( C  N
77.     public function handshaking($newClient, $line){
    7 i. ]$ E1 n* M! O: R7 F/ f2 i& U, u
78. 
    7 O, F3 [' n- P& g" V3 q* b3 p
79.         $headers = array();
    $ O# i; ]" Z# m6 l! B; x" T+ v: B
80.         $lines = preg_split("/\r\n/", $line);
    
81.         foreach($lines as $line)
    ; W0 ~, Y. S: I5 z: K
82.         {
    / B9 n3 v& q% c9 P# `; X, A6 `% n
83.             $line = chop($line);
    ( b1 G- f" \3 k, |2 L
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    7 Q3 b, w; C+ Y' {- d# g5 H9 z
85.             {
    1 {3 T% F% L# V, b6 p; B
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    
88.         }
    ; p& d: r3 c) O
89.         $secKey = $headers['Sec-WebSocket-Key'];
    ; _+ U* `, N5 [  E5 B5 I0 c. s' h
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" .
    % c# ?* [+ k/ m2 K! n6 k" E: x
92.             "Upgrade: websocket\r\n" .
    / c' K  ]: M: _- r9 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));
    / ^0 f0 ?2 s1 M/ ]8 o( w4 ?
98.     }
    
99. 
    & b* L) i3 o* E1 F+ ?/ Q# _
100.     /**
     
101.      * 解析接收数据
     1 o9 w/ G) U' _
102.      * @param $buffer
     : s. C* g4 f2 {. v# m/ L( X
103.      * @return null|string
     $ h; Z: F. Q, A: p2 \( n" y" C
104.      */
     / a0 R' p# X3 i! p
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     . g* v( _. q4 v+ R+ z! Y4 e: I
107.         $len = ord($buffer[1]) & 127;
     9 G' Q6 O) x; p
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     & f2 Q8 y! G- D
111.         } else if ($len === 127)  {
     
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     
114.         } else  {
       L+ E: W# @. Z( \" @6 I
115.             $masks = substr($buffer, 2, 4);
     3 h- f, \' i: c0 S" K
116.             $data = substr($buffer, 6);
     
117.         }
     7 ?% N% {$ u( S5 e/ x& ~
118.         for ($index = 0; $index < strlen($data); $index++) {
     2 @- l  {, D+ F- v4 {" L; h
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
       _2 @% p! n, w6 K6 {9 Z
121.         return $decoded;
     : o( J# k8 K8 O( s! [( u0 M8 y$ @
122.     }
     
123. 
     
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     ( ~8 [1 b: |$ u9 L* ]
127.      * @param $msg   要发送的数据
     2 }8 P% J0 r. U+ W% l) K8 R
128.      * @return int|string
     ; {2 \) V$ {" C9 T5 o  L2 m
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     
132.         socket_write($newClinet, $msg, strlen($msg));
     ( C/ b4 o" J1 M
133.     }
     - {( j: n$ x8 f0 V
134. 
     / v4 f( p! c( P3 p
135.     public function frame($s) {
     
136.         $a = str_split($s, 125);
     3 x. e, ]0 `3 T4 p2 j% ?
137.         if (count($a) == 1) {
     3 |7 i* u. _& q& t1 a) R( ~
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     ; x( ]5 E6 ]3 w  W( n/ \+ @
139.         }
     
140.         $ns = "";
     7 O; L& [  R# ]9 w& B
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     
143.         }
     
144.         return $ns;
     
145.     }
     
146. 
     
147.     /**
     0 [( N; u6 g! R8 }
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     
151.         return socket_close($this->_sockets);
     0 M* k" ]' x  s$ d3 A
152.     }
     ! N6 `( i3 h' ?/ ~' Q( C
153. }
     5 g9 c/ A, @& \- l# W, ]+ t
154. 
     
155. $sock = new SocketService();
     
156. $sock->run();
     0 g4 M5 m2 L. T+ ?/ N
157. 
     

复制代码

web.html

1. <!doctype html>
   - l1 N* `9 M( E/ _$ d* _8 ~* A
2. <html lang="en">
   8 W5 u' B9 e7 z4 d4 V7 @0 ]3 u
3. <head>
   ; o) d. Q3 w5 D& Q2 n
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   ) p# A" h* V8 k5 [; J3 n
6.   <title>websocket</title>
   
7. </head>
   1 @4 X$ T( b/ y0 S8 w5 Q) k  |
8. <body>
   
9. <input id="text" value="">
   8 m+ ^1 F) Z8 f' B# {
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    6 p; K- c  V5 o; S
12. <div id="msg"></div>
    1 C5 c; q# o% Q. n1 I; D
13. <script>
    
14. /**
    
15. 0：未连接
    8 R$ T$ q6 }; F7 C6 \
16. 1：连接成功，可通讯
    + L2 L4 H8 ~) w# @1 m- U0 M
17. 2：正在关闭
    " K# a0 Z: M( m; X* v5 u( \# Y2 O
18. 3：连接已关闭或无法打开
    
19. */
    
20. 
    : p. C* M( K7 |
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    6 N6 s6 A& a: u: k
26.         onError(event);
    ; C  k4 m) U" P+ |+ G8 q; F
27.     };
    
28. 
    
29.     // 打开websocket
    
30.     webSocket.onopen = function (event){
    " g5 c/ q0 P1 ], l$ X  |
31.         onOpen(event);
    
32.     };
    3 P, h4 W4 t' H5 @% j
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    8 ?6 Y2 X/ |9 e% ^" |
38. 
    3 e* k/ z9 ^, }0 F; V
39. 
    7 |$ [+ C" U% m, J7 z! {
40.     webSocket.onclose = function (event){
    ; V: q5 U3 S( a9 ^
41.         onClose(event);
    . E, u, r6 ~9 B: @4 G( M8 @
42.     }
    1 C4 ]: C7 A8 J* E" Z
43. 
    $ a5 ^, l$ U# J( P3 Q' m! t
44.     //关闭监听websocket
    
45.     function onError(event){
    4 h( I4 W3 X4 R' M
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    , D: @" }' x  c/ C" N  y' C
47.         console.log("error"+event.data);
    
48.     };
    ' }6 i+ W; I# f& r0 k/ w, U$ ?
49. 
    & f, X, g) [9 I/ f- g$ f& _
50.     function onOpen(event){
    4 _  }! b6 J1 B7 b
51.         console.log("open:"+sockState());
    & g0 F' n5 `$ L5 ?# P8 ?& P7 `$ T
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    4 t5 d+ {. h/ g( i
53.     };
    0 J& F+ O+ O4 X5 Q
54.     function onMessage(event){
    
55.         console.log("onMessage");
    
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    ! H/ w2 K% l" h+ c
58. 
      X# [8 O& W5 t# B' |7 c) u
59.     function onClose(event){
    
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    7 h' r+ C) O! i! F  w' f
61.         console.log("close:"+sockState());
    # x& S+ ^1 d) p9 y4 M. J( \
62.         webSocket.close();
    # A2 i7 t7 j. u# G' J
63.     }
    
64. 
    7 ]4 t4 {. c) Z- G1 Z& H. K
65.     function sockState(){
    9 Z# m/ `% C6 J) ~4 V: b
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    4 s2 P9 T! b/ {# d
67.             return status[webSocket.readyState];
    $ R% |! Q) x- B+ H; x4 g
68.     }
    
69. 
    9 W/ H& g! }. S9 S- `
70. 
    
71. 
    2 J$ ?3 `, t7 a; B* Y
72. function start(event){
    
73.         console.log(webSocket);
    5 S6 c0 G0 @8 [2 w- K# G' n
74.         var msg = document.getElementById('text').value;
    
75.         document.getElementById('text').value = '';
    9 c8 a% w$ G# [' }7 [7 q$ y
76.         console.log("send:"+sockState());
    " @8 @- P: Q1 a' H/ ^0 Y
77.         console.log("msg="+msg);
    % v( m  P: x" D, K1 A0 r  T8 X( Q
78.         webSocket.send("msg="+msg);
    ' I0 F, A. x. h* W
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    
80.     };
    
81. 
    
82.     function close(event){
    3 V, C4 e: ~2 I# s3 x5 v, V
83.         webSocket.close();
    
84.     }
    
85. </script>
    
86. </body>
    
87. </html>

复制代码

: b3 |% s- F% e/ A
6 W% r8 y& G; |% N9 l  Y! g