PHP 简单实现webSocket

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

1）客户端实现

<html>" M7 s! U) J* f5 Z7 u5 n4 k
<head>8 ?$ `2 C) x- K
<meta charset="UTF-8">8 X6 c! W! F# B
<title>Web sockets test</title>( C& X0 G0 T, u( _6 D' k0 P) \& Q
<script src="jquery-min.js" type="text/javascript"></script>9 B9 A3 l2 @) x! T
<script type="text/javascript">
s& T9 o: G9 O
var ws; g( j3 Q# m! }* p$ K/ {' U
function ToggleConnectionClicked() {
0 C9 t4 D! v8 R* z' }! ~' o6 z
try {
# e( c1 V: M- t# z
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器
" L/ t: H( U! P' M' Z% l, f
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};% l- d, e1 _, D0 x& P: U' E; r; ^
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};
! G: X8 i4 p8 s2 x/ E
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};9 e% A# t' [8 T- H& @
ws.onerror = function(event){alert("WebSocket异常！");};
$ L V' ^ G( l; @" r$ a
} catch (ex) {
6 |5 E9 R! h$ M) D7 K# W1 m% _# \
alert(ex.message); 4 i. n4 ~9 K( I' v% ~6 y* o& F) U0 f& t
}
: b& F9 B) @% c. W" `6 x8 u
};! E( a' t5 ]9 \( y; f- i1 k9 M
& u0 {$ w8 W& V5 a. n6 Q
function SendData() {
6 d0 `0 T0 t- w: `$ d; b
try{
1 `9 D/ [9 l8 z" s- E+ ~! H6 p# j. P
var content = document.getElementById("content").value;
% p) w& @" ^1 u; Z
if(content){
; e a& T. s9 t @9 }) _
ws.send(content);7 t. K; T% }5 R
}3 Z9 T) Q, G: a T8 r, R: ]
}catch(ex){8 ?& `$ W3 F* I0 k( Y/ }
alert(ex.message);" s9 J, r, }: I5 b" S
}6 H8 a5 R# h$ Q: L
};
6 E& J* k' M* o5 ]6 j. e" y
; c+ z5 T6 K! f p
function seestate(){
s0 E# w! H8 z& u2 z
alert(ws.readyState);
" ?) A% v1 e0 G5 d% K
}
6 l3 {- e5 K# D1 p. o( K9 [, D
7 E. z0 N) P, K w
</script>$ e2 S( _: {; p# ~
</head>5 V( v! n3 O$ K/ d! c t
<body>, [# T5 q7 A' E H6 o
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />. y3 ?( K% E" d
<textarea id="content" ></textarea>
: F- ~; d/ B r7 `" f
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />, A, X" R. l; u4 `' f( ?8 e
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />
S$ e5 c! ^. V' X, C% m
' [! `, |5 Q5 m/ H/ Y& Z
</body>3 G5 j% @! f o5 p5 q7 I+ I) a+ Q, m
</html>3 x4 L0 t2 r$ U4 h& ?7 Q4 i

复制代码

2）服务器端实现

class WS {; Z& b& V6 i* a) Y- \
var $master; // 连接 server 的 client
' [* |% P5 L- Q* ] p6 T/ y( h
var $sockets = array(); // 不同状态的 socket 管理- q0 Z7 L2 j" _/ \, ?" Z1 N
var $handshake = false; // 判断是否握手* `/ }# }/ F; n+ W- A
: @& X# r/ w, e( }& M. s/ @+ Y
function __construct($address, $port){
: i9 F& m( r. z+ A, q* z- ?: `
// 建立一个 socket 套接字
+ w1 R# Q1 G. h# d( |& T
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
1 ~/ v) x# \2 [7 s+ ]9 J
or die("socket_create() failed");
; c) e0 ^. C) m6 D0 o2 o) l. Y
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1)
; \+ n) w9 F# ?/ T
or die("socket_option() failed");
- O* w5 V" ?9 g0 F# R/ s1 y7 R
socket_bind($this->master, $address, $port) $ m3 z4 l. l5 H" z7 Y
or die("socket_bind() failed");
( {* _+ M. g: _
socket_listen($this->master, 2)
- R3 p9 l$ d% O8 I, B
or die("socket_listen() failed");2 M! C% d& g# o/ n E% }% Z
# s% v3 m0 A5 ?& c# O* Z2 q* b
$this->sockets[] = $this->master;8 \/ K2 I2 C/ k7 w
6 Z/ N' z1 N6 M; z/ `1 w
// debug
0 o5 \; A1 y% Q; Z: t( ^ d2 g
echo("Master socket : ".$this->master."\n");" a& W3 P- @6 I3 s9 a% `: f
' D7 @: h x3 r7 w5 Y
while(true) { V& t; w9 o3 H. M
//自动选择来消息的 socket 如果是握手自动选择主机+ R* s' I# z! I9 v
$write = NULL;+ L$ O" S0 F- x( @$ w/ ^
$except = NULL;' d9 k0 `( n# M+ B# _# p( u
socket_select($this->sockets, $write, $except, NULL);' J9 X( ]$ X# E0 \( }( N
: D7 n1 _( c8 X
foreach ($this->sockets as $socket) {& L# q- r2 C" N }% f g+ y; |
//连接主机的 client
! l+ V* K% S5 H' v
if ($socket == $this->master){
6 d- m: V7 J' x- E F8 H
$client = socket_accept($this->master);" F: s. V3 n5 b, J6 M) A4 A5 t
if ($client < 0) {7 ^- f. A1 A' v% C/ v
// debug
/ u1 ^5 l+ J$ Z$ w# E0 T D
echo "socket_accept() failed";8 ~; {/ T, Z1 D5 V, N: p( S$ d
continue;
" M6 k# F# j9 O* l* I& f
} else {6 f: j( i3 z& d0 D+ H
//connect($client);! t B( X8 c" k, j3 |. H
array_push($this->sockets, $client);2 V* u6 a& [. @, l+ M
echo "connect client\n";. n( W7 x) a# S: P' P, C, X/ v
}( R2 o( B4 N& \6 x K
} else {
& N. Q6 b/ h d
$bytes = @socket_recv($socket,$buffer,2048,0);/ y0 S8 Q: U# Y0 G
print_r($buffer);
% @* y" S! B, ]2 |5 d9 C' T' L M
if($bytes == 0) return;
# G$ v9 l. _ X5 h# [9 s
if (!$this->handshake) {
* i+ m$ {; u9 S Y# H. p2 E
// 如果没有握手，先握手回应% d' o' |5 C+ h! Q
$this->doHandShake($socket, $buffer);8 V' E2 A8 n1 `7 W9 u
echo "shakeHands\n";
- l0 _9 B' e4 C/ f
} else {
* P$ x6 }: Y$ _
2 S M* y2 X$ x7 m
// 如果已经握手，直接接受数据，并处理) m2 Q! r6 D, P" n1 h, f
$buffer = $this->decode($buffer);
+ |/ I- B* G! Q. M
//process($socket, $buffer); % }- \1 Y6 R# u, n
echo "send file\n";
/ R8 I# q6 H* Z+ L' d& m
}
! @$ {. |8 ~! Y8 H: J
}: n! C- ~3 c- ]
}
, _' ~7 H2 o" o/ y
}, d0 j3 z; o' j& x; |
}3 C/ w0 x2 X" b, m( N
# L$ x {! t6 l4 E& v$ y
function dohandshake($socket, $req)
8 Q( }. ~( S( ?! H# Q" q( X$ A* M/ Y
{
+ z1 v# E4 I: C( K$ [) H" s; Z
// 获取加密key8 N$ n/ @# @0 W0 `0 c+ K1 ]
$acceptKey = $this->encry($req);
' p4 Y6 X' u( P8 ~* o4 `. |
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .
% z- |/ j3 ^- D" ^! b
"Upgrade: websocket\r\n" ./ d; E' v+ @1 p3 l( K7 |
"Connection: Upgrade\r\n" .
: {+ ?) s( F; v# T1 s& {; D9 k
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .
/ \; e# W1 v% S" f/ ~
"\r\n";
; c# B- y, O& \6 a# \$ S
0 k) h3 f6 _5 G6 z8 ]0 ^) e
echo "dohandshake ".$upgrade.chr(0);
# E! E! _. c$ z/ O) [* S
// 写入socket8 p' i$ Q3 f3 L7 ?
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));1 V0 W3 V) Z" |6 r/ j
// 标记握手已经成功，下次接受数据采用数据帧格式
: x! r N( v: c U5 F, w0 ]
$this->handshake = true;
* i, g6 j" v! \1 {( C, l
}
& T( ^5 `9 [2 j$ z, T F
" y! L0 M/ N3 v: m+ Z
9 t* e9 r/ T3 V% s3 a" l7 s
function encry($req)0 N! J6 _- u4 C% T p
{. \. s7 |" m- y& \* H7 F; k
$key = $this->getKey($req);6 D; C1 P/ f1 _4 t4 }; D; F
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
$ O. B% B/ I% |3 a& @0 @
3 B1 T0 G5 U3 Z x3 b, F x
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));+ I4 ?* t) V9 r2 D6 s
}5 O7 m' G; I7 N( n4 S
& n, `8 u4 N' \
function getKey($req)
. O: P. P* X3 V7 p
{: u: W) [6 t2 X
$key = null;
$ n* Q* }; h! g% _
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) {
3 f' h# C: y) E& \4 ?# d
$key = $match[1]; / V% Y' F8 d# F3 `) V
}7 e0 m }/ N9 l3 X/ p1 i
return $key;, G' V$ {2 z3 v. f% K
}# H; b+ x* T$ ~( S* h- q
2 R8 g/ M2 |! c; `) A
// 解析数据帧& a. W. P+ I2 @- `4 q# q# L* k
function decode($buffer) ) b, J; k/ v9 P
{3 ~/ y9 R5 P2 C! E) W9 J4 R6 V
$len = $masks = $data = $decoded = null;+ b; W- s' q+ A
$len = ord($buffer[1]) & 127;
' r' C" Z$ i& q0 w, \, ~5 Q
' v" b+ L+ B8 M6 D
if ($len === 126) {/ i. u P( A- V T7 B3 d
$masks = substr($buffer, 4, 4);
K* p: u+ H7 h2 R( n) x
$data = substr($buffer, 8);! L# ?3 M. ` i2 j
} else if ($len === 127) {
/ R% p+ }9 h( V2 G# U6 Q& X7 E
$masks = substr($buffer, 10, 4);
9 v# C# A4 W$ y# \ U3 `9 ?
$data = substr($buffer, 14); a% \8 z. ]0 u5 A v8 V: t
} else {
) b: i, W# D4 r0 H2 u- \0 b
$masks = substr($buffer, 2, 4);
- A9 `# [6 C& z% y, Z6 @6 P8 j
$data = substr($buffer, 6);
3 F" C$ K4 e. @: F* o& c& |( C
}
& b( y% X- `& E4 h8 r
for ($index = 0; $index < strlen($data); $index++) {6 Y' i! l8 b, |- `5 D: F& J; w
$decoded .= $data[$index] ^ $masks[$index % 4];
! h. W, R+ @, |
}
) B- k- |( [ g! |6 p) x
return $decoded;
" \6 n2 Z1 r3 l0 T# d
}# M, N' B( p+ C3 E
$ g* V; `- O/ P+ z
// 返回帧信息处理# N$ W- e$ \ r$ X# g9 Q }, t1 q
function frame($s) / K8 d6 n( E c) C* B6 q o9 v
{6 o* }, z [3 X2 J( ^; a7 }7 {( V
$a = str_split($s, 125);
1 T2 j8 k7 T3 { M1 Q$ E8 S
if (count($a) == 1) {
' l- O9 s8 {% |# [$ x
return "\x81" . chr(strlen($a[0])) . $a[0];
$ ^$ v% F/ E" s+ t. b, C( `2 y1 `# X
}* a& z7 n& n! h9 w# z7 C
$ns = "";
) y8 y3 x, K- t; A/ e# X' X" ?
foreach ($a as $o) {
2 X$ n- Q. j. [5 F; ~; I+ x
$ns .= "\x81" . chr(strlen($o)) . $o;; B/ T9 T# h n5 ~& j
}2 O! p8 L) o. q$ H7 V4 {+ a
return $ns;
. L+ Q+ h( v1 j5 S
}. d- U2 T* T0 _+ D5 u6 ~
! J. }' X3 P1 G8 j: H* X6 r; ^
// 返回数据
$ o9 a( I$ n4 l/ C2 \
function send($client, $msg)# F! k4 X l9 b7 a: o" V
{3 H! D, e# q- p1 [& m; \
$msg = $this->frame($msg);* R+ |8 S5 H3 ` \4 u& @) P0 C' S! d( M
socket_write($client, $msg, strlen($msg));& t3 k/ C6 f/ }. w9 l/ ?8 q9 i
}/ {- r( [9 ]7 d+ E9 r
}
) v! @& V* a) I0 ?' N2 n7 x0 }
% a/ O9 V( H4 z6 U) Z0 t. Q% H
测试 $ws = new WS("127.0.0.1",2000);
. m( t+ T' y- w, I( U4 \/ q
' |8 E; c" l& p4 Q

复制代码

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

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