PHP 简单实现webSocket

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

1）客户端实现

<html>
# G1 _; Z1 l7 Q& X3 g4 Z8 N r
<head>
# k) x( s1 y; W' r. `& e1 `
<meta charset="UTF-8">
" {' I6 y% b: c& v7 v
<title>Web sockets test</title>; q+ Z% ^# z" P4 k
<script src="jquery-min.js" type="text/javascript"></script>- g. I/ S2 Q$ q( F
<script type="text/javascript">0 i6 V2 o. E. l0 v" j% s
var ws;! Y1 C' i4 g5 g/ [
function ToggleConnectionClicked() {
8 L/ [$ j- P# l
try {5 v/ j: J) R/ s1 H1 J( s, a) @
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器 & j c0 D3 [! ]$ v; E
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};+ |" F) e* c' ]0 w
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};1 z) K' x6 q* C9 U5 {' X4 }
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};' a% Y: w- r- Y9 k7 M9 x8 B
ws.onerror = function(event){alert("WebSocket异常！");};% P; v) \( Z$ {# i! }" u& P
} catch (ex) {
1 |& n$ A: d3 B. }
alert(ex.message); ( ~) S m" `4 }; Y
}
1 }4 C5 Y* k- A1 X
};
1 p; L( ], h. h
* }" B* r7 i& j9 T- ~
function SendData() {
' C. ]' T7 t' W- X7 s
try{
2 k6 b4 q, {: ]+ X# Z7 u
var content = document.getElementById("content").value;
6 o' F' N# e2 @' ^/ [/ @
if(content){8 h& X. {8 M M6 e- ~3 d; w
ws.send(content);
; T& A0 T) D4 \+ W1 Q( K/ _' h
}
: a* f% ] E: n3 ^! w
: M* @- {0 @% ]2 C4 P
}catch(ex){$ R1 e H7 e5 a5 j/ R
alert(ex.message);
: `$ F) {: c% N8 a, G4 D1 X
}
; a. B5 I+ q/ r
};5 g2 L, w; }2 |$ u
. Y* k( V* }8 H, [+ ~
function seestate(){" P; x5 \0 B6 z: m
alert(ws.readyState);1 q$ L2 k7 } M8 Q$ K- e
}
' \, h& ?& R* \; A% \4 g4 S
# e4 o: ^8 d* I- Y8 k) \
</script># f% {5 N3 I2 h$ L1 y; t0 c
</head>
" T- t0 q x8 g, O; @% M; h
<body>" W0 j, e m7 f! Q; R+ F+ y
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />
5 p, ~4 [# X; P8 t x/ p
<textarea id="content" ></textarea>/ V+ M% |+ d/ _$ ^ o$ i
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />
3 q& s6 m8 @" w6 P4 L
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />% p6 E8 h, q. c9 t* O! y
8 Q( P, V3 e: S# w# Y7 p
</body> D& ~& F0 y) r
</html>" O& ]# C7 o R' F+ C! R

复制代码

2）服务器端实现

class WS {
5 S# h' J5 R" b# a9 |" ]
var $master; // 连接 server 的 client( I- F* A: G' f* e4 \# W" Y( V7 o
var $sockets = array(); // 不同状态的 socket 管理
. I7 O% l0 t; l* O; k
var $handshake = false; // 判断是否握手
6 M0 c" e1 x8 r9 n
: Q G5 i7 q2 F3 r! V: {( ^
function __construct($address, $port){
. g* `3 U# O/ o( B) m3 |
// 建立一个 socket 套接字2 c; K" I% O) y
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) A0 P( u5 M8 K8 N
or die("socket_create() failed");8 M( a% x( ^% w# f9 y/ E
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) # r3 F: d- P0 I/ ?$ O7 W B
or die("socket_option() failed");8 P. I0 N: n8 C+ _# ]
socket_bind($this->master, $address, $port)
" [8 q* P0 Z# W
or die("socket_bind() failed"); b( m! C' W& [! X0 m3 k
socket_listen($this->master, 2)
7 J0 B" G ?' V" _
or die("socket_listen() failed");
9 W- F+ _$ A6 ^
/ ]2 X5 P3 |2 |8 Q, k) @
$this->sockets[] = $this->master;
# R9 |7 j) n) n: ]
4 ]: x1 i( J' r% I5 P$ d
// debug( e2 I; c% z Q& r M$ I! z
echo("Master socket : ".$this->master."\n");! b) n( C. @- M6 N5 \
. X- }! Q, i+ r; A4 m( z
while(true) {
' i4 r! O5 p. X, g" M
//自动选择来消息的 socket 如果是握手自动选择主机
+ L4 p7 h' x0 v/ [- r
$write = NULL;) Z3 e6 f: V x1 S9 Z. e- @
$except = NULL;
socket_select($this->sockets, $write, $except, NULL);. Z4 e% Y3 w. ~+ C$ V
5 m5 G, O, n- k0 h2 E
foreach ($this->sockets as $socket) {
3 R- H! b# Y& T3 m
//连接主机的 client 3 \0 R* ]3 R: a4 a* A% F
if ($socket == $this->master){1 j; [# l+ f" B0 k7 p% f; x
$client = socket_accept($this->master);
% ~9 V* c) l6 {
if ($client < 0) {; i1 d9 ]2 b$ E7 E, Z
// debug
1 I( I ^& }7 c
echo "socket_accept() failed";
+ |; U5 w4 m5 B j9 n, {2 r# n
continue;
7 h: z5 V+ p7 P U& l; X _
} else {
! r- O/ J% W6 j, N0 a0 |" |: Z
//connect($client);
# _* ^( u `+ r- x- a5 _+ W1 z
array_push($this->sockets, $client);
2 j ^% Q2 k0 f' l- L, T
echo "connect client\n";
' p9 p! d* i( z4 w
}! i$ G- |9 o9 y% N( A
} else {
# r( ]9 B% U. ?& S+ j' |* V2 D
$bytes = @socket_recv($socket,$buffer,2048,0);
/ b6 C5 \, V8 G) F4 P5 x
print_r($buffer);
5 C/ m0 h: Q8 n: W& `
if($bytes == 0) return;
2 H' ]) z8 {7 W" r/ ]# B5 @ I& S
if (!$this->handshake) {
. R1 {+ i D0 j* E4 J
// 如果没有握手，先握手回应! A7 r8 _# d& l! B
$this->doHandShake($socket, $buffer);$ K3 h5 D7 ^: I& s+ y' Q
echo "shakeHands\n";
9 F' u7 {+ [9 Q! M6 l
} else {, k7 w' O. z0 B
3 N! v3 ^6 L7 U" N
// 如果已经握手，直接接受数据，并处理
$buffer = $this->decode($buffer);7 s# F3 a9 R8 m, C: t# F8 ?
//process($socket, $buffer);
4 V p' ~4 @* w) a
echo "send file\n";
; T" r4 \, ^0 a" _; m0 J& }1 M8 p
}
4 Z. J w G, X5 r9 I) H
}. @/ p: ?4 W0 \
}
% d0 b+ V9 X& L" j, q6 b
}7 R9 X# h# C5 r( `8 t7 S- P% z
}$ Z& T3 }% ] o; B
. F- x v( t# j. `6 g
function dohandshake($socket, $req)0 B% y9 k5 X- d% x; ^; }6 L" p* Z
{* h1 H6 z2 p* f1 p/ v
// 获取加密key
( b8 Z( d+ A# e" b3 T! S
$acceptKey = $this->encry($req);4 }! e" @5 H8 @) M8 L$ p
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .! d3 a9 g9 |8 b: W) Y1 j
"Upgrade: websocket\r\n" .+ l& U& E- P1 M4 P! t- @1 b
"Connection: Upgrade\r\n" .& h: J0 B5 Y: @" \9 R& R4 S5 |
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .
" d. B" L: ^/ K3 O# Z
"\r\n";
5 q: d1 U) e! f3 X; G% P! n$ `
! r0 m% |7 {& [ x: Z9 J9 c
echo "dohandshake ".$upgrade.chr(0); 9 o( z: b$ ^' ^0 \' _# o4 O1 R
// 写入socket
0 z B" ^1 E& z
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
0 Z* }2 n2 w( a' B6 Z
// 标记握手已经成功，下次接受数据采用数据帧格式! h7 M& D1 T; ]: m) H1 a
$this->handshake = true;0 y/ p6 Q3 k% l2 w5 A+ O# O2 w
}
9 C8 @3 S3 i% M- q( [: c* Y
* P0 s' ^3 G" L9 Z! ~
3 t. N4 e; y1 ?: y9 ?+ P! P
function encry($req)
1 a5 O. k5 y6 L; [9 T3 R% K
{
* w6 L8 o+ [* R4 J! [1 c0 o7 q
$key = $this->getKey($req);2 W$ O H' M' p5 h$ ^+ P
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"; S! R! C7 s9 y8 u
8 }5 X5 R: L) c/ z
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
9 Z0 _2 c2 x/ a B6 M
}. K' F6 j$ s( l" R
* S% N" ~* Z- i9 N
function getKey($req)
4 P( _/ Q0 ^# c8 K8 J
{
$ F- X. l# R, c
$key = null;
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) {
' s* s1 x0 W9 [( I7 w& A2 ~( e
$key = $match[1];
" h$ [) _. o; }
}6 F2 I: f# z* o9 o! `4 i
return $key;
8 K6 n, Q8 s, Z1 R( k' V2 ^. t& u) j
}
: p: s. j9 r' a7 |1 U
2 g6 n; T! t) ~6 h4 a0 h( i+ |
// 解析数据帧
) w$ B$ `( c+ k
function decode($buffer)
) P- p" [( X; w) O* Q$ C( D8 }8 G
{4 r! L7 ^$ K5 S7 b
$len = $masks = $data = $decoded = null;" p8 |; L, A& Q/ `
$len = ord($buffer[1]) & 127;! Q: P9 W) q: o% C) d
6 s4 F- U, [" M q0 d& g d
if ($len === 126) {4 c1 K0 O2 y7 l; ~. h# J
$masks = substr($buffer, 4, 4);
: b: T* v' c/ f8 \5 F* [9 d! y
$data = substr($buffer, 8);8 W9 i6 S @( Y" `- g$ [
} else if ($len === 127) {
) [9 }7 l# u# t4 s/ O, h' |
$masks = substr($buffer, 10, 4);
) A7 i) V$ q( f, B
$data = substr($buffer, 14);9 [( d+ d* h4 ~5 f0 I
} else {
7 m' o8 y7 {# ? N/ \3 y v8 ?6 Y
$masks = substr($buffer, 2, 4);
5 ]# I8 ? m c% B) P/ D, N/ {
$data = substr($buffer, 6);# _8 A1 F: l* t6 | R- k, h' H1 h
}- S0 e9 F& I! g) Q' k: |
for ($index = 0; $index < strlen($data); $index++) {/ T0 r/ u8 {4 B
$decoded .= $data[$index] ^ $masks[$index % 4];" m6 O( [; E7 ^8 o- x: a+ m
}$ {- k; V+ }9 b" Y, J1 v- Q
return $decoded;
9 v' H8 I5 R3 X9 I7 j& ^4 z/ V
}
2 x M, [, G; `. L* C6 ^7 Y
) r0 \' N" D" C2 W; b1 j
// 返回帧信息处理
/ d1 d$ A" [, g$ {
function frame($s) $ ~* p7 w4 D3 S6 J" A$ s
{
0 G$ {# t% e! N( `+ F8 E5 d. x: i
$a = str_split($s, 125);3 I( H9 k& k# r4 l) _% q
if (count($a) == 1) {
1 e8 I# g- [- j2 Q* O' p7 r
return "\x81" . chr(strlen($a[0])) . $a[0];* ?9 p0 y" h& Q# x; K
}6 G8 A0 @2 V6 n2 {3 [' u
$ns = "";4 y T; }$ ] b$ W$ x5 L' f
foreach ($a as $o) {
' y4 M1 z- P+ ]: P' \
$ns .= "\x81" . chr(strlen($o)) . $o;
- p% v% z3 |& k. m2 N
}# K+ B, d2 L" L2 R6 F, G
return $ns;- D* {: C# }* ]& _4 z) A* V
}
' J+ h0 t9 t, j1 \5 C
6 y' V) x6 W4 G5 ?4 X6 @
// 返回数据2 x5 d: `: c0 i: e* y0 V1 G
function send($client, $msg)' M2 x* S! N2 [' k j
{
+ q+ g& X: Y8 c0 {
$msg = $this->frame($msg);* B/ ?3 Q% {4 c, u: V! P
socket_write($client, $msg, strlen($msg));
( Y8 a0 u# p$ y$ T2 i/ g
}7 z* j I% x$ d, J# D
}
# @3 A, y2 L. z, e
1 v" J" V' l7 v9 j
测试 $ws = new WS("127.0.0.1",2000);+ X) d; F6 K+ J8 u7 R0 \/ S
$ |* b3 l+ y0 O2 f; P9 {0 Y6 Q8 O

复制代码

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

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

浏览过的版块