PHP 简单实现webSocket

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

1）客户端实现

<html>
* Y- A8 ?) F9 @% c# Q3 r. L% z( S
<head>; f4 O ?* F" _+ H) [: }
<meta charset="UTF-8">
0 a& G1 |+ s, h. a" } o
<title>Web sockets test</title>
) c, U; b! D5 C7 @) e0 k. B9 U" y
<script src="jquery-min.js" type="text/javascript"></script>( k. V/ l ?* o
<script type="text/javascript">1 l# x- }: ?1 v% y2 o5 s
var ws;
( r0 g" ` N7 q- w* U. i% Z: P* T7 Q
function ToggleConnectionClicked() { 0 `4 p+ K3 {3 q2 A* _1 E
try {
3 X& ^/ y6 R8 K) g. w/ J; a
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器 * J2 u5 v& y+ ?& H# ~
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};+ c4 K) J" S) G, }7 E' ^& U
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};
; ]6 Q! ~! o" S! P$ J; g
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};
. V- a$ G; E! |
ws.onerror = function(event){alert("WebSocket异常！");};, E/ L3 \" u _/ `0 I( f, }
} catch (ex) {
; P0 f: C) o3 P
alert(ex.message);
0 e8 J: ~; V) k
}* k# O* e9 k+ K; v: I- K7 d' N9 L
};- t) o) n: l D/ U, O0 X7 `, B0 ~
( v: y% S2 O1 W$ v( `8 H
function SendData() {
$ ^7 s, u& {8 T
try{
, }: E& o6 U# u7 ^/ A
var content = document.getElementById("content").value;
$ t; e7 r" n6 V0 k$ P5 v. U
if(content){% V0 D' J7 L7 Q: S1 Z) h3 s
ws.send(content);
3 R3 u# c5 n& R7 K- J; g& e
}) k& K! V, A+ E3 [" I/ j; |" ]
+ J$ m/ Q6 }- ]5 A% b x
}catch(ex){: U. t; i y* C8 p R" C3 }
alert(ex.message);
9 w# X% L' o$ `- u3 g5 F Y3 g# x
}( T7 ~8 k) X9 O& k* ~2 Y, r8 {
};
8 m% C2 }! ?. @; O) [
! x, B! @/ X( u
function seestate(){& G1 U) Y" Y' D6 }
alert(ws.readyState);. h' ~; Y5 M) S* G* f
}
2 B0 Z F. `6 p3 p. `
9 v6 |. D! O: t4 J) s8 W k, d3 S
</script>& v# @" J1 r- M9 F& l* l6 H7 g
</head> A3 i% n. K1 A8 v1 w9 ^. c8 Y5 k
<body>& q% m6 [) q% W+ ?
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />) G/ g' x$ q. R' z* u4 m
<textarea id="content" ></textarea>
, i6 R# w! G# W& K6 p7 g/ d
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />
. p& W& {3 Z3 S6 K. u* A8 }* P
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />
1 ]" ^0 K' ]0 ]9 i" ^3 R9 P$ {
5 {, |2 W; D3 W, h4 o" _
</body>
% r1 e$ x0 N9 _/ S+ t! R
</html>! |' X. t& C: U: t& Z6 Z6 q

复制代码

2）服务器端实现

class WS {9 {; _8 J0 }$ a8 i# F
var $master; // 连接 server 的 client6 e9 [+ i# J4 n
var $sockets = array(); // 不同状态的 socket 管理
" X( V d4 O' d$ u- i
var $handshake = false; // 判断是否握手
1 m* w( ]# L0 R# [; _; i
# O3 t2 N: x: R4 s# O
function __construct($address, $port){" i M, R+ [6 H
// 建立一个 socket 套接字* R6 z; z4 @* D* z( l3 i B
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) 8 a. R/ r7 q( i2 ^
or die("socket_create() failed");' c, L2 g2 @* W; H/ W2 G8 L1 s9 H
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) $ r5 n9 ^" D, T
or die("socket_option() failed");
0 e/ e4 X' Z( I9 [& [
socket_bind($this->master, $address, $port)
5 B. n0 T( s3 \5 w. n
or die("socket_bind() failed");* x# L1 V% f& |* T/ u! I
socket_listen($this->master, 2) ' h# {# I5 d4 i( i" M
or die("socket_listen() failed");
+ p( p7 e8 N ?. J* q& d
I4 M3 x/ F3 ?1 N; i+ m
$this->sockets[] = $this->master;! m* Q0 f% c4 J" ]4 H
, E3 P- v; |$ L0 e( i' X1 Y
// debug
1 J. ?: f# f2 Q. Z1 ?. E
echo("Master socket : ".$this->master."\n");
; z# Q5 g4 P' R; z+ `; {" ^: |6 m) y
& D" {) H* c1 N$ c$ l O
while(true) {
9 S- E6 M& \# G. O
//自动选择来消息的 socket 如果是握手自动选择主机$ ?5 `+ b$ O/ B: K# J6 G0 E, a
$write = NULL;; \. B0 W0 V* }8 F4 ]9 e4 b. |# K
$except = NULL;7 E1 j/ r4 W/ k
socket_select($this->sockets, $write, $except, NULL);
- A5 x4 v0 n' u- _$ ^
$ w* S* M! N8 c
foreach ($this->sockets as $socket) {
- J E! C: B' Z9 Z
//连接主机的 client ' v" Q6 `6 @; h7 R0 f
if ($socket == $this->master){5 f2 q- _) n3 @2 i$ S- [
$client = socket_accept($this->master);6 Z( E- o9 S6 y* Z) w; C3 N: S
if ($client < 0) {# y2 b. ~: T( O: _- a |
// debug
* h; O0 f& ^2 X' p
echo "socket_accept() failed";
; Z) v1 ?8 ] m6 A) b
continue;' J. d. H7 X5 E- M7 b0 f
} else { |! _& k- N0 L p7 t4 c
//connect($client);/ N. U J: @# C; P3 V. N
array_push($this->sockets, $client);
# _: l3 [. a/ K& V, `! t
echo "connect client\n";& m \1 H% {) I0 a) h7 @
}
2 |; R0 x0 Q1 x& p) u6 {
} else {& {; v5 w6 j8 t& {9 w) i* h
$bytes = @socket_recv($socket,$buffer,2048,0);3 G7 i1 K& M- Y$ t4 G
print_r($buffer);
a7 R$ U. I; I5 L: y
if($bytes == 0) return;; Y! a: @$ y- N, t; w% [9 t7 H
if (!$this->handshake) {
) O. ? ?* C3 K3 N
// 如果没有握手，先握手回应: {/ q/ N8 r. ]: e
$this->doHandShake($socket, $buffer);
9 f% t7 N: U, J
echo "shakeHands\n";0 s" j! M6 V+ A& M+ k2 G
} else {2 w( O4 {( y* v5 d1 \8 a$ [3 {
E# e- l. c m3 A# h" @) I
// 如果已经握手，直接接受数据，并处理9 w/ O; Z" Y* X4 ?( z# L
$buffer = $this->decode($buffer);3 `7 { D4 E5 T
//process($socket, $buffer); ( k0 y" Z: K8 V* u
echo "send file\n";
/ S2 D( U) k5 C! ?& A$ Q4 ]
}
, b8 A# m5 W0 q! |
}
5 B0 W! s {/ i; w
}
4 W' j' D$ }; d9 F. y; z3 t! D' K
}
5 _$ E. M8 u! G
}
: l1 W+ k; M. e% w4 u
: P% Y3 b4 T; F' b; Q+ Q" g
function dohandshake($socket, $req)
3 T0 f3 P$ u: p" s' e* [
{8 I$ u2 V/ W# E
// 获取加密key% u Y, s3 o; |' m
$acceptKey = $this->encry($req);
2 g; c, }2 @( _
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .
_( E* E& f" r5 d3 W7 d& `9 w* Y
"Upgrade: websocket\r\n" .
. q6 B* l# V, s3 X6 T1 X e) m
"Connection: Upgrade\r\n" .3 L& f5 [3 l$ F* W
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .0 N# }& \$ ?2 R6 b* f0 j
"\r\n";
5 S- J& r4 ? s6 d5 J6 F
: e' t) V8 b$ i' G
echo "dohandshake ".$upgrade.chr(0);
. [% w; P3 X3 `, q- |6 g
// 写入socket2 N6 X" @' m6 [. I$ G* [
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
l) X; y& u P1 e7 S6 L
// 标记握手已经成功，下次接受数据采用数据帧格式* J6 k f9 v7 B9 _! v4 t
$this->handshake = true;& F1 k) C$ I Z3 m
}& w0 g& O7 {% Q7 V$ s" z
1 D. v* v K6 u' f2 S% B" i
) B1 E$ J* `% B% v* R t# L3 D
function encry($req)4 j: N' Z1 Q4 O: k
{' n8 t. K! U" O0 _# G
$key = $this->getKey($req);
& p# e5 B1 g% d% o% h" Q8 S4 h
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";# r! u* X$ E% a/ u
; c1 N( C M' Y/ S) h+ V9 L$ g
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));$ j' t- A: h3 A/ _
}
7 E) G0 K3 g+ R: F# T
4 t8 R' a2 o X; n2 O0 m" }
function getKey($req) 7 c3 z- b0 ]& V' _" e# q
{" \7 s0 A% j9 J- e U
$key = null;
' _. ?& F" }2 f1 N
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) { # u2 V4 [( |& Y
$key = $match[1];
7 S a0 z& s# K6 m
}# b' J& K, Y; ] {' k/ d; `
return $key;& O+ `2 n1 P% E
}
9 m( b% f& l" _! g- T. {% @
" T0 I) `! O( M
// 解析数据帧
$ ]7 N# C( @( f
function decode($buffer)
! @+ Q/ A. ]& X6 v8 q. F+ C
{' s* _6 Y/ x1 {% m* w0 o9 ^$ k
$len = $masks = $data = $decoded = null;# j2 f$ U# `. l3 X
$len = ord($buffer[1]) & 127;! |4 i/ V1 w* o4 P5 e4 ]
5 P# s: P2 o* X; A3 H0 x$ e3 q
if ($len === 126) {
: V$ c1 l% Q% a$ F# C5 K/ _
$masks = substr($buffer, 4, 4);
. J$ m6 g+ q# n# S' K3 K1 h
$data = substr($buffer, 8);
+ V: ^3 f/ W8 v6 g; u8 d
} else if ($len === 127) {
1 S0 _% i+ P: b) d. m
$masks = substr($buffer, 10, 4);
- F) x4 i7 s" J3 r, w$ G- R1 a8 y4 X6 M
$data = substr($buffer, 14);- d: S2 F/ t( {& v: r2 }" c
} else {
3 z* p$ V6 A, m- v ?
$masks = substr($buffer, 2, 4);
1 g7 {' M$ P5 j* x: u1 P4 ?
$data = substr($buffer, 6);3 E: g. t" u6 L$ q5 ~: `/ @7 m
}- {4 Q( C/ Z# ? w" P5 ~! W# V. I# n
for ($index = 0; $index < strlen($data); $index++) {
' ]* w% k( n( q/ T5 J1 |& p
$decoded .= $data[$index] ^ $masks[$index % 4];
; v; j. t- L8 x. w& }$ T( u6 H- e, @
}
2 K- r, Y- n( F" V- e
return $decoded;
3 Y" z( E# J. n& X
}7 E4 d) a+ u) ]! r H. k
, C! l! @) j' N8 g1 K' `
// 返回帧信息处理
" x$ Q" m9 q, H9 t
function frame($s)
, n; q% [. X) O" Y' g7 x
{ n& i% N1 [6 P j
$a = str_split($s, 125);( c2 V7 \( d+ D$ G* E8 O- Q! g
if (count($a) == 1) { }. _; k' a( ~9 V0 P
return "\x81" . chr(strlen($a[0])) . $a[0];+ M# U, s0 K# ~- m4 K0 k
}& v' m1 `1 |, l$ a8 M
$ns = "";. K0 G2 f8 Z, C. H$ _6 j7 Y
foreach ($a as $o) {+ v5 ~! n$ O* a$ |5 b- y% s% r
$ns .= "\x81" . chr(strlen($o)) . $o;+ q# r! g" n$ V, {
}
, I5 H5 y& d2 ^8 k3 H/ N- o
return $ns;$ d9 c! t. @% p' t }
}6 K+ g) M0 `0 w. I( y
: b& \0 _% Z4 J& }
// 返回数据
v0 T. s" P0 m( e* n
function send($client, $msg), \/ J* s2 c! e X
{6 D( [1 j* c+ n9 ]5 A2 ^. a, V
$msg = $this->frame($msg);
2 W/ R7 j4 g v7 X- H5 k3 g E2 Q
socket_write($client, $msg, strlen($msg));
4 l- ^- E! l, A" A& H4 [" \; D
}' b# k0 E2 Y9 H" h1 E3 m3 ?
}$ n5 I) B% g5 t u% M0 x
$ {& S. }3 w8 \1 r$ J
测试 $ws = new WS("127.0.0.1",2000);7 K* N1 p; c: X
. f: ?: e0 T b' j$ j# `

复制代码

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

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

浏览过的版块