PHP 简单实现webSocket

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

1）客户端实现

<html>
' t5 k8 x: G; B
<head>
9 z1 i Z h) @: z- j3 y
<meta charset="UTF-8">3 }; P% I7 `/ z9 \& ?. e$ F! N
<title>Web sockets test</title>
0 k. |1 g7 T J( M/ a, u) ]
<script src="jquery-min.js" type="text/javascript"></script>( E8 @7 e; B; E! |" ]6 Y
<script type="text/javascript">1 n* X1 l" }$ B: n( U/ y& M
var ws;, F% K! W& j0 V. m* N3 g% Y
function ToggleConnectionClicked() { # }9 p$ s' ]) w3 F6 n8 ]
try {
0 I5 b, ?3 U! R
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器 " a0 [0 d# G7 W) R
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};! D# Z* t% t9 X: k# K
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};; r# r$ O! Q8 Q) X& Y6 u2 w0 I( q
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};
+ C' }% {& f% w+ _0 H6 `, C
ws.onerror = function(event){alert("WebSocket异常！");};
3 Q1 y# M( U- R4 [9 L
} catch (ex) {) q( V, J' f4 B, k4 O/ t
alert(ex.message); 2 V; F* b O" h+ T) D
}
" k/ v, c2 y0 m3 F, B$ s6 N% h
};
3 Q$ E+ J8 r! m' m7 l
" o p/ H! K M
function SendData() {
3 ]" q1 g' Y" ^ Q3 ^. n
try{8 S, y# V1 `2 a! d# o: s
var content = document.getElementById("content").value;, f ]/ ~5 C7 B6 I( h) |
if(content){
/ @8 `* `2 L B' K& |: t
ws.send(content);
& b1 G8 C/ @; I
}
/ x' J$ v7 G ]) _ t
9 s* z1 j9 ?& O
}catch(ex){( K1 ^1 r" V5 E7 u
alert(ex.message);6 Q, L" R& m, S
}
: w$ g9 |9 E' C) j( a8 D% i: f
};
6 d, p% i% z4 j* |1 M9 V6 g; N2 s4 X1 Z
9 r* }# X: s, d. X# q$ G: Y
function seestate(){, |3 k3 u% r1 P6 q
alert(ws.readyState); C. O a; w0 M0 R |
}
! k# x% K0 D; y5 s0 C
* ?* d- ]4 Z$ k0 c
</script>! t! Q, ^4 H5 L5 m! Z
</head>
- [4 g+ ~6 p2 ?3 M* g3 Y% E! ?$ f
<body>
. Q; m5 J' M7 r, o
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />
4 q1 B" |, |: Z5 [& _# O
<textarea id="content" ></textarea>
$ d4 |& X' a3 [/ K) k
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />: _4 C* \3 I% D7 I, G5 b) t) ^
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />! x4 ~ |" O0 v3 T$ i
. U# s' N8 V. r
</body>
- Y1 A. N- R3 W y1 ?
</html>
3 g4 J7 f; _7 a; t! p

复制代码

2）服务器端实现

