PHP 简单实现webSocket

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

1）客户端实现

<html>/ K$ Q3 P% X( N" M
<head>7 h3 Z& b0 _3 L, D
<meta charset="UTF-8">3 v' N5 h- e* f# a
<title>Web sockets test</title>6 R4 p$ |; d: k1 I% \& Q; o* F
<script src="jquery-min.js" type="text/javascript"></script>
& q/ V( N/ I c6 q" C1 [% @, R; j
<script type="text/javascript">( H: F2 y+ ^. T5 C4 M; L
var ws;
/ `* b4 | B8 s- l$ h
function ToggleConnectionClicked() {
- T1 E0 X1 u. [) f% `
try {
- o) B' ]+ J5 _' K6 @4 w/ b
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器
8 ?5 f9 G7 \5 s4 N
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};5 b" G0 W/ d/ ]% H( C
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};
( C5 C8 L" c4 \( D( F" x7 j# k' P
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};; x, m, l W8 i: Q8 D
ws.onerror = function(event){alert("WebSocket异常！");};7 R! r' l0 j5 R) ?5 T3 I4 z
} catch (ex) {+ U3 j' {& X% |1 Q# _
alert(ex.message);
( V( }& N+ i/ t
}- a: V5 S, C, h0 Z
};2 i0 }, d" c5 U
2 D- d; [8 Q# `& h0 Z
function SendData() {1 i0 s2 c0 f$ ~
try{
' L" F \8 {3 J, I* M2 M
var content = document.getElementById("content").value;
0 A8 g. r' d9 j0 k; O0 y
if(content){8 H9 [. d( @4 T
ws.send(content);9 N3 s: A. G' Y5 _+ Q
}
2 V j# Y/ E& N
% g1 s/ z0 E/ o: ]
}catch(ex){' w( T" v' Z- L
alert(ex.message);
5 d e6 g* j& I
}" O7 U4 a. D% p8 |1 _0 K: _
};0 V& G5 H+ @0 w! Q+ i
[& u. p5 c; a# ?. q0 k: ^
function seestate(){- Q7 I& o3 s( J K
alert(ws.readyState);9 M( D, P: a3 N5 C- A0 j
}
; p0 B8 d6 D' t; N5 Q2 _, X
. [4 A2 v: l; w& w5 s
</script>
8 @+ V" l2 q) ^: |/ Y% v# |4 u
</head>( h7 p ~ J& n8 x7 N" x! p
<body>
# V( P# X1 _( b* {; S, [2 b
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />
# r6 j3 ?; {+ l b
<textarea id="content" ></textarea>
* D8 c$ b0 u S% X) x4 a
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />
8 v( C6 m% L- }% G! v' ^
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />
9 G T" D* _ e+ p
7 b0 J1 g1 Y1 k& Z/ a
</body>( I0 ?; a5 a B
</html># A U% ]/ S# i* D" r1 D8 q

复制代码

2）服务器端实现

class WS {6 k7 z$ \: X: P& r) {; Y( E
var $master; // 连接 server 的 client
0 @# H' |& V& \! ]- c
var $sockets = array(); // 不同状态的 socket 管理
l! s# h& Z' e/ s) w
var $handshake = false; // 判断是否握手; ?! E t2 X! v
! g* }) V. Z7 _
function __construct($address, $port){
+ P' s5 _0 c- g* b& U
// 建立一个 socket 套接字- n( B- _7 j8 a- e& B
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
/ q/ m6 T/ j% h8 C$ U7 J& j+ c
or die("socket_create() failed");
0 n: M* n- I+ Z5 @* ]
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1)
- C X% N6 m g2 S7 R
or die("socket_option() failed"); l4 c$ Q9 s7 f; g/ T1 a
socket_bind($this->master, $address, $port) * s% K% s+ E6 D
or die("socket_bind() failed");' N$ y/ |2 u# S' Z6 @ c) |1 }! v
socket_listen($this->master, 2) , [& y% V4 g" k1 R" E: `
or die("socket_listen() failed");
" t3 d2 x% g( `- ^; L- f
$this->sockets[] = $this->master; r' u g& Z; u* ], k* u
# y _; }* g5 R1 H: ^5 U7 g' u% z
// debug) K g9 E0 \4 D) {5 _
echo("Master socket : ".$this->master."\n");8 r, Q: r& o9 t# B; N/ ~
0 C$ }3 {# V, C- }% ?. _
while(true) {! v" w6 T6 L6 l+ ]5 R- j
//自动选择来消息的 socket 如果是握手自动选择主机
" Y. s# O) z; {# }$ C* N
$write = NULL;
" Y7 _2 u/ s V7 x# U& Q. h4 e! y
$except = NULL;6 z/ K3 [/ D) U
socket_select($this->sockets, $write, $except, NULL);
- s$ `8 o7 P+ W
! @; C1 y$ i: q# @4 E
foreach ($this->sockets as $socket) {7 ]) i+ a4 F) S* ^$ H8 u
//连接主机的 client + J& {8 t- {+ [
if ($socket == $this->master){! p# J6 f* \5 }1 @1 ]# ?. W
$client = socket_accept($this->master);7 @' F: o' l, P6 D8 t" j
if ($client < 0) {
/ T. V& e, u( [$ J* e$ J
// debug
7 \" |) D) u( n+ ?
echo "socket_accept() failed";. |! L( A1 T1 g% b
continue;
, d+ ]* [* n" A, w P
} else {
' L: I% H6 |& G3 r( F' ~8 |
//connect($client);
5 V( Y' c. A' v. b' Y) P
array_push($this->sockets, $client);
C" L0 D) t- O2 O5 G* I
echo "connect client\n";6 d) H$ ?: z) A% E1 l- k/ g2 Q
}
: g7 @8 u, ]( d1 l6 q
} else {
& Y. Q* @% ^+ c& W- m7 O
$bytes = @socket_recv($socket,$buffer,2048,0);& N( ?+ d; U5 E& u
print_r($buffer);, B2 G: l* z# ~1 z" C# S0 g
if($bytes == 0) return;2 M3 a8 a _0 Z5 m# w! m3 l
if (!$this->handshake) {
4 p* i" a Q0 Q. _( d
// 如果没有握手，先握手回应8 ]# B: \" I, P
$this->doHandShake($socket, $buffer);
( }- ?. }! r, {! U! Y0 B% f
echo "shakeHands\n";
7 p# {7 |+ O7 x, `7 T- d
} else {
' R( d2 @6 g5 U
4 d/ d) U& _1 h% N, c
// 如果已经握手，直接接受数据，并处理
9 F& _, Q) e- H6 S# [" @
$buffer = $this->decode($buffer);* c$ x! N8 ]& `5 o3 q4 M' L3 c
//process($socket, $buffer); " J+ y, z) E4 D
echo "send file\n";8 p% b6 D; _/ o) r% t
}+ L7 [4 n( a8 B) |' K, I& `7 `3 _
}
6 @! ^$ F/ k2 \" i. f* |. k
}# R7 l/ m; ~7 b* N
}- w' _2 A4 E7 }, O/ I
}5 I" M, G6 L3 X( X
# V; ?+ V6 }. B
function dohandshake($socket, $req)* z6 O5 l7 l8 E9 ~+ @% j+ v+ U$ _
{
; a" _. h# y7 w8 u1 d/ B; O
// 获取加密key
+ o* v! S% g9 c8 U2 O
$acceptKey = $this->encry($req);
0 W `1 ~- Z E
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .1 L6 Z. Y, I7 \1 Q# U( V
"Upgrade: websocket\r\n" .
% S( P7 L q& b* T; W7 Y
"Connection: Upgrade\r\n" .0 d; ?# @5 c) I& {2 v% m
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" ., B7 v" H8 f) m* r: q/ _ `+ r5 {4 w% u
"\r\n";9 w- D$ h) `( H- ], P. H& \
6 U: p8 |0 N' L* N! E; g
echo "dohandshake ".$upgrade.chr(0); 4 U7 {/ t& p9 s" L
// 写入socket, {/ p5 {$ |+ [
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
Q7 Z/ h$ \* T2 a
// 标记握手已经成功，下次接受数据采用数据帧格式) |4 n3 _ p" r
$this->handshake = true;' D7 @3 j) V7 t/ o% @. C
}
# R! }" [0 b$ Z, g, v$ N' z4 k
# ~7 P' @, z0 d+ e& z
5 r" @2 z; c7 `% @# y1 y/ h O
function encry($req)/ w; C4 ]! A0 D! y6 v/ {2 y
{) z6 {1 R' }5 |5 ~0 Q: v( Y
$key = $this->getKey($req);
2 N# ]$ Y. |0 E0 f- |2 d) i
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
; S+ V/ X- V& }- C' ?: X
0 b2 z* D, r6 j2 Z' H
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));! n; y% B2 Z- l: d
}
& y/ P2 c ~$ `0 Z4 z# I% w) ]- `$ L
" j; T8 }+ R7 n% ]% P* [* K( F
function getKey($req) ' P) U S+ Y) n. j, B
{* Y3 b9 ^* f5 w5 d) s
$key = null;
1 [' s7 Q- U+ A6 a: u
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) { + x1 b# J. N, J" k/ T
$key = $match[1]; " }# s8 ~. F$ C5 o0 X A. a
}) m0 y! |3 M# ` L' ]( e) T& N
return $key;
: F, C+ N+ w3 ~1 s' W& N2 R- `( M
} N) E1 a& `$ O/ G9 J3 Y
" j+ k$ E- F) i& g! z' L
// 解析数据帧
$ y: P. H& Z( y7 x' O7 |
function decode($buffer)
1 b$ w1 c% O9 k* B6 K1 E5 \' M' U1 h. I
{% f5 Q& s7 N2 `1 B6 R) h
$len = $masks = $data = $decoded = null;
' j1 h% [% e$ [3 m1 _4 F! e2 [
$len = ord($buffer[1]) & 127;
" d' C* _" b0 t* b6 o
& A" |7 }/ v9 p5 E. T
if ($len === 126) {
+ k5 `% a% i* p, ?0 s0 f$ Z- C
$masks = substr($buffer, 4, 4);- l3 M q7 J9 J" G4 {8 g
$data = substr($buffer, 8);
( G7 C* a9 \1 j6 A8 P& u: Q
} else if ($len === 127) {
, Q& C. W8 v9 [
$masks = substr($buffer, 10, 4);
* m, ^; o2 X0 J1 ~% q! e1 c
$data = substr($buffer, 14);& [2 w8 W) u* z5 Q; s
} else {
: f- m( e+ o$ Y" r
$masks = substr($buffer, 2, 4);
. d$ {7 V8 h; L* Y. }. v; {
$data = substr($buffer, 6);0 e$ I' o: @3 s
} p7 C/ n/ K6 G: ~# ]
for ($index = 0; $index < strlen($data); $index++) { l9 c9 K( [9 ] C
$decoded .= $data[$index] ^ $masks[$index % 4];% C! P: }" U g. F9 L' d/ `
}& o B! [: `# ~
return $decoded;
) u, R+ M5 ?: r" ?- \
}/ ?* m9 C3 P) ?7 Z/ T4 d+ y
1 c7 ?8 d' K5 s% G9 n
// 返回帧信息处理3 @( ~/ [' B6 X' n. Z2 ]
function frame($s)
* D, E$ r; U; t/ A9 A
{
! s9 | {" W, ~" P- X
$a = str_split($s, 125);6 b1 {' u+ Y) u( |( ]. I7 z- A
if (count($a) == 1) {
2 I3 s9 H& {3 r6 k# n
return "\x81" . chr(strlen($a[0])) . $a[0];% r. k2 _# ] o
}
, Y( W+ l0 f9 K9 }% y6 u5 x
$ns = "";$ b: |$ k) s/ _7 Z. b4 v4 `
foreach ($a as $o) {
/ }% L7 V) C* |* S3 |( _3 S" s
$ns .= "\x81" . chr(strlen($o)) . $o;
( a, I( H' {% }/ Y# o* v* Z: o0 C& Y
}) x% a+ D6 U' w5 o$ l# j% m
return $ns;
. t+ M5 s$ n. n5 s/ x" @- e
}" b l+ ?. L+ |+ T
/ {1 n; l( K" M7 e, m9 J
// 返回数据+ _) ?. S4 G: ?* h ^6 s- _
function send($client, $msg)/ L- M# B; C) i8 D
{) P& a- o( m6 z& k. F4 d: m! z
$msg = $this->frame($msg);
+ r! n4 b, J: `( T' D- x
socket_write($client, $msg, strlen($msg));
0 |3 y% S" ~( D3 ~/ ~( {; n
}! S; P* n! V$ L& x {- k9 f5 W) M
}
. S4 A9 [3 l6 L
5 r, u% q1 k6 y6 b; L
测试 $ws = new WS("127.0.0.1",2000);/ x9 r. H5 W/ y# }- d" u4 F9 G
$ C% K$ B: E, u2 d2 h" {

复制代码

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

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