php实现websocket实时消息推送

admin

php实现websocket实时消息推送

9 e( D5 i, n4 d, c/ q  Q% Y% X  u
/ d: x2 \- q2 j/ CSocketService.php

1. <?php
   
2. /**
   " _& X$ l, m! B& S' A( Z+ E5 s" m
3. * Created by xwx
   
4. * Date: 2017/10/18
   
5. * Time: 14:33
   
6. */
   , J/ k1 b' O; c* B
7. 
   % o' {/ l  B+ _0 s0 @' j
8. class SocketService
   
9. {
   
10.     private $address  = '0.0.0.0';
    ; d& ?. l' h  z7 k4 k# R
11.     private $port = 8083;
    " Z8 }, z2 [+ S3 V
12.     private $_sockets;
    
13.     public function __construct($address = '', $port='')
    
14.     {
    : ^2 o# I! s( j' T* P
15.             if(!empty($address)){
    
16.                 $this->address = $address;
    
17.             }
    ) P) j) I6 R* e- F
18.             if(!empty($port)) {
    
19.                 $this->port = $port;
    3 w, @  \2 J0 N$ F" E
20.             }
    
21.     }
    
22. 
    / b8 {9 A4 c/ @3 h" e2 S
23.     public function service(){
    7 |, `$ c9 @" X8 a# d" s+ C
24.         //获取tcp协议号码。
    * x! }- Q# X* F4 l+ w- l. c
25.         $tcp = getprotobyname("tcp");
    5 R) @- u! N& p% S: H- q8 ^/ w4 v* F
26.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);
    * K  @! O+ X% N5 j8 {8 f
27.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
    # }8 N/ J$ a# N
28.         if($sock < 0)
    5 e, ]! |+ Z1 h) c( _/ m
29.         {
    
30.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
    
31.         }
    $ r- L1 z/ I; V  ?" q
32.         socket_bind($sock, $this->address, $this->port);
    4 X- ]+ g( C/ b& S( C
33.         socket_listen($sock, $this->port);
    
34.         echo "listen on $this->address $this->port ... \n";
    
35.         $this->_sockets = $sock;
    
36.     }
    
37. 
    
38.     public function run(){
    
39.         $this->service();
    
40.         $clients[] = $this->_sockets;
    6 Q$ g4 P4 X5 L: z7 ]" Z
41.         while (true){
    
42.             $changes = $clients;
    
43.             $write = NULL;
    6 O" \7 j& `7 L
44.             $except = NULL;
    
45.             socket_select($changes,  $write,  $except, NULL);
    0 J6 C* s9 J# u. Y% Y6 A
46.             foreach ($changes as $key => $_sock){
    
47.                 if($this->_sockets == $_sock){ //判断是不是新接入的socket
    
48.                     if(($newClient = socket_accept($_sock))  === false){
    * k; J6 D2 o3 ?1 l
49.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");
    
50.                     }
    " c" s- Q& t" J  S8 ]1 V( W! Y
51.                     $line = trim(socket_read($newClient, 1024));
    
52.                     $this->handshaking($newClient, $line);
    . f( G$ |7 f, Q& P6 s' T
53.                     //获取client ip
    
54.                     socket_getpeername ($newClient, $ip);
    % |7 T+ a' p! W7 G
55.                     $clients[$ip] = $newClient;
    
56.                     echo  "Client ip:{$ip}   \n";
    
57.                     echo "Client msg:{$line} \n";
    * J* X* y3 E( J6 `9 R8 n, G
58.                 } else {
    6 h: ^0 ]- Z) q) E
59.                     socket_recv($_sock, $buffer,  2048, 0);
    * J4 K+ U' f+ F1 r1 [7 n. y
60.                     $msg = $this->message($buffer);
    ' [6 t( v" x+ `' z$ p' J7 a
61.                     //在这里业务代码
    & h$ \+ \/ {8 D; C
62.                     echo "{$key} clinet msg:",$msg,"\n";
    8 A2 X& j# J  `$ Y3 ^. L5 q* N
63.                     fwrite(STDOUT, 'Please input a argument:');
    
64.                     $response = trim(fgets(STDIN));
    ' E; T1 k: W9 E3 r' c$ c
65.                     $this->send($_sock, $response);
    
66.                     echo "{$key} response to Client:".$response,"\n";
    / S  M+ [" a# Z  X" Z* w
67.                 }
    
68.             }
    
69.         }
    
70.     }
    ) Y9 |& c' h4 l3 `1 L7 D1 v) @
71. 
    0 d/ y; r3 H+ h! L
72.     /**
    
73.      * 握手处理
    
74.      * @param $newClient socket
    
75.      * @return int  接收到的信息
    ( I" w& J& a6 y/ a5 {$ {# i/ B
76.      */
    $ a/ `3 R, I/ T. F
77.     public function handshaking($newClient, $line){
    
78. 
    
79.         $headers = array();
    4 s0 q' K5 ^" s; i
80.         $lines = preg_split("/\r\n/", $line);
    3 b& x$ t6 G8 Q% ^4 f
81.         foreach($lines as $line)
    
82.         {
    ( X0 _3 b5 X, m4 _
83.             $line = chop($line);
    
84.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
    6 x( M* k4 M6 `' d. v' X
85.             {
    4 C- j( m$ t, q
86.                 $headers[$matches[1]] = $matches[2];
    
87.             }
      Z! l! f. ]- u: F. |$ N
88.         }
    , y  J9 o' U; t; |
89.         $secKey = $headers['Sec-WebSocket-Key'];
    ' {& q/ |- k4 c" ~8 n
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" .
    
92.             "Upgrade: websocket\r\n" .
    * G7 m& B) b/ K" Z$ a
93.             "Connection: Upgrade\r\n" .
    4 ?' L9 G7 R/ M1 B: u  [
94.             "WebSocket-Origin: $this->address\r\n" .
    
95.             "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket\r\n".
    8 f7 @) r6 j) D4 \9 H2 l  D
