PHP 简单实现webSocket

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

1）客户端实现

<html>
3 G: n& P# u$ B9 n
<head>
) N0 J$ x) q0 W- [
<meta charset="UTF-8">
+ e- X- a. Z; G& Y! P! q c" p w
<title>Web sockets test</title>
" h- \; I' u/ _. o+ f. q" _; ?/ \
<script src="jquery-min.js" type="text/javascript"></script>- X5 n2 N ?6 V8 K4 b/ \
<script type="text/javascript">
4 e) W: s8 ], {
var ws;
" m% C) i6 Z$ o( l Q
function ToggleConnectionClicked() {
7 i$ W8 ~7 W; a2 ]8 A* h1 m5 q
try {
1 m) P9 T# M0 [& k& K5 t" |
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器
4 M2 B: E% O- L$ |; H/ q' n6 y
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};
0 J w, \3 V5 {* k
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};( g/ P, g& ]6 L2 U$ V% ~
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};5 P) g$ f6 v1 X; _
ws.onerror = function(event){alert("WebSocket异常！");};
- m* n0 c- F( w2 @
} catch (ex) {
L3 L# ~1 k9 x- A
alert(ex.message); 8 |' I+ S6 D: a+ C/ ~
}5 s+ ?7 [% t3 W- }
};) U/ P, L. `" t
1 j: Y- b& F- N+ ~; v# I
function SendData() {' \9 T# C5 T% P( ?2 \7 r
try{
+ Q6 m) G/ q6 b5 P2 {
var content = document.getElementById("content").value;
0 L( q$ |" R1 I1 l" s1 R( V
if(content){1 s; {6 ^6 C" |! N7 G' g3 i6 m# ~& @
ws.send(content);3 F$ b5 `: S3 n' X
}3 C& |# V& j! e$ c4 _
$ Y5 A, M+ j2 n9 A1 K' f9 `
}catch(ex){
8 U9 s8 }7 H2 O8 H) }
alert(ex.message);
, W, x9 g9 ^3 }
}: R+ N0 ~1 Q5 n; w% t' E( e7 U
};. t, u, @, Z- n) X# o0 z
; H9 s! y M1 w: J5 A
function seestate(){% M8 Z7 \% f" T0 d' @
alert(ws.readyState);* B! J- P( a+ U! i6 |6 M' Y& f
}% C- \) g% ` p/ l, M) V
( i" \( t$ @9 }# W
</script>+ z% Q+ h2 o" v1 o6 A1 X$ X
</head>0 z# {; S* m( @# k9 r
<body>7 S" s Y4 W. W% M) W7 c0 S) s) B
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />% f; u. M0 C* }2 ]
<textarea id="content" ></textarea>
+ f* P! a- _3 u* N! M
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />+ }; E& ~. a- S
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />2 ?$ S# J7 N! @
) J* R2 l) G) D1 u
</body>
6 r. E) ^2 ?0 r M- V' v
</html>+ j3 }7 D& ~' a4 g; D1 z8 ?3 `

复制代码

2）服务器端实现

