PHP 简单实现webSocket

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

1）客户端实现

<html>+ X3 i* ~3 O( [5 j$ r. M9 d
<head>
% H. A" v( C1 L& |. I4 b
<meta charset="UTF-8">/ |. N: Q* h7 L) D! @- w8 _8 ~
<title>Web sockets test</title>7 I1 V: W+ ^. K f( R
<script src="jquery-min.js" type="text/javascript"></script>
$ h/ Y$ k) ?4 f5 ^' M
<script type="text/javascript">
2 Y- f7 s6 E2 S. ~9 f; |6 ^7 C
var ws;
+ A; J! R. }+ E/ [# n0 b7 _* F
function ToggleConnectionClicked() {
+ W' ?, @& r5 e. }' h( Y
try {
- P% ~1 Z0 C( ] B! [& v
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器 ! s( |# M5 j J6 E% _' r# Q
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};
2 T; Y0 y8 j2 [0 |3 X
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};, B3 e0 R) \( Y
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};
$ b& v. A! ~) Z L6 S/ E) R0 f, {
ws.onerror = function(event){alert("WebSocket异常！");};0 f, ^/ ^* e% W
} catch (ex) {
7 w: R- b; _0 p. t! ~; |
alert(ex.message);
1 H# w% c; U8 }7 k* B
}
6 d. F* |; d5 F- { p
};
! {4 O7 @$ l' ]" `* Y3 V
% \$ U1 e4 S+ f% o* u' H( N
function SendData() {8 R0 Q& f. i5 C- ~4 l3 ?( K
try{' D1 t! }- r7 c7 c; x9 H! V
var content = document.getElementById("content").value;
2 Z$ r U% M+ l: H T3 W
if(content){! b l. @4 z/ W: |1 u4 x# I6 D/ _
ws.send(content);' c5 ?2 d3 R) O# k2 W5 E+ G8 C
}$ F: G3 }8 b& L! P' M5 m" w
* ?; M! G% _7 o) ^( Y M c
}catch(ex){
: X6 @# U4 g. _2 i
alert(ex.message);) p7 r% o0 T1 \: H
}- ]9 G9 b! A0 `) L& V4 i
};& e5 f, L) m) Y( p F: @; R4 X
% a8 d" Y; R8 |8 X
function seestate(){! H) {$ K! o* v+ m' W# w) e
alert(ws.readyState);
/ _8 n( l3 z) }& E8 h ~3 c8 t8 \
}
B3 K: J2 @! V# ~& T
( u' y) i2 m+ A# X+ r4 G/ C! p
</script>
, [8 t" Y4 m0 Q+ @0 B/ b! }! M
</head>+ e! i. j3 J, ], Y. J
<body>0 y. Y& @2 E# Y) _; T f
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />
8 [8 }/ t- f/ H( r0 h
<textarea id="content" ></textarea>
1 P4 f. i" W, t* G `
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />
+ J* m! t$ j' X! Y% z' M
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />& j5 A" v. G# J! n
$ J; K. ~" V% `4 A
</body>
" Z" }5 D( O: x: q" [
</html>
0 K; K n4 V$ `9 \3 [4 z

复制代码

2）服务器端实现

class WS {; h& r: @1 ?! F# L4 p* r5 ~7 K
var $master; // 连接 server 的 client
0 E- l7 ]) o& @
var $sockets = array(); // 不同状态的 socket 管理- Q8 g M8 @/ H+ Z8 } ^
var $handshake = false; // 判断是否握手
2 z$ c$ e/ r9 x% v' o) g
$ G+ [6 z# h1 x' f
function __construct($address, $port){
! K' x, S9 C3 d
// 建立一个 socket 套接字% t5 W' y# ~: w) X7 ~: T
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
0 E& [- `0 W" C8 F' @6 V' ^
or die("socket_create() failed");
' m, C5 a; A2 L0 Q2 _8 W- B% I8 U
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1)
- i) w. V- A0 h) b( S
or die("socket_option() failed");
) B5 {4 g7 u% L/ R
socket_bind($this->master, $address, $port) X+ q! _$ P; F7 ?4 P$ k! [( a% h
or die("socket_bind() failed");
7 J! W8 S0 N3 Y' C4 P
socket_listen($this->master, 2)
% q, j0 B# b& u! C4 T$ N: K
or die("socket_listen() failed");$ `5 p. ~9 @. B4 v# i# C
) H8 G ^* G& B8 A
$this->sockets[] = $this->master;$ W4 k2 y% D4 I. P% G
: \ ?) }6 u+ l. F. Y1 p( N3 v
// debug
8 X. T9 R% T* E* [7 d. U4 F- U
echo("Master socket : ".$this->master."\n");
2 h: @, S" g1 P0 t7 ]
4 z2 s! v: F0 A! R
while(true) {
! M1 k7 H. n6 n* B7 [% G
//自动选择来消息的 socket 如果是握手自动选择主机
* p* r, |5 r" M( i! e
$write = NULL;1 e4 x/ i8 H% k1 C6 w$ [
$except = NULL;% ~. F5 F P7 E0 ?
socket_select($this->sockets, $write, $except, NULL);+ j) a8 O, Q4 l/ q
/ B" @5 g1 q$ A4 [& ?; a
foreach ($this->sockets as $socket) {( ?7 \9 @& R8 n0 R1 `6 a
//连接主机的 client
: }* a9 d$ ]1 ^) t5 E, [
if ($socket == $this->master){8 D$ F6 F* _6 X2 }* r
$client = socket_accept($this->master);, L- B) J# k$ K. k
if ($client < 0) {
! ^0 c0 @8 o3 h) a9 U& X
// debug3 J) o+ `* K ^& v1 K7 u; ^
echo "socket_accept() failed";
( s, @2 ?% A# S
continue;; w6 D- a# u& d. x- t/ f
} else {* |3 h4 S: v& a8 o0 B- H9 l
//connect($client);
8 y! J6 u8 H/ a* ~
array_push($this->sockets, $client);4 T( D; ^6 ~$ t" L
echo "connect client\n";
, C5 Y2 r/ j, z% S7 [- Q6 U
}
} else {
8 ?. `" f8 E' S6 q+ S' M. e7 ?
$bytes = @socket_recv($socket,$buffer,2048,0);
6 j/ V: g) }( Y, b/ r- i' w+ W
print_r($buffer);- C) x% V. S: \
if($bytes == 0) return;' k: S3 l1 C7 z5 Y3 s% `0 P
if (!$this->handshake) {
. B5 I1 C$ O8 h4 ?( v' A
// 如果没有握手，先握手回应
* V* u2 r/ w0 g: B! Y6 {& F+ \
$this->doHandShake($socket, $buffer);' E! n3 c" n! j+ ~
echo "shakeHands\n";
" L: W" M" n @7 ~$ {0 Z& w, U
} else {
$ X5 i" J# R' k6 z
8 }8 Q. {! x$ ` v
// 如果已经握手，直接接受数据，并处理! w" P- W. C3 d0 g8 y( M
$buffer = $this->decode($buffer);
9 M5 X7 L! Z3 x4 w) x/ o/ `# u2 y$ Y
//process($socket, $buffer);
$ d( ?2 E2 H; x2 \, A, e% n* t
echo "send file\n";, y; S7 u# ?6 { v2 X( |1 B0 R. L
}
9 s2 Y% G/ ?/ z3 ^% e7 ~
}, K$ G6 C7 F% ~! k( z5 L/ w: }& y
}# s6 a0 j4 S1 _
}+ q3 o, B2 G/ ?6 l& J# I8 b3 W
}: \5 D" y& k' P) P g7 G9 e9 d4 ^; E
, `2 |# M, K6 |& f/ f x R
function dohandshake($socket, $req)
* o0 E ~ j; ^8 G" x% J# O
{
# S6 @5 H" @6 B0 z
// 获取加密key( V8 [3 V& P+ H+ h- x
$acceptKey = $this->encry($req);
1 h) Q3 B C. k1 q
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .
2 d9 p9 ~# y2 y2 v9 h. m4 p$ G' D
"Upgrade: websocket\r\n" ." `, }5 G {2 S( K
"Connection: Upgrade\r\n" .4 ]8 Y2 o9 K) A. X. E, W
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .
; ]& A9 z& k; k4 T; _; z0 z. U6 Z
"\r\n";+ G7 r! W+ }' E4 Z: \
9 T7 H7 P! f# m7 I# Z, M9 S
echo "dohandshake ".$upgrade.chr(0);
* w0 D, H/ P% u G. w; r
// 写入socket
" C. T" B0 `2 a0 d5 i
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
* F; z6 I1 I3 ^! E6 |
// 标记握手已经成功，下次接受数据采用数据帧格式
5 Z2 l: V! [4 V3 Q _
$this->handshake = true;4 H) I3 a* ]( z- F) E0 y1 h
}$ Y8 b& s& _3 Z8 |9 F2 D
8 M& \$ U9 q- j, b3 u! t
+ X7 t9 l7 `; s
function encry($req)
5 i- ~2 u" t2 Z, |
{: k9 w z7 ]( L+ t& ]* o' X7 G
$key = $this->getKey($req);
1 I! c! D7 y3 {! t7 z2 z
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";7 x: ^' h h; y6 Q+ G( F
6 L& Y; x3 ~6 P& J
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));1 e9 v5 b, K# p
}4 \6 {9 C0 T/ G: r
; o* t9 G# ]: Y5 w
function getKey($req) % G$ ~1 V8 m. w" B+ H; J2 v
{7 z& i2 T. S, H, a! Y. v
$key = null;% H# D) S9 t3 ?! h2 k0 E
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) {
. _' k6 X( ^7 q8 x/ |& B7 A
$key = $match[1]; 3 I( X. v3 r$ }* |7 o. O) C3 T6 g$ f
}" N5 U2 R6 e( o5 M
return $key;! W" g/ P: Y8 V' l
}
- X# w2 y( I' x4 n6 h
* o' ~8 T- T5 U
// 解析数据帧8 q. r, j/ |9 H0 [
function decode($buffer) 8 `, V# o9 T& B# O$ K0 T6 m
{( u7 t+ e8 D% O% J8 e" W
$len = $masks = $data = $decoded = null;8 ]# R, [3 F) M% t& Q% n0 Q: z( |
$len = ord($buffer[1]) & 127;
% A1 ^" G0 I u# s) F0 q) F
% }( E* O' C3 s/ N I8 H/ E
if ($len === 126) {. C4 m2 W# M1 M/ n/ p
$masks = substr($buffer, 4, 4);5 s( b% J/ M+ v, c1 V
$data = substr($buffer, 8);0 B+ J' G# o: {5 d/ i
} else if ($len === 127) {. a) ~; c" A1 o) J
$masks = substr($buffer, 10, 4);
8 M8 j( R( Z0 c& v$ a4 V
$data = substr($buffer, 14);
7 r& K# d ? t/ j
} else {& t l- x% s( l
$masks = substr($buffer, 2, 4);; k$ S4 F1 I1 V9 _8 e# t
$data = substr($buffer, 6);. w6 q8 S# j8 O
}2 V; R, Z$ Z( B& O
for ($index = 0; $index < strlen($data); $index++) {, g9 Z2 t: ?, ?( m K& E9 Z
$decoded .= $data[$index] ^ $masks[$index % 4];& W6 O8 b; e2 J- E
}
7 l: Y4 y( ?. e: P8 \
return $decoded;4 E, Z ~3 x8 y) I9 J
}5 [8 U" ~" C( R
7 T1 e: J9 F( w$ c. `
// 返回帧信息处理) u$ F) C U& _( X9 q
function frame($s) 9 l* k8 F: I# H( [) ?
{" T/ |+ r1 e( L# i) f
$a = str_split($s, 125);
: Z* v7 ^2 C8 d% l, E- k" a
if (count($a) == 1) {
: U! E5 z$ |4 u4 r e
return "\x81" . chr(strlen($a[0])) . $a[0];
' \6 y& c' {, D* u( b
}) l9 V% H O$ q! s5 G$ {
$ns = "";
) p! ~2 c& u5 |; w' ^
foreach ($a as $o) {
2 s+ N( j+ O3 V, i9 d
$ns .= "\x81" . chr(strlen($o)) . $o;1 b; ~6 d& W' F. K& \
}
( }5 m7 R. [1 n. u
return $ns;5 u7 O( g9 }; b( T! Z
}! `; [3 A6 p! z" u) |3 N! c$ V
9 n1 x2 b& r h/ X
// 返回数据
2 p. k, J- S5 E, E( Q4 ?% d
function send($client, $msg)
$ y3 h8 ?9 [- t, S( }& Q% n# f
{
, `. }2 {8 z/ U+ F4 U2 ^4 |2 a
$msg = $this->frame($msg);
! B' ]7 O; w: [' T; Q4 F
socket_write($client, $msg, strlen($msg));( \% u. G: i6 @! k% m5 P) _$ i
}0 P5 t2 L8 w: s6 H
}+ L) ]" e d2 Q. W0 l; Q9 g
: O$ Q( U; f! a
测试 $ws = new WS("127.0.0.1",2000);9 E, X# t* D5 m% b1 \
, y5 R3 E5 k3 x" D

复制代码

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

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

浏览过的版块