php实现websocket实时消息推送

admin

php实现websocket实时消息推送
& F0 L* s0 Z! I$ x3 ?: A0 _, |
# s, H7 \0 A% ]8 ?( q! o" R( }( f
7 C& j: D4 z3 t4 \9 t  |8 kSocketService.php

1. <?php
   
2. /**
   1 \6 g& S4 O4 O9 S+ U6 q% Z+ g" b3 y
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   # t% O  |% J+ I; ?& L/ m, B
6. */
   
7. 
   ! f% h0 l* q, D: B; L
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    . O. j) F: @' g) G
11.     private $port = 8083;
    
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    2 e& N) b+ d! }$ O. }
14.     {
    ( O7 @( Z% M. |9 k3 u) Q$ G+ C
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    6 Z2 B7 B/ g9 g1 W
18.             if(!empty($port)) {
    ) L- g- B5 `% J! Y$ P2 I
19.                 $this->port = $port;
    
20.             }
    . `0 ^5 t+ E( `4 M
21.     }
    
22. 
    6 p) ^6 y- a0 p+ x0 u
23.     public function service(){
    
24.         //获取tcp协议号码。
    
25.         $tcp = getprotobyname("tcp");
    - l, {- I* v) E# ?7 H# u
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    - Y* s: z8 v/ Q9 z, L
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    1 U! a, v3 j% `  J. H: b* D, d6 k
28.         if($sock < 0)
    3 A7 c8 f: V& |$ x* Y, U, q$ k+ U
29.         {
    $ P! l1 v8 T- ]( C1 J
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    0 I$ H  q1 p: ?6 x0 Y0 Q$ ]
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.     }
    0 C1 u$ b) |. A% O2 V
37. 
    2 A) V. I# x& w' n4 o/ P) \
38.     public function run(){
    
39.         $this->service();
    ' \7 J4 a2 J1 S5 Q8 C
40.         $clients[] = $this->_sockets;
    
41.         while (true){
    ! R' q2 N! ]1 b) l2 U% b
42.             $changes = $clients;
    
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
    # N' u0 u0 p- c% K4 \, K$ w
48.                     if(($newClient = socket_accept($_sock))  === false){
    6 y+ F1 S/ b2 e$ I5 P9 \) c
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    0 l# ~" [* U7 i1 h3 a
50.                     }
    # x  f- e' _+ G
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    ; s6 B( k9 S. f2 v% `! g: f0 n
55.                     $clients[$ip] = $newClient;
    / ]" \* X6 S4 q5 `+ t/ S$ N) s
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    - X+ v2 k4 n& _+ w
58.                 } else {
    
59.                     socket_recv($_sock, $buffer,  2048, 0);
    0 X# \) ~- D, V! ]/ H
60.                     $msg = $this->message($buffer);
    
61.                     //在这里业务代码
    ) {$ t6 l6 M; z. X5 V
62.                     echo "{$key} clinet msg:",$msg,"\n";
    " P' a4 `- |) i
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    " y: ]+ C! y7 q3 t& s
67.                 }
    4 c3 |6 g9 k- b- Z
68.             }
    , \( W9 D) r4 P: v, o' g, R
69.         }
    8 Z$ S1 j8 \+ x( M! F7 I$ ~% f
70.     }
    
71. 
    
72.     /**
    2 s; ]# Y; G1 g7 T+ r8 z
73.      * 握手处理
    
74.      * @param $newClient socket
    ' ?2 n  i# o* H, i$ `' A
75.      * @return int  接收到的信息
    
76.      */
    