96.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    & ]! E) O" ^& y
97.         return socket_write($newClient, $upgrade, strlen($upgrade));
    
98.     }
    9 x0 J' N3 q3 {* {7 Z
99. 
    8 g1 q: V0 d# u3 X* L. r( S7 j" @" _
100.     /**
     
101.      * 解析接收数据
     
102.      * @param $buffer
     ! h$ g  y0 M2 N7 H* {
103.      * @return null|string
     
104.      */
     
105.     public function message($buffer){
     
106.         $len = $masks = $data = $decoded = null;
     
107.         $len = ord($buffer[1]) & 127;
     
108.         if ($len === 126)  {
     
109.             $masks = substr($buffer, 4, 4);
     
110.             $data = substr($buffer, 8);
     $ A5 G1 a; x! S: p
111.         } else if ($len === 127)  {
     + c% a  h4 h: O: ^6 M7 i- x; y
112.             $masks = substr($buffer, 10, 4);
     2 k8 \! B. |5 B2 R0 h( B: L) [
113.             $data = substr($buffer, 14);
     
114.         } else  {
     
115.             $masks = substr($buffer, 2, 4);
     
116.             $data = substr($buffer, 6);
     : [0 N' y( U) T3 {. S
117.         }
     
118.         for ($index = 0; $index < strlen($data); $index++) {
     , e5 L3 A2 `5 L: [7 ^, b
119.             $decoded .= $data[$index] ^ $masks[$index % 4];
     5 J! _5 H+ ?- X3 Q! q" r: Z8 U
120.         }
     
121.         return $decoded;
     ! f0 O* c: {& ^9 w* B
122.     }
     
123. 
     ; A+ ^! _% Y* B
124.     /**
     
125.      * 发送数据
     & ~0 K! j' C+ x; n, [
126.      * @param $newClinet 新接入的socket
     
127.      * @param $msg   要发送的数据
     # y) S6 c5 A0 \/ w* n* Q" D' ]: J
128.      * @return int|string
     : Q) Y5 g' ?* D3 m7 N
129.      */
     
130.     public function send($newClinet, $msg){
     . O& |8 w1 n2 E: I5 B) H  T" t, i4 ^
131.         $msg = $this->frame($msg);
     8 w+ [' Q1 {! q3 ]3 n$ i
132.         socket_write($newClinet, $msg, strlen($msg));
     
133.     }
     ; c  O1 S, b5 Y, I
134. 
     
135.     public function frame($s) {
     5 ~/ Z& A3 Q' z0 O$ N; ?
136.         $a = str_split($s, 125);
     ; }6 M9 R4 F6 @* _( P: m( p
137.         if (count($a) == 1) {
     1 a& G# [% k; y# E5 @
138.             return "\x81" . chr(strlen($a[0])) . $a[0];
     
139.         }
       Y$ O/ U) n. l
140.         $ns = "";
     
141.         foreach ($a as $o) {
     
142.             $ns .= "\x81" . chr(strlen($o)) . $o;
     ; ~$ n' H$ V9 i* x1 [$ R/ c' }5 u
143.         }
     
144.         return $ns;
     + ~0 ?. b. p+ Z
145.     }
     5 }2 ~8 x) ]( S# \4 P9 L- _
146. 
     
147.     /**
     
148.      * 关闭socket
     
149.      */
     - J9 s  L. J; b8 Y8 t
150.     public function close(){
     ! s5 y# G* d# _# Q/ {* Q
151.         return socket_close($this->_sockets);
     
152.     }
     
153. }
     
154. 
     8 v4 |; Y* B4 |0 C; E; a1 g- k
155. $sock = new SocketService();
     1 R6 c: Z8 c% A
156. $sock->run();
     
157. 
     4 ^8 w8 z! s1 T8 M0 V

复制代码

web.html

1. <!doctype html>
   
2. <html lang="en">
   / ^# O% e) ~, R/ @( ^
3. <head>
   
4.   <meta charset="UTF-8">
   
5.   <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
   
6.   <title>websocket</title>
   ) k! d8 I" a% N+ Y& `3 s6 z
7. </head>
   
8. <body>
   & r! h% E5 p$ e: n3 T2 b
9. <input id="text" value="">
   . Z* p) j) T# q! L- c. M
10. <input type="submit" value="send" onclick="start()">
    
11. <input type="submit" value="close" onclick="close()">
    
12. <div id="msg"></div>
    
13. <script>
    
14. /**
    
15. 0：未连接
    # M/ W3 P' q) B5 e0 W3 B2 M
16. 1：连接成功，可通讯
    6 S6 c  R1 f1 |5 o% s
17. 2：正在关闭
    
18. 3：连接已关闭或无法打开
    / V( v7 G, D. [  y2 I7 M  c
19. */
    $ N- ~3 X, Z3 _- \0 u% ^' o- G2 i
20. 
    2 q+ c9 c% ?4 v7 Z6 c+ Y1 M
21.     //创建一个webSocket 实例
    
22.     var webSocket  = new  WebSocket("ws://192.168.31.152:8083");
    
23. 
    . `8 y9 y/ ?5 n/ Z
24. 
    * b0 |3 t3 Z; ^# `; B
25.     webSocket.onerror = function (event){
    
26.         onError(event);
    
27.     };
    , G. }) _' j( V( A
