PHP 简单实现webSocket

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

1）客户端实现

<html>
5 V( m% F2 b4 T2 x
<head>9 o0 J/ h- k; g" @/ q# g
<meta charset="UTF-8">: K) O; ^* G6 v
<title>Web sockets test</title>* X V/ r' @3 L
<script src="jquery-min.js" type="text/javascript"></script>
) y2 v2 `0 w: {( s g$ I
<script type="text/javascript">1 T7 l8 f) k3 X: v2 u h, d
var ws;
% E, ]- Q8 ^, Q# b+ h6 [' v/ t
function ToggleConnectionClicked() { & P: y6 j# e m7 v+ i
try {5 Q! e Y3 s1 a
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器
+ x& B( t0 s- V3 Z/ B
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};6 S/ {/ c' t% d) l4 `( ?
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};
# }% W) f$ O, t, A( H F. s2 i
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};
4 C- x+ `$ t1 Q2 C
ws.onerror = function(event){alert("WebSocket异常！");};
`: m) X6 E0 G$ ?
} catch (ex) {
8 ?7 k5 M# w* I0 o) a2 Q7 p
alert(ex.message);
; l6 }) U% ]$ I1 |4 B {4 I8 e
}
5 C- b# B: J) z$ h0 N. ~$ |
};1 o% A5 y9 W6 W- y4 u% A
3 S w5 O. h3 L4 N7 t1 m( B% Y, y% h
function SendData() {
3 S, o g9 a6 y& _. r$ v& [3 d
try{% `& Q. U1 n& R2 K+ B
var content = document.getElementById("content").value;$ c) u9 B4 v( J8 _4 J9 P3 |/ o* l
if(content){
0 i. ]0 V" W) d
ws.send(content);
( }& n0 O+ O1 p: q8 c
}
: a% m1 V3 J8 b8 o8 {
" X1 X0 g2 M: X2 }, M. a
}catch(ex){ _/ l1 n9 w7 W$ ]0 _; ^
alert(ex.message);
- ~0 _1 J- h$ s" K1 K+ R$ }
}/ j+ D& X" r4 X' Z) u9 }/ H
};
; K% {; g0 N9 L
$ l& U1 u2 h3 m- }$ b5 R/ ^ N
function seestate(){' Q5 M1 n# Y7 p$ l+ m& g) U
alert(ws.readyState);( E# ~/ S# ^2 R: x, v! ^1 B! y; T
}+ H& d/ H! e8 K3 P; q7 M
; p9 [$ W0 b: B" k1 r1 B
</script>, {0 F1 y* u n$ B8 H- V6 g
</head>3 e" i. J5 ?4 [3 x; k
<body>
" ~3 I. E o' C4 `
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />% ], r% g$ g: E9 O
<textarea id="content" ></textarea>
- m/ X3 w; C) `# Q& V
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />. G6 s, N( n- Y3 @2 V' L& S
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />
i% l, M1 w$ c" `/ P2 ~- v9 d
* c5 m7 [5 `, I& k. P0 c# [. r
</body>( I& U+ ~$ J% V( g# x* G) Y- M/ E
</html>
4 l- k+ Z' I" J5 m% g. y% D1 K

复制代码

2）服务器端实现

class WS {
5 j: y# Q E- C2 h9 q0 z1 C5 V
var $master; // 连接 server 的 client2 m$ U8 _ Z8 J
var $sockets = array(); // 不同状态的 socket 管理
5 v @. e$ u, f4 c
var $handshake = false; // 判断是否握手7 ^% V' e# L: N6 K$ ?- U% O
" u3 }6 j( | P2 R: M
function __construct($address, $port){
$ p) x! s) U g9 z1 U7 E C& q
// 建立一个 socket 套接字
! f" d0 F* ~5 o# @9 n; l1 v
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
4 R& ]% r5 I0 s
or die("socket_create() failed");
1 [' P C. m: R+ m7 Q6 L* x |$ @
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) % ]9 n* Y0 x, L
or die("socket_option() failed");* w" S4 @4 e4 `* m
socket_bind($this->master, $address, $port)
; b; r0 @8 P) U. [
or die("socket_bind() failed");
- c2 S# V4 V) ]) O% |& C% f
socket_listen($this->master, 2) ; M) c7 v% `) d3 j, e0 W+ K& w
or die("socket_listen() failed");
" D3 R0 ~- Q% L$ H' ~8 w6 A
6 c, }: x. r) L( _0 I- X: d/ H7 f
$this->sockets[] = $this->master;
4 o( R& G( v- F- ` u
9 Z8 m4 i, `' U
// debug- L' Q1 v; b% a9 Q& u1 `. t
echo("Master socket : ".$this->master."\n");& {& S8 h7 x( \# n" `
% o) {9 s7 D( d0 q& _8 V% @
while(true) {
4 W( L! p1 s! c2 V) g1 r6 D
//自动选择来消息的 socket 如果是握手自动选择主机3 f; L4 |4 b1 c/ x: j
$write = NULL;/ T% i% }2 d% C! x. q' T7 X4 L2 `7 l( O
$except = NULL;
; g/ T% i5 _2 G8 M
socket_select($this->sockets, $write, $except, NULL);. d& F$ ]4 @, o! T- e6 a8 d
& R; d& o x8 M) N0 ^5 x
foreach ($this->sockets as $socket) {
0 `5 v" Y% O* C/ j& N9 E+ M
//连接主机的 client 9 p. ^2 a8 Y% ^! }0 E Q- g
if ($socket == $this->master){
# Q' y; r4 s% Q @$ y7 I
$client = socket_accept($this->master);
) V2 T: {* Z9 s Z/ R
if ($client < 0) {
T1 I- j+ a$ k- e
// debug1 _. i3 E1 {5 {. V2 ^1 M) Q
echo "socket_accept() failed";6 f+ e9 h1 P# |1 w/ G% p# R Y
continue;
: O" `# T1 x% f G( B3 ^4 E
} else {
& q, i1 V: T% n& n) o ~. u% c
//connect($client);
# S5 P0 z6 f% U6 I7 y
array_push($this->sockets, $client); x2 ~6 D. U# Q( L: J$ e
echo "connect client\n";
0 I) y3 g" k' X3 q
}7 c5 `3 L6 Z6 { f
} else {
0 x7 _6 ~4 a. C y3 W1 N3 G& P
$bytes = @socket_recv($socket,$buffer,2048,0);
7 h. w" x" V8 l0 K
print_r($buffer);6 T# N# U. d( d$ E$ S( p
if($bytes == 0) return;
/ t8 h! l* L+ p4 p
if (!$this->handshake) {# v' {/ k b/ r$ o) Y, P: {) Z3 X; E- s
// 如果没有握手，先握手回应& e( o" I* f# ]4 f5 r& u) ~! n
$this->doHandShake($socket, $buffer);( y. c: g, S0 l2 b) f- L/ v& D; p
echo "shakeHands\n";
- R# [. d; u$ f2 G" k
} else {
* q8 K5 k( C0 v
1 x( y4 `+ A1 J. A; i
// 如果已经握手，直接接受数据，并处理
6 n# I7 h8 f3 ~7 r, b
$buffer = $this->decode($buffer);
. F: f' @; g7 w, q7 @/ Q' ?+ v4 e* a
//process($socket, $buffer);
* `; j+ e6 v9 T% B" ~$ s
echo "send file\n";8 V7 f* p* S" p# g
}
L3 }5 H7 y$ W/ k8 |( y, d
}
& r5 h' c5 S! @9 |1 \8 a
}
. B8 K! e0 v. `7 `5 o
}+ x0 H( d1 O0 b! L( R& X5 o+ a
}4 s9 A! O1 L% z. i2 x+ a
8 B. p0 Z3 G# u% r7 b- H8 y' h
function dohandshake($socket, $req)8 d" G& |3 i6 o+ f- ~
{7 L8 t! l5 ^0 F
// 获取加密key
1 g3 d# F3 l! i: j7 n1 d' W% h
$acceptKey = $this->encry($req);
' a( L* ]! J. O9 q' ]8 s
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .9 G3 N5 F- y& E0 r
"Upgrade: websocket\r\n" .! c$ M/ E" L9 c$ p' N
"Connection: Upgrade\r\n" .# Z7 R! i: u [' G9 m
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .6 ^( e1 U; m& k0 @4 R
"\r\n";- l$ u% I. F/ O. k$ a
$ |( U* B* J2 O! g4 ?& m+ U& v
echo "dohandshake ".$upgrade.chr(0);
' A( [3 s) Y q7 c9 a
// 写入socket2 K9 W2 _) p: q
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
2 a* b! l! }5 h; {3 d3 J3 O
// 标记握手已经成功，下次接受数据采用数据帧格式0 |* V! h. s0 G( r% @) o, x4 z; c
$this->handshake = true;
3 `) r- w# |. Y7 T. {, a$ ^% A
}
! q7 F8 B9 H+ Z2 O. B- D
1 Z M7 j$ u) |6 `
/ D4 Y" x2 n; i6 \
function encry($req)
5 h5 ^2 x1 Y4 S* x2 W; \
{4 S) D+ A' O% l$ z) j
$key = $this->getKey($req);$ |+ B: t* y: j! k3 h
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
* {2 D7 i9 J/ Q0 o4 x8 l& k6 A
- g7 R' l% k# T* C/ N. l5 n3 C
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));0 P0 H# m( U1 f3 u2 i9 V
}
5 f; ^/ v$ N3 @ _
6 [/ p8 ?: p! _5 e4 g
function getKey($req)
+ t1 Q+ }- l9 E. k
{
! ?0 C* I. R3 C# m* C, C" a0 V0 R
$key = null;# b9 a* c1 I$ {, }
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) { # Q) B" L1 ?" E# B4 _/ l3 \
$key = $match[1]; / Y$ t* C% v+ c
}( C# Q. z# I* g! @0 L
return $key;
* y @2 o, {3 n( u b
}
3 [# d7 {& ~/ [# V
/ Z! v7 H; U/ b3 ~9 Y% }# F. f5 f
// 解析数据帧
& { t7 r. a: Y* X+ o3 h
function decode($buffer)
$ }, D7 r+ L: o0 n+ O7 p" G! }2 G. ^
{- _( Y/ A* A; O4 P, ^3 @* v
$len = $masks = $data = $decoded = null;4 C5 P! I: K4 S Y! q- t
$len = ord($buffer[1]) & 127;/ P6 R$ ]% ^) T8 R, t9 h+ S
( m$ ^ y# `+ t" r/ c
if ($len === 126) {
4 D/ V3 l- U; g9 n% g
$masks = substr($buffer, 4, 4);
+ p# N+ T, m% i/ C1 g4 } Z1 q
$data = substr($buffer, 8);
+ |# O7 Q0 o) X' ~* Z
} else if ($len === 127) {
c! K- p4 J! V. p1 i6 H
$masks = substr($buffer, 10, 4);$ ~4 i/ C, \ P7 F
$data = substr($buffer, 14);
- i7 e1 P6 q$ ~4 z
} else {
7 O% U0 w& d- Z( Q, \* `( y
$masks = substr($buffer, 2, 4);
+ ^, G5 [/ }% g9 X' U# Y. j
$data = substr($buffer, 6);
% M- z& X% L% z. ~2 e1 d8 A( t6 t8 h
}
! N4 f/ Y1 X# C# `
for ($index = 0; $index < strlen($data); $index++) {
4 X* g* [2 J" I j/ @
$decoded .= $data[$index] ^ $masks[$index % 4]; T- ~+ U% r2 m2 m9 y# M5 M# [3 h
}* ~% F3 I. f6 \
return $decoded;
. ? N# C: H! A4 t$ e& J2 E, {$ w
}1 l: I1 _3 d. Y! R$ F& g( c
. o; q# Q+ V* k4 _8 Y( }& s
// 返回帧信息处理
) l+ o' a! G2 w
function frame($s)
4 D& G; L) w3 n% I: D) K6 C
{9 z* g0 I# c. _% E4 z% e# s( |
$a = str_split($s, 125);, C& m' ?9 S9 M2 C
if (count($a) == 1) {; `2 d% G R3 H% n
return "\x81" . chr(strlen($a[0])) . $a[0];/ |/ x0 U" {$ T- b# o! q% b
}4 `! n2 x3 G- X1 e
$ns = "";+ ?4 h# a# `5 y# n1 i: ?9 O) g/ ^
foreach ($a as $o) {
9 F* s0 C1 ~" N* w2 P6 X- U0 F. T
$ns .= "\x81" . chr(strlen($o)) . $o;
* ^ D! p$ Y. ]! m
}
4 M* W7 Y* Z: `
return $ns;( q+ f6 z# E9 X# [9 x
}: Q* @0 L( d" n( {% ]5 x1 Y' r
2 x; {! P, A& }8 q
// 返回数据0 m- R6 W, Q" y/ K- f& X/ W
function send($client, $msg)
' @8 d6 u7 D4 k5 b" e: F4 v
{
0 n0 o0 l( s4 |& u2 e, e, V
$msg = $this->frame($msg);4 b% j" C. h( |4 M& l0 T9 @, ^
socket_write($client, $msg, strlen($msg));
7 r) h* c- a! f, B3 t
}1 R1 A9 [ E! F) C5 X6 E# Q, R- \
}
, k% d q+ V% h! K0 n
; K6 `! M; i+ |0 f1 b2 r
测试 $ws = new WS("127.0.0.1",2000);
' g) t% J J S G& f
8 x# K- | i4 ? F$ h- `4 y1 T

复制代码

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

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

浏览过的版块