PHP 简单实现webSocket

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

1）客户端实现

<html>4 q' |: ~6 Z; }/ H d" W0 }
<head># M; D% s! H* X) C+ j; ~6 l% K; b+ \
<meta charset="UTF-8">
8 m# r+ B5 N5 V* o
<title>Web sockets test</title>
) x5 I+ ] S% o) h' N7 W/ h
<script src="jquery-min.js" type="text/javascript"></script>
- {2 y0 \2 U0 w) _, {
<script type="text/javascript">" s2 k& ^; Y! T" w" T- [- {
var ws;
7 J* v0 x; [9 ~
function ToggleConnectionClicked() {
9 e( K% E* G' B: v5 Y4 G
try {1 z, u0 G: Z1 y! j3 z& z
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器
# G% X$ z+ k8 _
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};# \, I9 s2 K8 ~$ Z: `5 r* B8 V. Q/ N
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};1 O5 o5 E" j9 D) L8 Y8 a* \
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};
- B( Y. }% X9 ?7 h
ws.onerror = function(event){alert("WebSocket异常！");};# d- Q( p+ C/ M- ?& \
} catch (ex) {: _" u# i! g, n( u# ^3 k
alert(ex.message); / D* o0 x7 I, L' T- f
}" r7 d6 M. N- G2 m- V- I! e2 Y0 b! B
};4 q$ j% _: c7 b8 E
. i) @2 K* I- [ [) H7 W% @0 n
function SendData() {# E6 s, Z4 ] }& j8 A" W& T! u" ]
try{
+ } U" z4 L2 |. H O" n6 U7 v1 o
var content = document.getElementById("content").value;% k8 E* ~7 G- A: O# Y4 G( M
if(content){
( t8 d; _& [5 ~/ X( ~
ws.send(content);
" Y7 c/ Q" D2 e9 Z3 V' {( h- }
}( O/ I' j$ {& f. S
* h0 b3 x1 F: N5 P% n
}catch(ex){
% g4 i. E. a2 ?( n& r
alert(ex.message);4 C7 m7 L% d1 o* u, H
}- j8 l c) Y$ m! I1 P E# p& w1 b
};
# q( R/ }/ P# B% |1 r0 q
9 G/ y/ Y2 e4 F; Q- A4 q
function seestate(){
& ~2 L5 |! L. ^. I. e6 ]* v
alert(ws.readyState);
1 l" |& V; z' O3 }: p' E% s- L& d5 G
}( d0 S. [4 t) s9 @" Q& a
) M. ?9 |* U, d! R9 Q1 i5 H; M
</script>
4 [: Q. @% P, @: W( o
</head>
) o( `* p# D- A! p/ z5 X' W( D" }+ i
<body>. Z" s# w: D* s# k
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />
' Z1 N1 I6 L; g, S; Z( b8 e0 j
<textarea id="content" ></textarea>5 O& w* g, g9 J- N7 h% [& l
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />6 t$ F# } i8 ?: R& d# n0 u3 d
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />
1 K) u' ]0 o6 A/ j/ B- ] N
2 U% c8 N( ^4 ]0 A7 m5 }: F
</body>( @( [3 n2 U9 o5 k
</html>
6 f& r ]- s9 H1 @- i- e& Q- i9 |% ~

复制代码

2）服务器端实现

class WS {) t, P4 u2 T5 S2 @* e- V: X
var $master; // 连接 server 的 client
! Q6 Q& d* p$ X& h0 g' T
var $sockets = array(); // 不同状态的 socket 管理, Z( ~& l0 b6 u$ Z' r4 R- j: a' y& s, s
var $handshake = false; // 判断是否握手3 X9 F! }% [! S, `
1 K$ I7 Z6 l6 {7 w' s- E1 [' k! X8 V
function __construct($address, $port){
5 ], @( k9 Q8 Y/ v* x& L! P6 w! f
// 建立一个 socket 套接字4 J& |" }% Y% `" _7 i& m7 M7 [) X
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
, N% x- b1 m8 I; \$ g1 V' ^0 T' {# a, R
or die("socket_create() failed");9 N' F+ R" B2 M, S
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1)
6 g. i& R' ?6 j7 L7 Q) X9 W
or die("socket_option() failed");: ]" v; ?, ]9 v- }$ h& h
socket_bind($this->master, $address, $port)
* ~* E0 o; B l# ]0 B) l* K
or die("socket_bind() failed");( u! ~9 J/ f$ q; ]) E1 Z
socket_listen($this->master, 2) 4 m$ B7 ^3 j7 I: B
or die("socket_listen() failed");
& a+ O) S# H8 g0 K) m3 m- e( w
. p4 U5 q8 ? L- ~
$this->sockets[] = $this->master;
) A& J( h* h) A5 O( C. A
+ M4 k b/ M& U, d% y; t2 q# J/ N
// debug) y: P3 e9 I0 D* ?5 |
echo("Master socket : ".$this->master."\n");
: _9 i/ t* L1 b# m" [ E8 ]
L7 {0 |; C- p8 s- t9 |& m
while(true) {8 e4 w) B: H4 _/ q, g H- D
//自动选择来消息的 socket 如果是握手自动选择主机( u8 c( a$ e4 A: j
$write = NULL;
' e" a, V9 u. }- N) K6 L5 g1 u
$except = NULL;
: }" j6 ]( v8 d# }7 A# m, o5 S
socket_select($this->sockets, $write, $except, NULL);$ l3 ^: u* j) ]$ v/ c' ~# R* G
2 t9 W% C& i3 Y) R6 X4 i- n5 S) k
foreach ($this->sockets as $socket) {# e& S6 v+ j H9 b1 S' z$ c
//连接主机的 client + ^, `# \7 u4 x6 J) g$ b. G% C S% \
if ($socket == $this->master){5 O. R1 i# _9 j3 J
$client = socket_accept($this->master);
/ I: u3 ]5 k4 `+ a7 U( D- L
if ($client < 0) {
! l8 p3 ^$ k3 G s9 N
// debug2 c _; c: t+ t
echo "socket_accept() failed";
, I/ |5 e8 ~2 g, z% U% j1 S, G
continue;
5 U9 [; k- A- n+ S( D. t( H
} else {8 v& X9 F& s9 E! P- s
//connect($client);
1 y5 b* I4 b0 T1 n# q( ]# A1 ?
array_push($this->sockets, $client);
, `! f+ D' J$ }% T
echo "connect client\n";5 |9 @7 I1 K7 A7 j( H
}8 x) n: v7 p$ A; w% z$ n
} else {
0 o# e$ Q9 T& k8 Q, j ]# I! T
$bytes = @socket_recv($socket,$buffer,2048,0);) K) Z( e) g+ u
print_r($buffer);
2 t( e- {# ?$ a' C
if($bytes == 0) return;' b J, {6 _" J7 G- x2 \
if (!$this->handshake) {# c& `) z7 F D& }" }
// 如果没有握手，先握手回应9 o- M0 |( K& K) o+ e8 r# G- `
$this->doHandShake($socket, $buffer);
' z; O) ^4 @! k; U! a+ i
echo "shakeHands\n";% [3 s" Y/ L) `, x* v
} else {# F' G: H. Z1 y% s/ o7 L
' N4 S7 h; f' @5 G3 Z$ q. s
// 如果已经握手，直接接受数据，并处理. D: T# b* q5 |
$buffer = $this->decode($buffer);- C1 r% j4 ]0 M3 N
//process($socket, $buffer); : U% r& s0 R' ~; Z& K' x
echo "send file\n";
( S: B/ |: _9 J' D
}. E/ c+ I2 X( D3 N: `+ Y D1 }
}
( ?/ }" h' {1 I7 l4 D% J6 o
}: _ O4 |5 j4 m5 S) O# f6 S( f" `( ^
}
& G, }3 `: H) o- F$ b0 V7 o3 q
}
% O! F, v1 i5 I8 A
- B% Y4 I; k% I" h) K- O ?
function dohandshake($socket, $req)- n) S( n( v5 W- i5 x4 `
{0 |2 i ~2 i3 B$ \5 U
// 获取加密key
. j s5 n+ H/ ]) A3 H& J& R. g
$acceptKey = $this->encry($req);+ L1 `8 r& F6 Y! N( u; E) O
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .. r% v5 f/ o+ ~0 J7 c
"Upgrade: websocket\r\n" .
3 X7 G1 C1 x$ D" Z
"Connection: Upgrade\r\n" .& }( l$ h9 N6 B6 \5 u- |* J4 [1 A
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .
; d, S# H+ I) d/ h& O% R
"\r\n";
) g% y* E- |( }; X8 o5 q
. A6 ~/ Z8 k) S# M- `
echo "dohandshake ".$upgrade.chr(0);
' [' R" J- h, _7 ~: g @
// 写入socket/ S$ o$ p- F9 u; G" T" X
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
U$ ?, A' Z& M& r: J1 M: d
// 标记握手已经成功，下次接受数据采用数据帧格式
3 D, d: G4 v) u! z
$this->handshake = true;
3 ]/ X! O R8 g
}" V3 {3 n: B2 @$ Y3 i' p# F9 c
, ^3 ^& {, b. Y7 y2 S+ T, U7 O
5 B( u2 } G* m0 K5 ?! t/ I. g
function encry($req)+ V, o2 H( |4 H& |8 M1 U
{8 u0 z' }" H2 o8 U
$key = $this->getKey($req);3 k& z* Z, d" V: l. Z( z6 Q6 y
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
( C/ B/ E' e( J7 W4 I/ Z* n, z
& l: l/ c8 ]% h4 q/ M4 o2 J: k9 j
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));5 t( {2 _5 Z! q0 z9 N5 w; m
}
! K! i* H3 {1 m9 I2 x# s
& {6 z0 W3 Y" [, R* H
function getKey($req) 2 N8 h8 E1 ]7 L- U& }# ]
{; ?+ a! F+ N: x7 ?2 I2 t
$key = null;" c4 W% u, m: _5 m
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) { ; m& J: A: |+ U- |# }/ J9 z8 [! m
$key = $match[1]; 5 Q3 m4 i/ j! \( u( R4 o
}& \9 [1 G& G0 B% ~
return $key;
: p9 \$ t! x) a$ j9 k: u" i+ T4 y
}* n3 K# W; w3 i
; Z s. i# b) g. C( P
// 解析数据帧
( l( _- [4 b2 I( K9 y
function decode($buffer) ) h# V: |3 l0 y( l% h+ ?6 r- E
{- N5 s+ ~; g7 O# a3 y
$len = $masks = $data = $decoded = null;8 n9 S/ U' J( j+ N& U; h
$len = ord($buffer[1]) & 127;. L" l9 _# A4 i4 |6 W( D
( l8 R, m$ i& a0 q5 b7 E
if ($len === 126) {
( x& ] m* ^* ^7 B0 W& g+ W+ C# ^
$masks = substr($buffer, 4, 4);; \7 T. B3 H u( V9 Y: N- N& |
$data = substr($buffer, 8);- V" ]+ L# t9 G" L5 V1 A" E
} else if ($len === 127) {
( m' a8 U7 L2 X9 a. x8 D
$masks = substr($buffer, 10, 4);
- U. {8 H3 b, l8 C: Z5 j1 b$ k$ x
$data = substr($buffer, 14);3 o( k2 H n9 G! d4 {: U
} else {
! k" I9 y' J. s: P A1 n: R
$masks = substr($buffer, 2, 4);
; k" ?8 H) i7 N4 ~/ Y
$data = substr($buffer, 6);
, S. p8 a5 S6 s. |3 S: Y
}; f; `2 R% w9 l: F& K
for ($index = 0; $index < strlen($data); $index++) {
# @/ n, x: a7 _+ `; }; z P
$decoded .= $data[$index] ^ $masks[$index % 4];
1 e' X6 J% _+ ?( E7 g9 ~! s
}
# U# r0 l, S. H5 T& l
return $decoded;
4 T( y% V. `6 d6 H1 n
}
# }0 h! ?; C# Q- r7 R
, \1 V, n( d e( l5 A
// 返回帧信息处理
# |( c3 F1 U+ Q4 t0 @
function frame($s)
9 U$ ?( C1 k/ h: c
{. c9 _) U+ N9 z! I* e9 a/ z7 K3 d
$a = str_split($s, 125);; r) h5 k( I) h$ V, X# i* {
if (count($a) == 1) {
0 N* H c6 f9 {$ k/ t& I+ f
return "\x81" . chr(strlen($a[0])) . $a[0];
+ z4 v7 h$ Q( N$ q4 Z% }
}9 t. h f/ t! U* |( W
$ns = "";5 F& I# L3 j E0 I6 p: r7 f4 O
foreach ($a as $o) {- S% J; m$ H) Z! Z+ r! `" k% T8 A
$ns .= "\x81" . chr(strlen($o)) . $o;
' N( V3 w5 v+ o2 y1 c
}$ K7 d% W4 u. r, g' ?( O. Q. z; q
return $ns;
- `+ R* v4 p d% m1 w
}& `% M" x3 o b9 E) l
3 \5 E1 Y3 M/ X
// 返回数据
# G N) J( ~$ q
function send($client, $msg)2 A. Z5 b9 ~/ r8 a! r, S* q1 s6 F# y
{
2 U6 t: _2 n7 w6 ^
$msg = $this->frame($msg);
# o. F6 p0 J0 ~- W/ Q5 k" l2 L
socket_write($client, $msg, strlen($msg));
+ r& H- ]2 \; ]0 |5 _, Q4 [2 V
}
2 c# E' F# y- a" E* l
}
% C6 v; d# J1 I5 D8 K! k
& W1 {% }) y: h
测试 $ws = new WS("127.0.0.1",2000);2 j* P7 N* x$ V r! x2 `
1 Q& z, y3 E8 |; \! s1 o

复制代码

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

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

浏览过的版块