PHP 简单实现webSocket

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

1）客户端实现

<html>
) @* `9 \' m, H
<head>
, |7 Y F$ @% m3 g E- W
<meta charset="UTF-8">
! c/ o5 a/ S9 D
<title>Web sockets test</title>
8 ?; B s1 @" d/ w
<script src="jquery-min.js" type="text/javascript"></script>* R% t1 }4 a5 [+ G* |
<script type="text/javascript">% |4 k" Y! h& K, h/ T" G$ f4 u" a+ ^. k# g
var ws;6 u' D; A! n3 p+ W8 M! x, u
function ToggleConnectionClicked() {
" M" U& J9 |! M0 u9 U' k
try {( O O. J7 ^; o; E8 g; [) P
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器 & t3 m7 g0 S7 `
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};
B3 O$ N; [) u5 C' S
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};- \' {, R% Q. d1 h m A+ r
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};
- v1 v2 B7 `8 N; j c' z
ws.onerror = function(event){alert("WebSocket异常！");};2 l' U& m! g5 E' D1 j4 b
} catch (ex) {
: b7 n8 B% R L9 j3 W0 U
alert(ex.message); 8 y8 l& e: l3 v1 g5 C, d: @
}
, G2 e: ^' e$ v% Y9 Y
}; Q/ w5 D6 v' _1 D
. H7 c& L" _/ b+ Y7 p5 R% |% w
function SendData() {( f+ s- f# a2 t7 }' ^
try{
$ j3 ]) B4 z& A
var content = document.getElementById("content").value;( C$ G3 ?% J" S* O
if(content){1 ], C- Z2 ]3 v; b# I5 v
ws.send(content);8 [! p2 g5 l) T, L- j
}5 }7 A a6 r2 G5 e8 r
; z7 [1 z2 M& O: l/ b
}catch(ex){
% x4 o/ } k* y- U2 U
alert(ex.message);2 J5 f( X# z, f% l
}
" W* p2 `$ u; L3 w* U: P$ J
};
/ p9 I y2 o- r3 E
- Z: q! ^+ i1 U9 G- R
function seestate(){
& P. G5 L5 H% c3 j1 z3 P! W
alert(ws.readyState);3 d) X, y- |6 k0 }3 ` A
}) j; [( `( x4 |9 |& `, g9 S8 g
& j) {3 O4 \7 U7 Q& v
</script>
; F' r- Q3 D+ ~ N. a
</head>
9 w4 V/ C( C7 @- x. ?
<body>; \% q: Q/ X7 i0 @$ j; ?
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />3 J& c% [3 O, n' q9 E' d
<textarea id="content" ></textarea>
: j& @, P6 ^8 Z6 v- g( I1 K
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />
) [) r! x8 J7 r0 _) {4 a
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />+ G& ^! o( R B* V3 s* P
- J& { o {0 m' \+ h! k! ?
</body>
5 M K9 \+ @% f# O
</html>
! p6 J$ h9 c+ J6 X! u1 K- ]

复制代码

2）服务器端实现

class WS {
0 R$ |( n6 F# u" M! q9 m1 e7 C) t
var $master; // 连接 server 的 client
# x: [0 K& {2 t5 J
var $sockets = array(); // 不同状态的 socket 管理8 S) j# t# c! {! n3 q
var $handshake = false; // 判断是否握手6 \3 N; `5 H% i* F% U6 J
: `/ N; X ]. Z; m, p
function __construct($address, $port){
+ K4 u- c+ N3 k- W
// 建立一个 socket 套接字% W- }' m/ X" {* m o1 J! }2 f4 Q# R( v
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) + p& y% d- D5 z' N
or die("socket_create() failed");9 @8 J5 d0 k u2 {& T6 V/ A
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1)
* \, P( H7 E8 t0 _( \
or die("socket_option() failed");) n6 i; ~9 r7 F/ L: K, s, m8 r9 ~8 B
socket_bind($this->master, $address, $port)
3 f9 J- q; i7 Z5 ~7 N! |+ z9 P: L
or die("socket_bind() failed");
: u: x9 J$ z: n- f0 x
socket_listen($this->master, 2) . T1 [- ?: }' T" X7 b5 t- K* g$ K
or die("socket_listen() failed");, ^, M& @4 h6 E8 h
5 ^) t J7 U% d. M; H
$this->sockets[] = $this->master;2 x( R, c! B& Q+ U3 y" r# u
* w8 ]- ^: Q. B8 b% H5 w
// debug" ^ Q" q9 @; r5 C( h) ~# ?3 ~2 J
echo("Master socket : ".$this->master."\n");
$ `7 V5 y8 E7 C& }2 Y
while(true) {
( S! f5 A7 k) |& ^, H! Q# h
//自动选择来消息的 socket 如果是握手自动选择主机6 u0 o; j. R$ R4 Q
$write = NULL; \" ?8 d: {. A9 i$ a5 h, d3 G+ e
$except = NULL;
$ V$ s% J' O+ X; w! t
socket_select($this->sockets, $write, $except, NULL);& F3 R7 k; r1 n. }8 v# |
& f/ J/ m+ f$ ~# y6 P
foreach ($this->sockets as $socket) {
& O7 L* k) |8 | U7 P
//连接主机的 client 5 ]' q) t: V, Y a3 O
if ($socket == $this->master){/ _7 f: N) I! |, V
$client = socket_accept($this->master);
/ G" h6 b6 N/ x6 i1 s
if ($client < 0) {' \: w3 a; Q' S9 N3 m, o8 ]
// debug6 Y! ~0 y4 r# }
echo "socket_accept() failed";( Z; M$ U6 Z) _
continue;+ N+ t2 V: A0 S! L# C
} else {; {5 M# I3 b; ~$ f$ o" u0 s
//connect($client);4 S, L4 z) l- l V
array_push($this->sockets, $client);
) ^% j' n7 f2 y+ h0 P6 u7 j* T
echo "connect client\n";
- u/ C; D9 q. o; J! \
}
5 V1 A" l0 M9 _: F
} else {6 U+ q- I. O! k. Y/ v5 v
$bytes = @socket_recv($socket,$buffer,2048,0);
; m7 }- @' X; X+ r' E" `& p) ~7 a: _
print_r($buffer);
& G6 t! o4 ?$ y3 N G
if($bytes == 0) return;/ I5 Z$ a( k5 O$ i! b' }
if (!$this->handshake) {
. d2 ]. k- k+ e7 a( N$ b
// 如果没有握手，先握手回应
! z0 o; v' z( x* F4 q$ H! \+ y
$this->doHandShake($socket, $buffer);) T. {9 l; l/ C9 e! i
echo "shakeHands\n";
`4 [# o' o8 A# k; l7 W
} else {3 E# d) I7 a" d4 D4 L3 k4 z, E
- L$ b0 z( g- L2 r1 L
// 如果已经握手，直接接受数据，并处理! j7 D1 u# O% P: L- ^, Q) v- v" s
$buffer = $this->decode($buffer);
2 B: m2 b$ t6 J* X# g6 Y8 ]5 M
//process($socket, $buffer); ! ^0 h5 W2 F+ X0 _3 X) Y
echo "send file\n";
4 d7 Q7 [! b9 ^. X) a
}, ^' _. L& j8 Z1 a/ B
}
/ i4 E) L7 Q" y4 n% e* s
}
- h% o5 P. e, Z' W& f/ e" e/ H3 k
} G# d R/ P0 s4 J2 c# h
}
- x8 e" N# a9 W3 ]* P3 N0 x* C+ d0 d
- z; P! h3 J8 z$ f
function dohandshake($socket, $req)
I, e4 x- X/ W I& C
{
9 {9 L$ z+ S5 {, y3 x
// 获取加密key
. c1 o9 n) x+ S. K3 Q9 o+ q2 n5 v9 |9 x
$acceptKey = $this->encry($req);
6 ~0 D% R- J7 C
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" ." {: i8 A2 H; m0 X B' k- @7 K
"Upgrade: websocket\r\n" .) p2 o. {/ S6 j8 ?3 {. A6 T! _3 s
"Connection: Upgrade\r\n" .
( t; V5 z0 A1 d5 H7 I" z
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .& y2 o2 g" e7 y9 g/ W
"\r\n";
8 d9 o0 \9 r) @) n
+ n0 o5 G1 ?) ~5 c z4 E+ S
echo "dohandshake ".$upgrade.chr(0); 1 [! R2 `7 ^, r! M( z
// 写入socket) S0 l$ z/ Y) J" e' @8 E
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
3 \; j4 r2 c& L }* F
// 标记握手已经成功，下次接受数据采用数据帧格式; r0 b' O( y0 y6 `! a; D* {. x
$this->handshake = true;/ ]1 o; n2 w3 i: B
}
, @/ T s% d7 L
+ T! k, @" \1 C
. W2 T- s% m h" x, M3 S' c
function encry($req)
. T' Q- ]2 `% s& _2 j; {( |! Y
{% \8 e- x, ~- N5 J! ]' A
$key = $this->getKey($req);
/ \( v. r$ z6 _7 f6 y
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
7 r" ~. K4 h7 I6 c
! {! E( \1 g+ ^* s6 I/ e
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));& a$ e+ s& g3 V, q) i
}
2 y0 ?, R: }5 U* s
1 C; g( ~) s+ U) e
function getKey($req)
3 ]/ Z& \& w" i$ U
{
7 c2 H2 r4 T- P |6 i: c
$key = null;0 o/ j ?+ ~9 J. ~" U
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) {
# G) h6 R8 f5 ]( E* V. b* t" p9 a
$key = $match[1]; - j" F/ h0 I" C
}! }; c) Q1 @) ]- V: b
return $key;
1 S+ b& N3 n1 F8 X
}
/ t( d m8 W* v- _ K/ L
' h" ?0 T- o' D6 d ]! R; ?
// 解析数据帧4 x$ O5 Q9 z* l+ ]7 G. [7 {2 E9 q
function decode($buffer)
* w/ D' M# ]4 _/ K& L) @ m
{
7 O) v* h( m4 ~" i6 J
$len = $masks = $data = $decoded = null;
, S3 V9 l0 S/ i/ h; `
$len = ord($buffer[1]) & 127;
1 F$ ~) V; g; K- g5 v! v( f
. x d# g& e! B5 j6 w
if ($len === 126) {6 B0 N8 _( ?$ U9 l: n
$masks = substr($buffer, 4, 4);5 {2 k' ?1 b5 @3 _; V
$data = substr($buffer, 8); k' ^; B2 O- _, c- N/ w; A
} else if ($len === 127) {
9 T7 |- M- R: e9 z9 o$ k
$masks = substr($buffer, 10, 4);
7 U2 X- ~0 L. Y% f' `: P c
$data = substr($buffer, 14);3 e. r" ?7 a, H; `( n! Z
} else {5 {4 f; e& j [: W s! t
$masks = substr($buffer, 2, 4);
7 Z& E7 F9 |1 t9 p
$data = substr($buffer, 6);
) O4 |7 ^2 C& f0 C# U1 S1 u
}
. P9 ]* c- g v- X
for ($index = 0; $index < strlen($data); $index++) {( Z& e2 h- U2 g" m6 M% o
$decoded .= $data[$index] ^ $masks[$index % 4];
( i2 X$ I$ Z6 H$ ]* U
}& q! u6 m$ P4 [
return $decoded;/ X* U/ C; X7 @0 {( I
}& ~, d/ z4 [1 S7 O3 Z1 t, L
) ]/ }# g8 M8 ?2 v
// 返回帧信息处理
8 D& a" H+ R( d3 P
function frame($s)
2 e+ m0 y. k5 p' M
{
5 b$ l( Q; ^7 ?0 F* z
$a = str_split($s, 125); ~5 |1 s: Q9 v# e( N* I# d
if (count($a) == 1) {' U" m! |' `6 |6 P$ p2 i+ N$ F
return "\x81" . chr(strlen($a[0])) . $a[0];
8 v/ y( r% d! L$ J$ P9 W
}: b( Q% f, }/ K) n! B; Y, v* M
$ns = "";& \5 l; m/ @. f" P
foreach ($a as $o) {
: e$ i& K V+ y, k0 W/ X
$ns .= "\x81" . chr(strlen($o)) . $o;* \# b4 L- @# b+ ]5 R+ H3 l
}
0 Z( a# B" h' C9 S
return $ns;
' ^+ F6 R9 u) o! R. v
}
$ x# y4 V; i2 _7 X
4 U* ], A( ]( {8 ]! X
// 返回数据
, y; G- E6 k" b3 ]
function send($client, $msg)4 c+ P, ^7 I: K& M) t2 p
{8 ~* x8 C" L/ ]' t9 _8 I
$msg = $this->frame($msg);
/ Z" j9 a6 M8 A3 V W5 j6 s
socket_write($client, $msg, strlen($msg));
% j' a" h! ^( a8 h
}
2 r! R% x' ?( O2 K
}& ^" |4 u. h( q
: f8 t: X' Q. \
测试 $ws = new WS("127.0.0.1",2000);
( P! U% _6 } I4 F+ P: v
9 m/ g+ e, H* G6 {+ a% G! d

复制代码

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

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