77.     public function handshaking($newClient, $line){
    
78. 
    5 j& b2 S1 B  z7 O' S+ T
79.         $headers = array();
    . Q& i9 J, P  _( Y- S0 l- K
80.         $lines = preg_split("/\r\n/", $line);
    & x* M" z, S# P. ?. P' D: y* b
81.         foreach($lines as $line)
    
82.         {
    $ @' J) h" d% X/ `
83.             $line = chop($line);
    # ]' I) F( c! i! I$ D
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    
85.             {
    
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
    # A5 \' K: @- ]0 F4 S
88.         }
    
89.         $secKey = $headers['Sec-WebSocket-Key'];
    & Z* _& G& W) c& y8 ?' |$ \1 R
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" .
    / K) [$ j: w* N0 E
92.             "Upgrade: websocket\r\n" .
    . i: ?: M5 X  ^
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";
    % {( o6 B4 I# `
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    % |9 `1 d* D  a2 v9 W  n% _, q  U" Q
99. 
    ' V" _- a8 U$ y8 g% C
100.     /**
     
101.      * 解析接收数据
     3 M! [' e2 m- O; A' O, o
102.      * @param $buffer
     2 t3 K0 D! ^2 v8 ]9 J: W# {1 K: L- z
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     ' ^5 h) [, }9 g0 c5 W" \
106.         $len = $masks = $data = $decoded = null;
     & R$ B1 u* {0 S2 x* _+ D
107.         $len = ord($buffer[1]) & 127;
     & B0 G0 V: \7 k" J- A( `/ C; A
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     5 ]9 A& C4 v8 b1 B3 P# a6 }) k) H
110.             $data = substr($buffer, 8);
     
111.         } else if ($len === 127)  {
     % p' d( O: q$ e: F6 Z9 ~. X
112.             $masks = substr($buffer, 10, 4);
     
113.             $data = substr($buffer, 14);
     / v& G' k. L! s
114.         } else  {
     4 m7 w" Z" I+ j. O- ?* M: z
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     
117.         }
     2 h! j, g7 V. m3 W' V& _9 h. A
118.         for ($index = 0; $index < strlen($data); $index++) {
       A: M' N3 r& `  ^/ {
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     
120.         }
     
121.         return $decoded;
     
122.     }
     
123. 
     " F) i5 ~0 `3 K0 C: V
124.     /**
     
125.      * 发送数据
     
126.      * @param $newClinet 新接入的socket
     9 `% q, C/ W& l4 W* T4 {1 `4 ^
127.      * @param $msg   要发送的数据
     ! u- \& Z: G- h: C
128.      * @return int|string
     * i) {  E4 ~* O0 m5 S6 B
129.      */
     
130.     public function send($newClinet, $msg){
     
131.         $msg = $this->frame($msg);
     & ^8 }. e) B7 o" w0 A" J$ _1 i
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     $ {$ B( V5 u/ T$ o5 }
134. 
     
135.     public function frame($s) {
     & h3 i; X4 o6 a7 Q9 ^
136.         $a = str_split($s, 125);
     0 {2 l2 R3 r& o" b6 u3 ~
137.         if (count($a) == 1) {
     1 Z) N- r9 |8 C4 y* z2 l; R
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
     ; p0 p, n$ Z1 S( Z% w# I- V
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
       r) t) U) [. t9 ?: j
143.         }
     ; J( Z( y1 a9 S: x! M
144.         return $ns;
     % f/ l/ _- k+ B6 i& k9 |" r
145.     }
     / C0 _3 C+ L, ^' {% u3 m1 _* w1 u
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     
150.     public function close(){
     5 T! R0 k+ Z( K: l
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     9 w) T% _8 g& [7 M
154. 
     % M) X5 f, q4 d3 n! s2 J% F, t1 s
155. $sock = new SocketService();
     ' W# c; D1 j- n0 H- q
156. $sock->run();
     # i& R9 p5 q- n9 b2 h* |" C8 ~
157. 
     

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   : t: L+ H2 Z* B2 e7 P$ _) \
3. <head>
   ; T' u2 n! E% x4 U
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   ( S1 c1 T6 X6 g1 h
6.   <title>websocket</title>
   
7. </head>
   
8. <body>
   ; y, V) R5 v# R4 W
9. <input id="text" value="">
   - i( ~3 P' Z% C) D* E
10. <input type="submit" value="send" onclick="start()">
    ( n) _& y4 k8 w
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    . K+ v* B9 P# h* ^8 s
13. <script>
    . L6 M) E7 ]- S) o( }