class WS {1 f( U; H0 M! K. n
var $master; // 连接 server 的 client! Q- E* Q5 `0 U
var $sockets = array(); // 不同状态的 socket 管理
- Y1 `1 F. J# Y" {
var $handshake = false; // 判断是否握手+ [, P# J2 P. I$ e1 [- [. O z
- z! n5 y% Y* D' O$ U o3 ?
function __construct($address, $port){
. z: C& C# }8 \- I& }1 E* a
// 建立一个 socket 套接字
0 ~% {/ w4 f3 u' B) e$ L+ Q
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
6 |* d% p. n7 }2 W7 S" |2 j* n7 x- f
or die("socket_create() failed");
7 O2 p2 i3 W' J) u1 G1 t
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) : j: k/ J5 F% r, D: k7 g# `
or die("socket_option() failed");
: N" @- A& h0 H
socket_bind($this->master, $address, $port)
# c: ?$ K/ b: L0 r ?1 t/ p3 m2 S
or die("socket_bind() failed");
6 g) C! ]! w, L1 D9 D& u5 q
socket_listen($this->master, 2) , |% z% q9 v- t
or die("socket_listen() failed");% X9 U0 n' G2 p* {. ]+ b% c# A+ m
# h2 A6 i, E( Z' S7 V
$this->sockets[] = $this->master;
8 c- P* o6 c( E: r) J$ f* f. _
- z! w0 [6 q/ B' x7 i! f! T
// debug
' I3 Q6 f! G) a, K5 r
echo("Master socket : ".$this->master."\n");
: k$ M. `6 ]2 O! r" X
2 r: G/ v6 V2 e% C" t0 N' {
while(true) {+ `, P9 r# s- w; w# V7 h
//自动选择来消息的 socket 如果是握手自动选择主机
% p$ n% J" R% ]8 p
$write = NULL;
! B; N7 B* v: b% P2 R
$except = NULL;- S+ W2 L% F) f6 Q# Z
socket_select($this->sockets, $write, $except, NULL);
8 ]. G" w3 C' ?: I+ Z e( w( C
7 G' x0 D, Q; ~6 X1 b
foreach ($this->sockets as $socket) {
* w( b- C) \' j; T4 [0 r% {! b
//连接主机的 client 3 |1 q# ^3 a: @# L& ^/ p. D
if ($socket == $this->master){
! O5 `( X$ _7 W, a" I
$client = socket_accept($this->master);' n- D- _3 O7 Z# {- n! q
if ($client < 0) {
3 O# v+ u. e. [/ o
// debug
7 R4 C6 p/ s' T( w$ J4 n# }
echo "socket_accept() failed";
8 y3 u( d; x% m. F
continue;: ?5 t! B% S, u, T: m
} else {
; K) s4 _7 C, _5 ?2 M$ y& ?5 `" b* l
//connect($client);
- I# ]* m9 Q. j# W" V# I5 w! k8 I
array_push($this->sockets, $client);
9 Q9 {& a5 B n- u8 @, q
echo "connect client\n";
) K2 b& L4 d& [' g1 K
}: t& y/ D$ y I( F
} else {
% l0 O1 k9 ]# | r) |) Q
$bytes = @socket_recv($socket,$buffer,2048,0);5 ^0 T& K2 N: z! T
print_r($buffer);, C$ U2 _! ]! M$ w" s) t: R$ F
if($bytes == 0) return;! q4 K9 G5 c a5 c' M5 P4 x
if (!$this->handshake) {2 k0 S& w/ Z2 G/ d7 v! p2 [" f$ |* N# d. Y
// 如果没有握手，先握手回应
5 A0 v- x) s$ _3 A1 J' Y3 o7 d
$this->doHandShake($socket, $buffer);) P( V7 T( V: k
echo "shakeHands\n";
% m0 ?6 Z( v' S
} else {
/ B: h: `. w: k: ]. L; k
" z) w% l5 L+ @- O) g% Q
// 如果已经握手，直接接受数据，并处理6 i2 K0 u( m/ y3 _
$buffer = $this->decode($buffer);
5 Z7 S2 Z2 I/ w' i% e' |( k# E5 D6 e
//process($socket, $buffer);
: F% `, f/ g! u9 z; q
echo "send file\n";
# [# A4 W0 [, f8 F0 ?
}3 {& a2 q, t% G6 x, a; @, v
}
" B& O/ q2 |- ]: I1 O; d# f1 O1 u+ \
}
8 L4 P5 o0 e8 N. w$ q5 L, [
}
7 a9 S. x2 F& G
}; @+ M6 }! I8 u3 J/ |4 ^/ P, V
0 k: V8 b# K5 b+ L4 Y
function dohandshake($socket, $req)9 {1 T0 [* G: ]/ M8 @' K: Y
{
' P6 E7 ]6 @' ?* q% `+ |" Q, G* c
// 获取加密key
+ {7 h& N4 D6 E9 m* Y( E
$acceptKey = $this->encry($req);
r7 p1 u, Z1 L" w, y+ m5 _
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .6 ~9 d4 ], n! U! ]5 V1 X6 b
"Upgrade: websocket\r\n" .; K1 z% o- I$ I S4 |5 a
"Connection: Upgrade\r\n" .% O& }2 R) c& \9 R. k/ o( R
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .. d& ]6 d1 _' E# I( X
"\r\n";
2 M" B2 ^7 y9 ]6 P& z
; q9 V# J! ]0 o5 }7 |' ?
echo "dohandshake ".$upgrade.chr(0); , d$ @- H" y" G i1 q1 ~
// 写入socket8 r C/ T0 ~$ L7 q9 W
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));" G! d2 X; U; o7 S$ L
// 标记握手已经成功，下次接受数据采用数据帧格式
/ b# h/ E- u0 v
$this->handshake = true;
1 c* y* a0 s' m' d7 i0 B- F. v
}5 t9 T. d4 _0 X
! z7 H& q' R7 E4 W8 _
' C+ D$ X/ H6 H4 `* S
function encry($req)1 ]: v+ r( g$ b3 I4 H& o; l/ e
{
6 G: N8 C6 T5 @+ m, J" }
$key = $this->getKey($req);, U+ Q2 m. U: ^+ j! j1 L
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";# }" ~3 R& q# w7 [7 s3 v
8 V+ a# i, p+ ~" e5 ^. G
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
" G1 v$ @. g8 D) i2 n8 [! {
}
2 a! b |: }# d$ N. E7 w: ^
) X3 U# K w5 x: }
function getKey($req)
/ G* U% c x% \6 b8 E: e. O
{4 s+ }8 ^7 i; a' _ H+ c
$key = null;
# F6 g6 i$ L B/ }; P+ ]
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) { 1 P) {8 w3 D4 c Y
$key = $match[1]; 8 |, O) E# X2 _ o2 |+ Q
}0 z* {2 J0 K' X' F# f2 G0 e
return $key;
6 o+ j& P( a4 w8 g
}
+ D: B2 D/ f9 R: Y% m/ p. k
2 g1 @" ?9 y1 A: N8 _2 V6 k1 n
// 解析数据帧/ k' S% J3 }( o
function decode($buffer)
9 A# O7 O$ ~. d2 u4 K
{
) i x0 x7 o7 }8 r& `
$len = $masks = $data = $decoded = null;( r, S% s- R$ i8 y1 }' `
$len = ord($buffer[1]) & 127;
8 S. c% o% {) d% Q& j
8 @, H- |9 M: ]$ e& m
if ($len === 126) {
" M# E8 l2 t% N2 D6 f) K* n
$masks = substr($buffer, 4, 4);
# n0 d4 O% H$ M/ K9 v
$data = substr($buffer, 8);: H& \1 k( M1 _& M) F/ m
} else if ($len === 127) {
9 A2 n" O: R- I2 n1 d% }; Q
$masks = substr($buffer, 10, 4);% {1 I+ `+ }: g
$data = substr($buffer, 14);7 Q# }/ }" e% E' b
} else {8 k. a/ t& [' v% u. f' i
$masks = substr($buffer, 2, 4);0 d- }' D, R( g/ f! j/ I
$data = substr($buffer, 6);
8 F) d# S& x) c7 \' X, p$ x2 q
}
" p# O9 l5 o* M: F5 }3 W1 ^
for ($index = 0; $index < strlen($data); $index++) {
1 n& @: e3 t& D+ ?- N
$decoded .= $data[$index] ^ $masks[$index % 4];$ n' s& V' r. } |5 m
}
1 G1 ]; J# t. Z0 L
return $decoded;( D$ e+ C/ Z5 i
}
( {% b! U' P( b" M/ M
% @* w. ]( V5 S. N# J3 u
// 返回帧信息处理& b2 _1 V4 x6 B2 s7 ^& X0 Y% K$ }- T
function frame($s) . E2 C5 [! @0 E: v- H
{# `# l. n- q! ~ H3 W+ m& k6 u
$a = str_split($s, 125);
" y, \/ }2 ^. Q+ ~( x2 M( i
if (count($a) == 1) {$ K% R* Q5 H* v: U' U r- X/ M
return "\x81" . chr(strlen($a[0])) . $a[0];+ H5 T9 p4 P: [/ g. M: K0 p+ N! W( C+ M+ u
}
# b8 z* |6 b6 R
$ns = "";
}5 f/ C8 m( M( |, b
foreach ($a as $o) {
- V/ E) i1 q* H6 j+ @
$ns .= "\x81" . chr(strlen($o)) . $o;1 V+ b/ M1 k4 _7 H/ A: S3 l
}& J7 F+ f9 S* R5 k
return $ns;
. t! [5 J3 p9 p5 T; W; j
}
7 p# q6 x% E# o' u
/ c; ^3 X, {3 n/ P: ^7 i
// 返回数据: P# s2 b/ t# o$ {* I
function send($client, $msg)( r4 s: A r' h
{
' U, A! X; T: [7 u& q' r
$msg = $this->frame($msg);
. B, L4 @# Q( _5 N
socket_write($client, $msg, strlen($msg)); K$ T I9 {( r2 V) w
}
2 K# s- x; D7 z- }7 m
}
3 R# r* w+ ~7 }& r, I& m, ^
6 d% u% U! Z B6 E. \$ f* W
测试 $ws = new WS("127.0.0.1",2000);! h2 }# B7 w9 S/ |; h, X# K1 w
4 ?# a4 D }: P+ P0 E

复制代码

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

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