PHP 简单实现webSocket

admin · 发表于 2018-10-27 12:35:15

1）客户端实现

<html>! `- [& g. t; I1 x' e. U
<head>
/ R- I9 M# M; Y2 x
<meta charset="UTF-8">
0 f/ B( r v0 `! I, J' Z" T w
<title>Web sockets test</title>6 W1 |8 P- l# X7 Q1 h, J" K
<script src="jquery-min.js" type="text/javascript"></script>8 L4 E3 y+ z' a# }
<script type="text/javascript">
; D/ {7 h l) o
var ws;2 p* G; S" j+ @
function ToggleConnectionClicked() { " u- H R8 W8 i% |
try {
# @! _& Q* ]$ Z. N' u& D
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器
, T4 i4 v0 V: r& g( V
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};
; M: J) }' `8 N# R2 q4 |+ w
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};
, [ j6 t1 g% n; D' p
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};1 W( w/ o% E5 L$ z
ws.onerror = function(event){alert("WebSocket异常！");};3 l! |$ U% j8 u$ Z/ r. A* S
} catch (ex) {& A1 r( e |1 [* U
alert(ex.message); 2 x' p/ ?+ J/ C
}
- [3 j% H- v0 v# H2 j
};, [, @8 J% `3 d0 ?8 V3 s4 P: J
9 A7 j% s. [; W Q) J# O
function SendData() {
2 Z: @$ }) t. F: e1 N
try{
5 w$ `$ r5 v/ m$ Q0 ~ @/ C
var content = document.getElementById("content").value;
0 y- M" D. [. Z9 n$ y: N
if(content){
* }# K" U( O) a, a1 d
ws.send(content);( S7 v' S/ k3 E8 X" w
}2 e% Y3 ~% g, V
P7 t9 h7 A' N* w
}catch(ex){" o: x3 D! k: a9 N# W* X q( N
alert(ex.message);
1 v& K) l5 H7 `2 F+ p! [
} }# c. \- s0 S4 l1 {* r8 h" P1 C
};
: j- R1 b7 m4 s' q4 D3 W0 @
( \# K1 K1 D: Y& \, H. J9 A( p
function seestate(){# T2 R' M/ \7 C9 y6 c
alert(ws.readyState);9 ^' p* ^* `9 E, R
}$ p& N% z3 g( j" K" V8 x
b5 f4 C5 F( N$ c$ l
</script>' S6 M0 c0 Q# B+ u# \( L" u
</head>+ U7 J: T8 f0 N9 B1 q
<body>
2 `, O& V7 U5 N$ K2 h& Q
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />
% J; o7 ^ n6 z
<textarea id="content" ></textarea>: V4 `5 o. m# K
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />
' [& p0 N7 `5 z3 O
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />
. F9 b8 H0 b8 w' Y* A# e7 L% C, @
' s6 X# z: c2 o+ ^; q
</body>
1 }3 _3 r. g# {( y' `1 P7 B% U
</html>
/ p0 j) @; ~4 C: F6 r; Z

复制代码

2）服务器端实现

class WS {
8 p' `+ z4 p/ I Q! d0 a" |
var $master; // 连接 server 的 client5 e. f. O) _7 K& }# ]/ P+ K. ~" R
var $sockets = array(); // 不同状态的 socket 管理8 l. i- [- D8 W7 |3 T$ ?
var $handshake = false; // 判断是否握手
6 X2 ^3 E3 c J# v9 l
. i+ _/ A4 [& s2 X' H9 v- z
function __construct($address, $port){- T8 d! N0 p+ {) L. \$ V2 f2 D8 ~
// 建立一个 socket 套接字
1 w0 a! {& [& S" m. a$ F3 {
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) + E, b2 r" o u0 e% ]5 x; b
or die("socket_create() failed");+ g& v/ ]6 m; ^
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) ! K& g+ F; R* x! R9 q! G9 g
or die("socket_option() failed");
3 Q7 F! c3 o6 w2 Y/ b9 i$ m
socket_bind($this->master, $address, $port) 4 r2 a0 D, |1 ?& f6 l
or die("socket_bind() failed");
- |9 z3 s# E4 U) b
socket_listen($this->master, 2) ( n) U3 d6 U( k O. Q! X- r
or die("socket_listen() failed");
* i2 h1 V& j; ?. ?' l3 m- e
! n6 p+ h( y. t$ r9 f7 c5 u( P
$this->sockets[] = $this->master;
" b! n5 ^ x6 r2 ?$ z9 s# H; I
5 I% P4 j, _* }
// debug' A; m' E* Q8 d( A4 @
echo("Master socket : ".$this->master."\n");0 F8 ^6 v+ `' _/ R; p+ S
6 w& Y# v. t) x* i3 @
while(true) {5 s& K; m+ R2 c; q5 B9 Y, v% C0 W
//自动选择来消息的 socket 如果是握手自动选择主机' @: x/ D6 C9 m2 g* F5 N! X; v
$write = NULL;
% ~; }9 J5 G% A: w( M$ P: u" W
$except = NULL;
) y: }* I* a, n0 r# o* H. W
socket_select($this->sockets, $write, $except, NULL);6 Y: V% E5 ~( J% V& b, F
V* f! r# V5 C. K9 Q1 W) N8 ~
foreach ($this->sockets as $socket) {1 F2 X7 a" Q; R5 H- a: a
//连接主机的 client 9 E' h8 B( A( Q+ S" u
if ($socket == $this->master){
% e" l5 @1 a& V$ t/ z- p% J$ ]
$client = socket_accept($this->master);
. P2 s, m4 I+ q) `
if ($client < 0) {8 c' b3 n* X$ L6 W' I, w
// debug6 @) n) T- `9 x# ?: Z4 H
echo "socket_accept() failed";
2 F) U$ l0 h8 v) x$ a3 c3 j( R
continue;
$ t/ m7 ?- ?+ l/ g9 o
} else {: ^" J! w& F* L. N( {6 T
//connect($client);
5 z0 @0 y& T, `( A7 o! k
array_push($this->sockets, $client);( F- P7 L# B! H# @- t
echo "connect client\n";
1 U4 |' K6 [; D7 T' g7 q
}/ R J( B$ [0 e4 v5 h
} else {2 m7 v- P# O- ^, Q+ F4 h
$bytes = @socket_recv($socket,$buffer,2048,0);! S$ G( t" |, z( I1 l. F
print_r($buffer);
& J5 L4 g1 g# |$ x+ q9 f
if($bytes == 0) return;: L) m z3 r5 U [- t2 f
if (!$this->handshake) {
' }$ `/ A3 J! E [4 U& Y+ J2 q& ~
// 如果没有握手，先握手回应
5 i1 t( [2 }* A
$this->doHandShake($socket, $buffer);
( x+ V. ?1 l0 ?
echo "shakeHands\n";* H, T& {2 ~2 J3 r3 c1 A b' ?
} else {
2 q% Y; ~. Q8 s6 P
1 J; F# M9 V( O) Z7 v' W0 e
// 如果已经握手，直接接受数据，并处理
4 I5 W# o- ]. z( q* m$ Y7 a
$buffer = $this->decode($buffer);; \# {5 v3 d5 c' @0 S
//process($socket, $buffer);
* F3 j6 ?0 y4 b; n7 B8 O* r
echo "send file\n";
# W t' N+ @2 R1 v! w
}0 y+ I8 ^) X( T: ?% H1 |- s0 h+ p
}3 }4 v* ]# M }& D. T9 t7 T
}9 V9 g% d0 {: _* u
}
, f8 r0 ^+ g8 p; I
}
" l, k" Y' T* r- X& y, X' u$ k
2 O" D' W) g, s
function dohandshake($socket, $req)
5 A6 _" y* Q7 o& C' w$ |1 {
{5 N/ z- g: `/ p- K6 @9 n
// 获取加密key5 c) ^2 x2 @% f, E3 e+ m
$acceptKey = $this->encry($req);6 b. L/ [4 ^% Z4 y7 G+ K' m( |. q" G! Z
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .
/ }; c# z i+ h! R& I* l
"Upgrade: websocket\r\n" .3 Q- `( d& f( M0 x3 k6 Q8 I
"Connection: Upgrade\r\n" .* j+ g1 ~7 i+ s8 G+ @3 @( O
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .9 }/ o8 @: K3 r0 D
"\r\n";& v" B; b6 c% F+ }/ `2 u
* f' y! u% D' G, s2 i( h: k
echo "dohandshake ".$upgrade.chr(0);
% a H) q& Z% ]5 i i
// 写入socket
- C2 N4 `7 t- E; B; A% O- a8 f
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));1 Y) ~" z2 y# X0 g v
// 标记握手已经成功，下次接受数据采用数据帧格式+ @+ U$ {0 g) J4 h7 V2 f
$this->handshake = true;
9 ]9 n3 B# z; _ P% Y: J$ I0 E
}) D1 ^3 N5 {* z" p
) j( s( j* c+ \4 M/ x
+ ^; M, m' N. w& G6 S
function encry($req)
4 q8 Y. {9 D% b1 T; M* [/ U
{/ e0 R& P" x8 q
$key = $this->getKey($req);
T+ c5 j5 F! y: H3 s
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
" f& Z7 T2 `* }
% U: N# y: ~) r. h5 E
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
/ Z5 C H% A1 o' ]; [
}/ z0 v' D1 _, j% y$ a! v3 s; M
8 a( V6 L: \" A9 V
function getKey($req) $ q# e; c* q, k3 r, Z# p$ q
{
5 l/ P4 j4 u% O6 \" ]+ G3 {
$key = null;% j, ]/ H; p& T, p; B" X5 B$ u
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) { 0 j+ I7 q$ H$ `2 c V4 @* @
$key = $match[1]; . Z" Y/ t1 l7 l' r
}
& _6 \- O# Q% u4 f5 h
return $key;% u9 F5 l2 A5 |
}3 m. }) ]& g2 y; x! E; \# Y4 ^
0 a5 F; w5 x5 g Z) W" s* R
// 解析数据帧& c0 _ e! J1 {1 `5 ^( f% k. r
function decode($buffer) 9 Q, ]$ P3 l% O' Q: e$ U! N' N) W
{
6 p% h/ s6 ~) B1 x* [
$len = $masks = $data = $decoded = null;
0 r* D2 s* w; g: Z; [2 V) j
$len = ord($buffer[1]) & 127;
! D6 { N% [6 y! O
& o( G7 C! u$ H2 B+ I
if ($len === 126) {4 |$ b) S& ?2 b; W
$masks = substr($buffer, 4, 4);
2 H* }& f1 _3 B8 l1 S4 N; }" @# V; F
$data = substr($buffer, 8);
1 ]/ V" o: Y; N
} else if ($len === 127) {
- \) q; q; [; P6 u e
$masks = substr($buffer, 10, 4);' j8 Y2 b5 t7 e$ N5 {& P
$data = substr($buffer, 14);& v6 C! ?1 j: l5 C
} else {
$ ^/ v; L! Y$ y' @: j
$masks = substr($buffer, 2, 4);7 a1 ?! f2 A) Q6 _
$data = substr($buffer, 6);
- p5 x% a/ C8 z1 v9 F" H: i6 j3 ]
}
, p$ u1 Q v2 d# x; \+ G( Y! C
for ($index = 0; $index < strlen($data); $index++) {/ R% _/ S# |$ [, }, U$ X7 h
$decoded .= $data[$index] ^ $masks[$index % 4];
; P5 M- [9 }* U! ?5 p- z+ a0 e
}
5 c0 i" ]; J' v
return $decoded;; |: r3 |1 [ A/ ]( Z
}* d% y2 B( V: W3 P
# c$ T' ]" ?; f
// 返回帧信息处理
. l9 n# {7 a8 x1 _9 k
function frame($s) % b; C% r4 I3 B* S8 P* h+ k0 c
{: P( |6 z1 x1 x! |2 h; [4 E0 N
$a = str_split($s, 125);
" w) h u8 Q) U2 [: z+ H( q
if (count($a) == 1) {
6 p( S0 B$ \) R# Y7 V, A4 Y2 A
return "\x81" . chr(strlen($a[0])) . $a[0];, n" A5 l G9 z- S: u
}
2 Z, [0 N7 j( V6 `
$ns = "";- ^9 O3 @. ]- f! }/ M
foreach ($a as $o) {
J( q! \( B0 M) W) o7 G2 q2 F
$ns .= "\x81" . chr(strlen($o)) . $o;; y# |" d; V: j+ s) n
}
/ i8 o$ j9 r! ?% X% F, u% I
return $ns;
+ U, e2 R1 B( }
}$ e: z5 }$ }5 a% I. M
% b2 q6 j* o$ X$ ^5 V
// 返回数据0 }! W6 o4 B* c( k; r
function send($client, $msg)
' D" K# s, n! o# P% o
{
# L* b2 D: m! h7 R! Z
$msg = $this->frame($msg);$ Y! g Q7 X% N$ z
socket_write($client, $msg, strlen($msg));+ a% `: r8 c/ t% T% }& n
}7 v3 Q% i; E$ p- E4 e
}4 |3 v0 k$ f8 `
; j) E) N/ R& b* r. A
测试 $ws = new WS("127.0.0.1",2000); ~' J* V1 A7 K6 r! T3 J9 E
- q! w4 [7 E5 \1 ^9 _3 d3 |

复制代码

帐号		自动登录	找回密码
密码			立即注册

[php学习资料] PHP 简单实现webSocket