28. 
    + a$ D" G0 O* t* Q' Z/ R/ T2 L
29.     // 打开websocket
    , o3 Y7 [) `- O; [1 T. }) u
30.     webSocket.onopen = function (event){
      i6 }4 d' t2 @) K7 A8 H  r# Z4 G
31.         onOpen(event);
    3 ^1 Y! D& m& B1 l5 S9 \: t, D6 e3 ^
32.     };
    1 g3 h+ @/ |- E# S0 |) R; q
33. 
    
34.     //监听消息
    
35.     webSocket.onmessage = function (event){
    
36.         onMessage(event);
    
37.     };
    
38. 
    
39. 
      F  E  q4 ?- ~3 \
40.     webSocket.onclose = function (event){
    
41.         onClose(event);
    $ @$ |8 V$ p) t5 }. L
42.     }
    ( P6 }3 X" A8 ]  k- j
43. 
    4 @$ p# S* R7 X, T" P3 `) P
44.     //关闭监听websocket
    0 Q8 s+ G/ j* r+ [0 b
45.     function onError(event){
    - Z' ?( ~5 ^" o+ J
46.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
47.         console.log("error"+event.data);
    
48.     };
    1 B1 F- ?# F' v5 A
49. 
    
50.     function onOpen(event){
    * Y1 G: b& \1 R3 K. F' A" b
51.         console.log("open:"+sockState());
    
52.         document.getElementById("msg").innerHTML = "<p>Connect to Service</p>";
    
53.     };
    
54.     function onMessage(event){
    ) W/ A, m' C4 [/ k  a9 I. S
55.         console.log("onMessage");
    / r1 r3 u7 o8 W! g3 T( b* H
56.         document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>"
    
57.     };
    
58. 
    
59.     function onClose(event){
    # K: q) p+ @# N" K
60.         document.getElementById("msg").innerHTML = "<p>close</p>";
    
61.         console.log("close:"+sockState());
    3 ]3 d9 c# a4 k3 M9 R6 C2 Y
62.         webSocket.close();
    ' W/ S2 s' y3 q6 r
63.     }
    
64. 
    
65.     function sockState(){
    
66.         var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];
    3 f. X* d* f. V8 w
67.             return status[webSocket.readyState];
    : ^+ ~# N. l6 T4 t6 t
68.     }
    1 Q0 i8 e) l( J0 P% x
69. 
    5 ~# O3 d# Z) X
70. 
    
71. 
    
72. function start(event){
    4 L& w# X# s* W) D! V
73.         console.log(webSocket);
    
74.         var msg = document.getElementById('text').value;
      J( Q5 i4 B# i* c" W& V5 y! q
75.         document.getElementById('text').value = '';
    
76.         console.log("send:"+sockState());
    
77.         console.log("msg="+msg);
    
78.         webSocket.send("msg="+msg);
    
79.         document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>"
    ; Z" t/ F1 `8 w! |
80.     };
    $ ?1 ^  \0 z6 s9 V9 D1 ^
81. 
    . j# m0 ~% l& ^# S4 `$ X5 y7 [
82.     function close(event){
    
83.         webSocket.close();
    1 @: s# K; P' X* o; J
84.     }
    ( A5 J' H4 x/ n+ @! d$ h
85. </script>
    
86. </body>
    
87. </html>

复制代码

: h+ n5 s7 F% J6 g0 R4 ~

- z, k- D" [# C" F