PHP 简单实现webSocket

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

1）客户端实现

<html>+ C0 t6 t4 u3 V# Q+ f- U
<head>" y+ z. N( j# s3 I/ o& S
<meta charset="UTF-8">! `5 R+ U1 c# [0 C
<title>Web sockets test</title>
- h# k. z: N9 U
<script src="jquery-min.js" type="text/javascript"></script>( Z2 S+ v: T; c* K6 a
<script type="text/javascript">
( k: ~! \) }) O. c5 }3 U' t$ s
var ws;
+ G9 K( u4 h' @7 m
function ToggleConnectionClicked() {
, N' x/ [$ j1 E; a3 m
try {
" L1 s7 D6 _; t- c. B3 B! }5 p
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器 Z' M- f' L# N
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};8 J/ e2 o3 J8 l
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};5 @, D. _* t* N" ]
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};# X. \- @) v& F. C0 ^- Z/ O& _8 r& u
ws.onerror = function(event){alert("WebSocket异常！");};
$ `* J ?" X- b0 n. e& p
} catch (ex) {
8 W+ l3 R: G% c
alert(ex.message);
/ V! E6 T% c/ G [/ Z
}( M' M4 x+ {: @$ w$ A! J: P
};7 k+ W8 V+ s( P* @
( }0 E: _" J8 [* _. X- \- | y
function SendData() {8 c# o; ?% Y( R3 N3 k+ ?
try{
7 {5 P4 I9 k* A$ i/ P, i0 T
var content = document.getElementById("content").value;3 ?4 i- V0 Q7 ~+ U! M: J# Q
if(content){% T2 T" \+ K A; `: E
ws.send(content);; n8 l1 i/ N' s/ p8 ~
}2 e" C. @5 ~( L; i
& ?9 E! g, p& {! z5 f
}catch(ex){
9 D7 j( @" y7 |1 w/ i" x8 B
alert(ex.message);
4 h* t" D: U5 ]
}4 q/ @% g5 E: ]( b% v
};+ }3 n* h/ |" [$ s, H
! B9 M3 ]( d( S/ g7 w+ K$ {( C2 B6 B
function seestate(){
6 B h- ~ m$ \% h2 \5 T
alert(ws.readyState);+ w5 S0 }! P1 p' J0 C3 G, ?
}$ d* @: ?, n3 I! k
. x5 O. Z3 a) {& f q Q- O4 H
</script>
( v5 S- Y: d% @& C& x) ^6 @: I5 q
</head>
9 L0 c o4 T# G: |% \
<body>
7 f/ a! I1 r, \: ?9 n
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />1 I3 c; d- f! a
<textarea id="content" ></textarea>7 P, Q2 I# t) F5 `( x1 a
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />3 E0 I: b0 F# x) [+ P
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />
) l+ c/ ?4 O. t
+ r% G6 p" y: S& [4 |
</body>
9 B1 M8 J2 ]2 e% m# Y
</html>* U( Y1 V$ {" \% l) G4 z

复制代码

2）服务器端实现

class WS {7 E0 \) T0 s+ K8 a9 B' }' ^
var $master; // 连接 server 的 client
* Y3 W. Q6 r+ o+ F. Z
var $sockets = array(); // 不同状态的 socket 管理
9 x) @7 T/ Q, i/ E% p
var $handshake = false; // 判断是否握手
( d" I" Q0 c5 F- v, Y4 Y
( z) z/ u! O% a4 n3 {, H" p8 p
function __construct($address, $port){" R4 S5 j3 U. S. R2 R
// 建立一个 socket 套接字/ F, E! A/ J. \& ~7 Z8 W
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) 5 u7 O/ ]* Z- f; V
or die("socket_create() failed");
3 r" b- T: s- D+ G
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1)
3 O. Y) A2 D1 F
or die("socket_option() failed");
) P+ H" f" c4 O p! ?
socket_bind($this->master, $address, $port)
9 `) [: l. B! L, A+ U
or die("socket_bind() failed");
; t2 N9 c& b: l. F! d
socket_listen($this->master, 2)
6 h. E+ @: t* _5 O, c% R0 S+ R
or die("socket_listen() failed");
4 Z' g, d! `4 P) v5 I6 [
* R3 L3 d: X. o" ~3 F* y0 {3 d G
$this->sockets[] = $this->master;7 }1 ?5 E1 o4 y" u
g. H5 i) _/ f" _0 ]; k8 n/ p, j
// debug
D( j# a" ?; g3 V! V- ~/ ]) k" ~5 T
echo("Master socket : ".$this->master."\n");
: [5 J- G4 ~8 Y) K0 [6 ?
2 i3 e; i- l" j6 E4 a% V
while(true) {
) K3 A: J# w: h* P4 s
//自动选择来消息的 socket 如果是握手自动选择主机
5 V: l4 J$ M) g; J! f& j
$write = NULL;
1 ^% l: \+ J0 S3 Z$ C
$except = NULL;4 |, u {% G. ?' c5 i% u6 i/ E
socket_select($this->sockets, $write, $except, NULL);* N2 S( S& z2 x* |, Q7 L3 O
4 V, {' j, q' Y6 M+ Z/ q
foreach ($this->sockets as $socket) {
6 X! d& V3 B B' y' _8 b( ~
//连接主机的 client
: d4 E3 O. k9 J9 c2 g" n
if ($socket == $this->master){4 M" E6 b+ p6 ]8 ^! s+ E
$client = socket_accept($this->master);8 _5 G' n# O! s. C4 |4 T3 t# \2 H
if ($client < 0) {
/ {7 E* Y* w* f# k' w3 g
// debug2 N6 I' N7 M' X6 T0 `; ~
echo "socket_accept() failed";
$ k9 Y% W% G/ e1 N: \! z
continue;
0 _) M/ `: S2 K% c- ^$ W; P
} else {
; x5 I- D$ L: \; y
//connect($client);
$ e) R* x+ d9 F$ [9 @; U3 B
array_push($this->sockets, $client);6 k, \* c9 O! k& Z
echo "connect client\n";+ E g) B) f# w7 ?5 ~7 i$ t7 q3 ^
}
) R" o2 O @( {. g, g
} else {8 i" w, n. d. j9 \% ]4 g
$bytes = @socket_recv($socket,$buffer,2048,0);
[- F, ]9 j* X( {
print_r($buffer);
* v/ a& w( F% h- V6 @! B
if($bytes == 0) return; [6 ? z6 ]" Z+ O, {
if (!$this->handshake) {! w5 b' m3 \4 g5 R, ?1 r5 G5 |
// 如果没有握手，先握手回应
/ }+ j1 _3 k q+ K( r( ?9 Z- W
$this->doHandShake($socket, $buffer);9 }& q4 u% g6 B) l$ M$ B
echo "shakeHands\n";
z! }; r, \! T& \9 |% [
} else {
+ j" {% ]% E7 I6 s' k% o
7 Z) u M; y. W/ }% r8 s
// 如果已经握手，直接接受数据，并处理+ \0 y. Q5 W% v v1 s
$buffer = $this->decode($buffer);& A4 p6 d$ a/ D( i+ Y: |
//process($socket, $buffer); , P+ K. c# g4 ~" T
echo "send file\n"; o" z9 b5 i/ h S- K8 ^6 R6 d
}
; q/ W7 | F+ B: p# d, E a# g
}; d7 l, Z8 k6 w. I0 W/ s
}' t/ b( M5 `/ e# E
}
4 t: Y# [8 T/ Z
}
x/ _- L0 Z& g1 }) n8 Z) b
2 D! g0 ^% M |
function dohandshake($socket, $req)
" ~3 Y9 P4 c4 t, f# p2 N4 |2 G
{" j* `' U6 v' S' m
// 获取加密key* ~2 P& x8 H f9 r
$acceptKey = $this->encry($req);7 T( Z' C" `4 g( k, R
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .3 K# j& C, _0 L: K% f e+ O' X
"Upgrade: websocket\r\n" ./ ]8 R# i- g8 Z' R0 Y# \4 i
"Connection: Upgrade\r\n" .; m( n D& i8 [
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .0 y" b# M0 v* X# h7 `# @4 @' {
"\r\n"; R2 l# B1 J2 V6 b, p; B$ R5 |
3 v' D' v9 B$ f: A# f
echo "dohandshake ".$upgrade.chr(0); , n6 a n+ R4 |
// 写入socket( V% @) H: [6 x. q% _2 v0 `
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));3 E: w4 i" E5 G- I l
// 标记握手已经成功，下次接受数据采用数据帧格式
3 ^$ h/ ^* t1 a* U& N4 C) z
$this->handshake = true;
$ e: b. [' n$ e6 `* [/ E
}8 S1 F* }9 F, c% E
1 ~0 K; V2 e2 [. m/ _9 l5 p
4 l) @; u0 `% g
function encry($req)3 \+ ]6 C" N. P3 N
{- G9 |2 L1 N2 j* `9 Y
$key = $this->getKey($req);' q9 d! z4 Q, [
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";4 |0 p# {3 R9 u% q8 {
% y0 Q* j! i' l. h) O
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));* t" X3 | g( v5 {9 W2 e0 C
}
, k, E0 a& o! ?' Q: }' G" H
9 `# x( t$ @, C2 ]
function getKey($req)
% j% J# z1 H I6 Y& b
{
) x) _ O; ~1 u$ I& i
$key = null;
( ~. F! r* p) l0 n* L, C
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) {
4 T) E+ x; d) M0 |! `" k& O
$key = $match[1]; " l/ q3 B' Q" y# i9 ?5 R& q
}
" m2 a; p+ X) Y8 y
return $key;% k+ i- p5 p* T8 a) \/ x
}
" c* D2 s8 }- v/ ~
/ U3 W9 L! }7 T
// 解析数据帧7 d ~# w, C/ @; }1 m; Z
function decode($buffer) , o1 a. E2 a, d( [
{ e; E8 O) H" {+ f) }
$len = $masks = $data = $decoded = null;: v5 h9 X: g: {$ v; ^2 k+ C
$len = ord($buffer[1]) & 127;
" t* ^5 z( M0 \
/ k' p5 W9 b- J3 R
if ($len === 126) {& V% \- d W x; e+ t, D3 V
$masks = substr($buffer, 4, 4);
4 o' `, T9 e9 a3 O. ?2 a
$data = substr($buffer, 8);* l2 Z; I0 q5 i- b, h% ]* z5 J9 ~
} else if ($len === 127) {
! L: d; X9 u* f& K( s
$masks = substr($buffer, 10, 4);
) D: q8 @. U" U, @6 g3 l% ]) |
$data = substr($buffer, 14);
4 o* f3 U7 z$ q$ a
} else {5 G& N. ^; [' w
$masks = substr($buffer, 2, 4);& F, A) I0 j# @- k6 g
$data = substr($buffer, 6);
A2 Q r% ?% R8 c+ R3 \
}
8 ` |8 {- ~4 r5 |% Y; W! ^
for ($index = 0; $index < strlen($data); $index++) {
; O+ m5 T* J( T: j- [
$decoded .= $data[$index] ^ $masks[$index % 4];, X1 _8 X6 `/ i1 j) @, g& J
}
" i! D! t0 U. g- b% E1 i
return $decoded;
B; @$ h* U- h
}
6 m" {4 s+ I; c h; U. O: A
1 b9 t& p# A$ \/ f/ C
// 返回帧信息处理: p! f3 e/ h& {2 C* x
function frame($s) 3 l# {) Q) z0 l$ b0 g& R
{4 c4 l! e0 l* @* ?, F: E' ~
$a = str_split($s, 125);
: M' ^6 A# J0 d
if (count($a) == 1) { P- o* ]; G G1 U8 D {2 w
return "\x81" . chr(strlen($a[0])) . $a[0];
( P5 @# e& l% f* m
}2 P0 v' D1 s6 L5 w2 @3 U6 a. c
$ns = "";
; ?; T& `% v B8 j$ o9 A# G! [
foreach ($a as $o) {2 a6 U. V Q# }) |7 q3 e$ {. s; Z
$ns .= "\x81" . chr(strlen($o)) . $o;
! x1 a! `$ O5 t3 Q
}
. { X# B) D9 M" k! L _. V6 y$ f
return $ns; d0 W8 s0 o& f, Q, M2 R" m
}
: U2 J" I% K! ^! u q% E. Z/ z; v
1 w c4 H& n6 w! p. E" U& P
// 返回数据$ R' w8 V/ ]/ A$ y' J. \1 ]7 t2 g
function send($client, $msg)
+ J& x; L9 G; V% Z6 h; n
{
& s, t. y* o2 J3 {, H
$msg = $this->frame($msg);
" {' v7 A& _) |) n: v% p1 m, v
socket_write($client, $msg, strlen($msg));
3 `. p% L1 G* d6 h* G' d
}
" ?0 J, }3 P3 R* b
}
5 y* J6 N* j5 D0 @9 a, C5 `8 g
+ e- Z) ]" c% n" s# X; n
测试 $ws = new WS("127.0.0.1",2000);
% @: m4 Y, t. R/ f: t+ V8 F
- L) c0 M! W2 B7 O6 W6 H

复制代码

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

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

浏览过的版块