class WS {4 C) t. o. Z: F" A3 p# Y. @: D9 i
var $master; // 连接 server 的 client
, @' f- h' e# _; f7 B9 a
var $sockets = array(); // 不同状态的 socket 管理$ W* m! y9 _; V- q) G. Z8 m
var $handshake = false; // 判断是否握手
1 |, h6 {1 U8 S( B- c
% ], R- u) }! S- t0 z. X; B
function __construct($address, $port){
; s4 i1 @% \9 D. {* ]
// 建立一个 socket 套接字
4 t7 }0 n" d, {5 V5 K; ^5 m& Z
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) $ `- T( _# [* u, T
or die("socket_create() failed");8 s: r- j( j" i' a* ?
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) 8 l9 H" F; w& ^6 v V" R+ O% o8 P) Q
or die("socket_option() failed");0 F6 @! `7 J4 G4 \3 N
socket_bind($this->master, $address, $port) ]- U7 F* \ c6 G$ P- T* l3 E% y
or die("socket_bind() failed");- \ S& u" Z! _. Q* V& U
socket_listen($this->master, 2)
4 ^; E' h& Y! C0 S' P
or die("socket_listen() failed");
* g9 }$ ?# [% I9 Z' m2 V# k
# Q$ x4 Q `6 ?6 E" A0 |
$this->sockets[] = $this->master;
3 { a! F3 a8 [1 b4 A" j, H9 F/ A2 i
. O2 M0 F/ n3 S/ s% \
// debug
1 y/ o5 S2 |8 [9 ^2 r
echo("Master socket : ".$this->master."\n"); Y- ^* E$ w% N! D0 u( Y: t/ k
- c5 k3 S; N5 @
while(true) {
- Y/ J- f% r" H3 j9 J
//自动选择来消息的 socket 如果是握手自动选择主机4 B: a9 d" a% H T; C* X
$write = NULL;
3 g6 N( P1 R( I0 ]
$except = NULL;( h: P9 B% ]; k( Q: _
socket_select($this->sockets, $write, $except, NULL);9 _ m$ M4 }7 P* U
# i- U) Z+ _- {! A2 U
foreach ($this->sockets as $socket) {
* ~; c7 h7 n/ t5 F1 n2 n8 N" ?2 f
//连接主机的 client $ M: Q# {) X6 i9 B+ ~
if ($socket == $this->master){ d) a6 ^4 ~8 `! W) H5 Y) d
$client = socket_accept($this->master);. l0 Y2 a- Y% Y, r a% p) K9 ^
if ($client < 0) {+ @- g4 X- _9 A6 c: J9 X
// debug2 q' ]8 |5 V: k5 c
echo "socket_accept() failed";
- Z5 @% i1 x) d6 @$ {
continue;
. v( W' L8 ?6 ]0 P2 z2 e
} else {
6 {5 H% I ]# H& z5 o5 Y% ^" j4 a
//connect($client);2 q! M: O1 H- D d
array_push($this->sockets, $client);
8 [! ?$ X, G9 J8 X1 Z& y. q
echo "connect client\n";: m, p3 X. g. C% r. z
}5 n d- I2 ~# i. P. H
} else {
/ n. {1 }* t3 O( }: b k
$bytes = @socket_recv($socket,$buffer,2048,0);
* c9 |0 u% u9 G: P* ? I
print_r($buffer);" g# S( }9 W9 O
if($bytes == 0) return;% t$ ^" ~0 F4 \+ @' g4 b, o9 O6 y
if (!$this->handshake) {5 W& Y" o/ ~7 d, g0 S3 t& ^. z! w
// 如果没有握手，先握手回应3 G, n6 V% b$ g% }+ i7 d
$this->doHandShake($socket, $buffer);
4 j4 }8 c# ^' S
echo "shakeHands\n";
$ P" L' D. G/ {
} else {/ F7 @8 N) h& x
% t3 R2 N9 [# c5 X
// 如果已经握手，直接接受数据，并处理4 O$ [1 f% U9 e+ [3 A0 C7 j
$buffer = $this->decode($buffer); D$ x4 D! u0 q2 P: o/ N9 U( t
//process($socket, $buffer); 3 f4 Y: O5 X" O; M0 l7 V
echo "send file\n";# i. W- } r( N
} C+ R7 l- \" T4 q* i Q9 M0 H
}6 E, `0 d! x/ [0 N9 i
}% }2 V7 X/ z M4 g5 L$ v! w) V
}
, ^0 A" x' t4 n& g6 N. F D' \
}
" A% ?" P6 |* U+ J
$ }, s& t; ^0 v5 b4 }5 Q* R; g
function dohandshake($socket, $req)% H; R/ p4 Z( ]3 ~5 [
{
; ~5 z7 B; k8 h. N6 m& P
// 获取加密key( A% K5 V& O' Z; ^
$acceptKey = $this->encry($req);
% \' n* R+ N8 h1 e9 F0 f: f& K2 p
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .* g% R* G0 v0 U: D
"Upgrade: websocket\r\n" .2 ^/ ]5 x, e' X4 i p. l
"Connection: Upgrade\r\n" .
5 X" o0 ] t& b. A; m& G" p
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .
, m0 L4 M* Y5 g; [7 P
"\r\n";
' z3 z! h* J i F- z
' `; p- @' Z" _
echo "dohandshake ".$upgrade.chr(0); 1 {/ x: w2 z @ t
// 写入socket
, W6 H% m0 h7 A5 {) e8 S5 k E K
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));9 W( n/ K3 N, E4 m1 F) h
// 标记握手已经成功，下次接受数据采用数据帧格式
3 O$ \9 t# Z3 J, _) i
$this->handshake = true;, O2 T) v% D7 O) F4 D
}
' }- D* r: ]5 N5 V
3 G' w3 {) j7 F3 Z
+ M; G' b" F$ ]. S( \! L
function encry($req)
* ~) ~- X h5 P/ `
{+ y" `# r+ y- g
$key = $this->getKey($req);1 P M5 B9 b) ?- m+ R/ c' F
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
4 X6 B5 ~4 ]: M3 c' Y: {; U
$ Y+ f# {+ i" F6 F
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));) m% {6 r6 S; m6 ]
}
& i: ~. _, j9 c
$ m; X0 N2 ^! M. F
function getKey($req) ( L0 A' J# a* f, w6 \2 _4 M
{/ x+ Q2 z( T, u8 K8 Y; X7 [
$key = null;% u4 S0 O9 k9 U5 P6 V
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) {
) {9 U5 Y, }3 |( P/ Y
$key = $match[1];
' q$ @5 O/ n' ]* W
}' l0 r( n B L
return $key;* U" z4 U! X% \+ |
}4 |* P- W4 p3 |* \) `- ?. B6 j
7 M* c, S) E8 i! A
// 解析数据帧
4 T( d8 q+ B( l- R
function decode($buffer) ( h7 g" u4 P. o! s6 h
{+ h. z3 t& w4 ]! e
$len = $masks = $data = $decoded = null;! i8 J3 W* G+ d5 E; A
$len = ord($buffer[1]) & 127;
( p# z5 z/ G* B8 s' ?9 \
: R8 P" a6 |( d' V) H
if ($len === 126) {5 j3 \0 q% ]9 y; F5 i- n# n, S
$masks = substr($buffer, 4, 4);
; `# T8 w8 ]6 s3 c4 s
$data = substr($buffer, 8);
8 H3 b. [4 @7 u/ ~
} else if ($len === 127) {% e; m1 ?5 y! J: D. g
$masks = substr($buffer, 10, 4);
T, f' K1 M9 G: F$ I2 D. A
$data = substr($buffer, 14); x" I3 d f6 W; }0 I
} else {0 s! Y& ^0 u2 ^) J$ K0 Z
$masks = substr($buffer, 2, 4);8 W7 p D! s8 {% q$ F
$data = substr($buffer, 6);5 A3 l5 A1 i% n# k) B
}. L# J4 l& r3 ^
for ($index = 0; $index < strlen($data); $index++) {
6 c' l) |. U2 b& ]
$decoded .= $data[$index] ^ $masks[$index % 4]; x7 E* E/ _! z! A3 U" N# {/ R1 k
}
! Q# \8 t5 s" Q B/ `- m
return $decoded;
}4 V' g* y) k2 m& h* k& I5 C4 v6 |- w
* M, F H/ T; f% |7 @; s3 q3 j
// 返回帧信息处理) Q4 j* u) Q9 |) b) i
function frame($s) + p% A1 @# u2 J/ y- F
{0 x& {6 o3 [0 m( b
$a = str_split($s, 125);2 i$ b+ S, F! p1 E
if (count($a) == 1) {; G8 A# Q/ f/ U& w' w. {
return "\x81" . chr(strlen($a[0])) . $a[0];: V) w3 e p$ {/ _
}
h* Q6 }& J# F# f+ A0 s3 a/ v
$ns = "";2 n( p2 G% F% [, q
foreach ($a as $o) {( f# u& ?& t5 M$ u
$ns .= "\x81" . chr(strlen($o)) . $o;
3 m! p' ?5 ^$ U3 v6 f$ W) d
}& X# G* y6 V4 K; {0 }0 d9 }9 e
return $ns;
" m7 t @8 `0 M) T/ u: @
}7 c! |) A5 H) p2 q. R
( S; d6 `: ?( `* t& T$ V
// 返回数据
, P0 \0 z" @" N% X) `0 f! M
function send($client, $msg)
# t$ Q, R* D( O9 l" Q5 ~( W
{
6 N3 t2 Q; z- F9 ~
$msg = $this->frame($msg);
! {4 e# w" | s9 U S
socket_write($client, $msg, strlen($msg));4 `7 f: f/ r) \1 S- H; Z2 n; R
}2 S/ O7 [, ~: V+ G% a: d# e4 S+ C
}
9 Q5 o# v" I* a% j) V
: C, L0 P+ X. y; o `# h
测试 $ws = new WS("127.0.0.1",2000);& ^3 u$ s( r+ v( e$ h8 @+ Y
4 L2 V0 o( [9 {

复制代码

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

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