PHP 简单实现webSocket

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

1）客户端实现

<html>
7 X. x% D7 `' L
<head>6 [. E1 F f; s: T! L
<meta charset="UTF-8">
* z+ m! j J! ^% z& W
<title>Web sockets test</title>% D& R* z5 X' @ ?2 ~ x3 s; |
<script src="jquery-min.js" type="text/javascript"></script>
5 x3 S, i. u7 J0 {$ e; s$ K6 p
<script type="text/javascript">
. c( K( d4 A7 C5 H" O- G
var ws;; d0 E/ |) d1 T( j- n' T- q
function ToggleConnectionClicked() { 9 j! b, T, J1 u9 y2 h0 ]
try {7 ?4 T- P4 ^4 H1 N0 A' d" k
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器 - L( b- `5 H8 h
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};
9 M/ P" v |( `; w
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};! D4 F$ }3 m+ q! T+ F+ D3 E5 M
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};3 E( a8 U5 f* v# ?; }* A! G5 C
ws.onerror = function(event){alert("WebSocket异常！");};
$ I- } ^5 x0 P5 Z
} catch (ex) {. ^0 f2 J5 h/ `0 q4 R) b3 C E7 u
alert(ex.message); 0 w* _# h8 L! q. U4 h3 L& ?9 N% z
}" r: j+ \4 L8 X! y l
};& Z' l0 a4 G) p8 B8 J. X
; S6 W0 |' |: A4 @6 P
function SendData() {2 k5 G+ D: u* V0 t, s4 U- s
try{9 s( [( k) X+ ?, K/ X1 H( [
var content = document.getElementById("content").value;
" u& g/ k; y8 l- M) q
if(content){2 y1 B7 g, B( ^0 o4 |! H$ }
ws.send(content);4 }$ T: z, F5 w' L9 }3 t' w
}
% j/ ?# ~- ]: E7 h0 j
! T0 b! e7 Y7 _
}catch(ex){# k9 b7 \4 v7 z% V) V3 m( _
alert(ex.message);1 o) u( Q% G8 \ D
}! F. C$ J( x2 h/ R8 T3 @
};) o3 R# l1 H3 F, R
3 L2 F+ ?5 p2 y, d- S( T' O% O
function seestate(){
% P R! o# H* y
alert(ws.readyState);0 j, e0 E$ e% D2 t# F" A
}- H w' A1 Y9 z9 C o
4 {) j0 Q8 ?' }. F' }: n
</script>
: H* d0 N' h5 g9 V) O3 o$ Z
</head>
9 H1 G$ y W5 M) o3 M. B t# o
<body>& `, Q. L" A" c" J6 i: A
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />7 _( F! f3 M: J/ n# D' U8 Q, I
<textarea id="content" ></textarea>1 e1 o8 I0 A! O/ i
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />
0 x, n& u; |" g) H e2 Y. Y) K; `/ f
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />
?0 H" `5 ^0 g, @: e
% j @8 p* C8 O( T
</body>
$ a& [: @3 u3 `2 [: C5 \
</html>
( |6 i) c5 P4 B, [

复制代码

2）服务器端实现

class WS {
0 b% `0 U! @1 t$ O. j9 _
var $master; // 连接 server 的 client
1 \& b. C. N7 L4 S% d, X; P
var $sockets = array(); // 不同状态的 socket 管理
; o( r4 c8 _8 `' R T
var $handshake = false; // 判断是否握手6 D$ E" d4 [' I+ K& h
+ U4 i+ h' y7 y+ d
function __construct($address, $port){
; o! `! L6 i- `0 c7 \- X4 J
// 建立一个 socket 套接字
9 T. ~' l* F+ m& w0 z3 R/ a% [
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
& {1 o9 j/ X' i6 d1 c- a
or die("socket_create() failed");
3 y: o# f# D. } _* z, Y) r
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) 3 k! r8 J% f; F# `% ?( g2 _! J
or die("socket_option() failed");5 i- f: M& m9 O
socket_bind($this->master, $address, $port) ) v0 c7 l" M9 O) H$ E( P+ G
or die("socket_bind() failed");0 t+ o4 l( P+ n3 D
socket_listen($this->master, 2)
" X6 n- `" ?* D
or die("socket_listen() failed");
, g: N; p0 E& O/ W9 E7 i D [
9 P7 F/ Q0 P/ J* t9 `2 V* F; S/ o
$this->sockets[] = $this->master;, D0 |" @+ B+ ?0 K8 q: ~0 m
! U* L1 m# ~- t. b' [
// debug
# q& s. Y3 F6 J% ?
echo("Master socket : ".$this->master."\n");- C1 B; [! q/ @
( ~6 R& q% l" J# ?8 s N
while(true) {
% t- |' W: G$ y; M( p
//自动选择来消息的 socket 如果是握手自动选择主机5 r) I2 J& t- D8 C
$write = NULL;8 |( u' J: z+ x8 [, m
$except = NULL;& |7 _. Z/ I. ?. ^: K1 Y8 n5 d
socket_select($this->sockets, $write, $except, NULL);
2 P; k) d) B+ y2 ~% B) p
4 _! w! T3 |* w
foreach ($this->sockets as $socket) {! r6 l6 l9 \$ E9 f# V# Z1 V8 A! G
//连接主机的 client # o! W2 q; p& ^# }
if ($socket == $this->master){9 q- c/ b: F W0 {9 O% U
$client = socket_accept($this->master);* F$ ~$ b3 O7 g* R4 H7 }% K% m3 y
if ($client < 0) {$ q/ ?' `' k6 D9 \' F. ~
// debug, z8 G- e. ?+ e% h
echo "socket_accept() failed";
2 _/ I( l6 w1 m' I. Q, ]: p4 K
continue;( O9 x0 E' O1 h* E, o& M
} else {
% _ R% _" M; z8 u* d% |
//connect($client);. n3 s6 w. k J- W/ U2 X
array_push($this->sockets, $client);
; B5 b+ v6 p% |) V5 y% f4 y/ x
echo "connect client\n"; r+ r+ v& }: s6 z- J! Q; F" g
}
/ D" @! H# x3 g9 t. A) d5 J @& H
} else {: { t' {' B( a6 H
$bytes = @socket_recv($socket,$buffer,2048,0);
6 G: [8 f3 i1 u
print_r($buffer);& n M$ E( f8 G5 `8 t2 @8 ]9 M& W
if($bytes == 0) return;8 b2 X4 \7 n0 m) h
if (!$this->handshake) {
0 t& x3 x) c+ e8 F: [
// 如果没有握手，先握手回应6 ~- v4 Q8 z$ y! e- x
$this->doHandShake($socket, $buffer);" ]# {9 _6 v+ U; R$ i
echo "shakeHands\n";
- N/ m0 O. W7 J
} else {3 G4 o6 Z+ \" O8 E
# Q/ P' ~( [- T0 e! Z3 Y
// 如果已经握手，直接接受数据，并处理
: h6 @0 _, R1 m, c R
$buffer = $this->decode($buffer);
; E. I" N& `# l8 G' ~5 t S
//process($socket, $buffer); 9 v1 G, `5 I) o' U) Q: U4 C/ V
echo "send file\n";. `5 @5 [$ L1 B6 @6 i( J9 ~. |3 ?
}
; Z/ k/ h' ]% s
}
8 x; o( Y0 e* ]# {0 j7 H" m
}
# L- t4 X Z1 K! g$ x9 X2 K. d4 d
}
' W: `+ P& o. ~8 F1 O( t! W0 ~
}4 p, v( a3 ?. }$ B! d4 n5 r$ p# S
: P$ M8 c6 l6 q! f4 q
function dohandshake($socket, $req)7 w3 ?: s6 d. [, H& p" V
{
* `8 z& z2 Z* @1 u
// 获取加密key" q4 ]( B! _) C& m8 o3 x9 x
$acceptKey = $this->encry($req);
, m# L3 c2 }- u
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .
- z( L3 ~* J2 J9 I. d- R
"Upgrade: websocket\r\n" .
) d! J" ?( m1 K( r% c; P
"Connection: Upgrade\r\n" .
, c/ o4 [& L4 b- N& q
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .! U3 O: _6 h7 U0 ]7 f8 C& ~
"\r\n";# M9 f/ p! O" Y% z4 ?: M# G. ^
! f" y$ |- ~2 l a( C
echo "dohandshake ".$upgrade.chr(0);
+ [3 l6 C# c# J3 K( |4 }3 [
// 写入socket
/ _8 H0 V$ o2 @8 [- D5 f+ ?* H
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));: Z7 P$ q8 J, q0 M0 m
// 标记握手已经成功，下次接受数据采用数据帧格式
$ v0 Z; k) R, }# |
$this->handshake = true;
6 z- e) g" c1 r2 P' B0 o
}9 W& h3 ^+ w M/ O6 B. }# ]
T- }- `1 c$ W4 S, D$ X# X" m
- u6 |& y7 W9 g9 E# N5 z- |
function encry($req)0 a8 X7 {. y/ }( T* k0 @# s5 B7 K6 I
{
% \( U/ B: P. `5 {/ d4 ]9 ^: [
$key = $this->getKey($req);3 r1 B% h$ i; W; n/ K
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
" v" G! s2 s. E! f! e% m& ^
. K- G: g, S j: V" A: \
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));6 ?/ @& Z/ {7 ]* ~+ \" O8 `6 w6 t
}+ F! |" F9 e+ P) |
9 ]( g& l" @% g2 s4 P. T
function getKey($req) 0 w/ j3 X$ J7 p' v. u4 h( W v& s
{
* M0 I( H) J* F1 d% f
$key = null;0 T0 ? G. M' V. Q0 C/ ?+ w7 b
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) { ' e% d( [- F& }% r
$key = $match[1];
6 v' _$ E) ^9 w% }2 f2 Q$ L, w6 |
}
: F, n O0 f- O2 p7 j- p
return $key;" c9 _; w$ |& i G5 u$ I
}, ] C7 x9 i' j1 u
8 n/ ?5 p6 S; {8 w& ^
// 解析数据帧
+ c( _* Q$ H+ J/ T
function decode($buffer) 4 ~8 S. c) F! \
{1 s% `- M, j$ F: @3 c8 K! `
$len = $masks = $data = $decoded = null;
) h# w( \6 ~% D! Z& q
$len = ord($buffer[1]) & 127;
5 U7 l4 E1 [) c- A/ |7 x
2 Z; A" p3 T5 ~& W8 T; `
if ($len === 126) {
! V5 O+ _ P9 F
$masks = substr($buffer, 4, 4);
t% ~7 x+ s! i$ `& `
$data = substr($buffer, 8);
( I; Q- A0 o* m( r; _& {& X
} else if ($len === 127) {
7 l3 ~* Q3 g6 X4 b8 E
$masks = substr($buffer, 10, 4);* X) {# q" K0 h6 Y Y5 q
$data = substr($buffer, 14);
3 B% j& O. F) N! { o$ }0 {
} else {1 I! e1 ^: h& K! I
$masks = substr($buffer, 2, 4);( A; g3 @5 d9 t7 c
$data = substr($buffer, 6);
1 Z) V( d+ r& X
}. u$ i6 h4 J+ w7 A( L% |
for ($index = 0; $index < strlen($data); $index++) {/ u8 f, `" }+ \9 E
$decoded .= $data[$index] ^ $masks[$index % 4];
: x; U6 ^: U8 R; B. s; ?5 i4 d
}
2 Z+ T( |5 L: V# z
return $decoded;& c0 `$ u P8 {) n y. j1 U
}5 [8 R k1 j/ x7 ^7 ^, M/ |) e
4 }$ q8 u% M" L' O% }
// 返回帧信息处理
% b L$ I7 S/ h
function frame($s) & L0 q* D- o# d, X/ ]9 l
{
3 x' h% S# [0 h# l
$a = str_split($s, 125);
& @- k1 \+ H- [3 }( c' u" U. M
if (count($a) == 1) {' a s1 k" Z, X P
return "\x81" . chr(strlen($a[0])) . $a[0];
+ ^/ H6 p- }! k' \
}
0 m" h( Z" A& S; a2 @9 [
$ns = "";: p8 A) z$ o0 y! A& ]. O
foreach ($a as $o) {
7 q0 C1 L- V/ h" |- n. Q5 ]5 E+ L7 ]
$ns .= "\x81" . chr(strlen($o)) . $o;# Y4 l' V6 e. T' m$ H& D o1 f
}
( x5 p% `( t Z. g& B9 }
return $ns;
; p2 z: P }1 a, O* A5 R0 O+ G
}5 \' ]2 Q1 U0 V9 X7 [
2 N5 i% j1 R* Q W( r
// 返回数据
; e( u. s v& K* y* R
function send($client, $msg)
; Z. S6 G' ^, t. L# G
{
. U* [7 F; W% w, V
$msg = $this->frame($msg);
# L0 C7 E4 d) b
socket_write($client, $msg, strlen($msg));
{( i( V3 S& c. y; k: o5 F' J, O
}
* d+ b4 @6 g1 a5 |0 i
} e: Y! ~, P$ D5 x/ j
# x/ }! P5 D* W8 V( v
测试 $ws = new WS("127.0.0.1",2000);
3 K& h' f* L" `: D$ h5 v ~. K
) l: ~$ _) V# P$ r2 ?2 f- m

复制代码

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

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

浏览过的版块