14. /**
    ' c6 X2 n% g  H8 d
15. 0：未连接
    
16. 1：连接成功，可通讯
    2 T: Z! s- ?( O5 f  ]! v
17. 2：正在关闭
    - e6 }' y1 C$ W- D2 j
18. 3：连接已关闭或无法打开
    
19. */
    
20. 
    
21.     //创建一个webSocket 实例
    ; t6 x* N% G; b( `9 `8 i2 O  H: l9 F
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    
24. 
    
25.     webSocket.onerror = function (event){
    : p8 \/ Y& I# S. n1 a! o' p
26.         onError(event);
    ) k! c) q8 O, U" J1 Z6 y4 \
27.     };
    
28. 
    4 m  j4 |# }5 e6 J
29.     // 打开websocket
    7 l* K( a0 o& o
30.     webSocket.onopen = function (event){
    : h  C' `, y; o6 j
31.         onOpen(event);
    
32.     };
    6 s# C; m! b0 l% y% l' {1 u
33. 
    
34.     //监听消息
    " P  `* f. R% T, ^9 H: T
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    0 v# K; R- G6 W9 u5 ^8 {( [1 m
37.     };
    
38. 
    
39. 
    # h: ?! H  p( }
40.     webSocket.onclose = function (event){
    + `1 ]2 }3 w# g7 y! W- \. y+ a* I! l
41.         onClose(event);
    ( ^& Q/ D9 Q" O$ x/ t
42.     }
    - d8 Y* j( C. Y+ T: q
43. 
    
44.     //关闭监听websocket
      u" g% C2 O) t
45.     function onError(event){
    & z& k( L' W3 |5 E5 B# U" A. G
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    9 t+ c" e1 ~; g5 S0 G4 t
49. 
    
50.     function onOpen(event){
    2 ]: ]$ E6 b6 T. Q% J+ O
51.         console.log("open:"+sockState());
    ! p7 `3 x  k! T  t) T: A; l+ J
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    " F  l. ?/ T% N( J8 L  ?
53.     };
    
54.     function onMessage(event){
    
55.         console.log("onMessage");
    2 F; ~2 y& m: t/ ^0 b- F1 M
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    ) G2 ^) H( Q2 X
58. 
    % k" K! D: j1 e# A
59.     function onClose(event){
    ; a4 K) L- S  n
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    " w: j: j; Z" e
61.         console.log("close:"+sockState());
    + n& k& l4 h4 Y0 |, _+ i1 L! {
62.         webSocket.close();
    
63.     }
    0 k2 ^4 Y2 i- C7 p7 j5 M7 i
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    
67.             return status[webSocket.readyState];
    
68.     }
    
69. 
    
70. 
    
71. 
    / Z: z: W; C" a( H- M$ Y9 G" a
72. function start(event){
    3 M" O; P$ E4 k- B8 p0 j$ {: o
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
    3 U* H) w4 x: U" k: {
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    3 N' Z& j+ T0 ?7 i4 B; P8 j
78.         webSocket.send("msg="+msg);
    ) d- V0 A# P) O& G: q/ v
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    $ L5 {5 ^0 R7 Q
80.     };
    
81. 
    8 y3 ?% _( s1 d0 X7 w# Q1 ?
82.     function close(event){
    ) U% a5 D6 x( f% k$ D, @. T* M
83.         webSocket.close();
    " H9 f4 v+ h/ ^; z) x9 Q! \
84.     }
    2 Y" [# K/ c6 O% _: q
85. </script>
    
86. </body>
    
87. </html>

复制代码

; J' Q4 g# W8 |
; K. v% \* ?5 d5 w