PHP 简单实现webSocket

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

1）客户端实现

<html>
' m, R' L) t- P1 [) ]
<head>
! Y' g3 ]4 J- P. V# M
<meta charset="UTF-8">
" H0 A0 ^/ I# J, X. V4 J
<title>Web sockets test</title>( n4 @0 {7 R8 K- U" v4 o3 I+ o% C
<script src="jquery-min.js" type="text/javascript"></script>! ~; z% ?0 N. a
<script type="text/javascript">
7 P4 H3 Y3 Z1 F7 C3 l* B j7 \
var ws;
+ E Z5 }# D0 x* }3 _# r" {7 Y
function ToggleConnectionClicked() {
& C1 e0 D4 u& U4 l) I( S6 }
try {* y/ h1 v) @$ ?4 Q3 \
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器
/ u# A: n z0 I' @( A% `
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};2 S5 b. R2 B; b& k0 a
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};
0 Z; o+ B3 N7 C+ Z& K
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};
; F# b+ M0 W/ K; |" ?+ e
ws.onerror = function(event){alert("WebSocket异常！");};
( e+ }& ]. Y/ P* w4 z0 R
} catch (ex) {/ D0 N9 [1 t4 `3 X: o% d
alert(ex.message);
6 I1 r9 I8 I/ }. K! O# j# j* F# q: L
}9 E( Z5 C5 Q b7 r
};+ T+ |: j8 D' E, u
, j6 F: l3 X$ O
function SendData() {4 Y( i7 s9 M7 ^; t; p& ~7 q
try{
" r" f# w: E- Q" p- R6 {
var content = document.getElementById("content").value; |. J) }$ T4 Q7 u u
if(content){; I8 b, ~/ S: G& o
ws.send(content);: `1 K6 J4 p7 L& r( [0 z: ~4 j
}: o. Y: g; X. s1 J
/ Z- V6 F5 r% k+ j0 K$ |
}catch(ex){
9 M1 `* K0 h8 h a
alert(ex.message);# ^ q, K- y4 {1 P9 Q: o. n( Y5 M1 q( J
}
& ^) X2 a8 ^2 L
};
Q' |% {9 ^. K' R, _. U( Y
) a* I+ s! L; q/ V
function seestate(){
/ `/ ^( R; q3 d# t, U0 S% K
alert(ws.readyState);
3 W; _9 A5 q( e" L/ _* O5 Q. t, O
}
( [( D/ Y, w( N' m, r4 j! i
* Z$ o! @6 L* S+ x
</script>
# R6 F# K* ]+ v& f- ?( c3 O* ?
</head>) [+ B& k* ^6 L/ Q D: m
<body>
' W0 z2 Y) S- C6 l
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />- j2 @ a, C- Q) {
<textarea id="content" ></textarea>' ^& Y* e6 b$ C6 Y2 s! S' l" D9 |1 D# S
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />
2 p: y9 j+ W4 D
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />+ g, J8 V! Z9 A0 | t
</body>
+ K8 o5 v1 h' C3 W: x. e
</html>
3 v! t5 D% j- Z) t

复制代码

2）服务器端实现

class WS {
+ ^" W( u$ N% x, _6 t5 u* J
var $master; // 连接 server 的 client
% H4 b. n1 k* K
var $sockets = array(); // 不同状态的 socket 管理4 a( z6 ^0 P; E! `
var $handshake = false; // 判断是否握手, T0 B! W# ?) q3 H" ^$ z! @* C3 ?3 s. F. A
/ \4 x+ D2 V6 ~) O: {
function __construct($address, $port){
) P% F3 A! Y8 G, N
// 建立一个 socket 套接字2 J1 l8 {: x. P% I: P: U. Z
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
; l2 s+ G' _$ M6 h
or die("socket_create() failed");
' L8 \- v6 r/ ]3 f* z% q; y& ^
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1)
) h3 B4 @" s) t& P* x0 W( }
or die("socket_option() failed");4 k) \8 W p8 x- E: L: y
socket_bind($this->master, $address, $port)
: Q+ l; R. y; M( j3 y- e
or die("socket_bind() failed");
0 q+ f* j) P9 |1 o% y$ k) q
socket_listen($this->master, 2) . A( r& n7 P$ G! ^4 `8 B
or die("socket_listen() failed");% g7 ^# a* j0 e7 F8 O: y
. q, C' s9 a$ f4 d( f. w
$this->sockets[] = $this->master;
5 ]. Y3 x. o6 K- z& s" J7 E4 P
$ A6 c, h2 m+ u% f6 W' g
// debug+ ]/ T# I4 [: o" B; |: G
echo("Master socket : ".$this->master."\n");
+ a0 k$ R0 A* z* W0 F! ~8 E
3 L% s3 N. X' [3 N- b
while(true) {+ x" E1 B/ T# I+ R& o( ]
//自动选择来消息的 socket 如果是握手自动选择主机
# {# x: l5 Y' ]/ n0 z+ f
$write = NULL;; f8 _3 @3 W2 p% Z
$except = NULL;5 H: |2 P# R+ ]8 ?" d
socket_select($this->sockets, $write, $except, NULL);4 |; A) y' h. A; n+ `0 T
2 G) X; N4 M& o% L& o3 F2 G
foreach ($this->sockets as $socket) {, L: @0 v! j; j! J
//连接主机的 client 0 x5 P' r. }4 c$ x: \9 D
if ($socket == $this->master){3 Z& a- A7 z0 g4 x
$client = socket_accept($this->master);
0 v0 a4 E: n0 E8 @ x, G$ n
if ($client < 0) {3 T( N! V, h+ ~: A( v* E5 c
// debug
7 x# A) Q( b9 R# _2 \
echo "socket_accept() failed";
; o2 q4 [, Z8 y$ h: \7 a
continue;: ~& b2 b" b: U( ?4 c) v
} else {
H) ?+ @4 f8 u7 o( k0 f
//connect($client);" \5 W, K$ F6 B. H) S2 `
array_push($this->sockets, $client);7 r7 U) O) z6 ?' l
echo "connect client\n";
9 ~- J7 f2 w0 q/ T) Y) F
}. E. X7 `, L, W2 v' d) Q
} else {
6 E, r' o1 L2 O( B2 H# d
$bytes = @socket_recv($socket,$buffer,2048,0);* @. O2 t! n- ]' p/ E0 u- r
print_r($buffer);
) S* U" w x S' ]" H7 q& b* d4 O
if($bytes == 0) return;
: B0 l- N# B3 j0 w
if (!$this->handshake) {$ t+ e7 _* W& I: R( B; w
// 如果没有握手，先握手回应
/ C- T& W: P7 y; X
$this->doHandShake($socket, $buffer);
% \. k2 I/ K, J; K- `8 d
echo "shakeHands\n";
- L* S' k0 ?2 I/ J) r
} else {
: p. s' v9 x T8 R, F
+ N+ o9 D3 M/ S
// 如果已经握手，直接接受数据，并处理+ j. f4 M" {1 m/ B& U* j8 _
$buffer = $this->decode($buffer);3 d5 _' B1 Q9 a# V
//process($socket, $buffer); ) P) t Z. G+ e5 r. C
echo "send file\n";
+ [+ |' E- z* O+ ^5 ?: e0 w2 M5 [
}+ h# \/ b4 w% I( y7 ^
}
s" N& z* K, w
}# k, o6 a1 L6 `$ }. T$ R2 g( l
}. ?4 H8 t7 ^0 A' r+ z4 `2 Z3 e
}
" K# _" Z# H+ [4 l; G1 o
. E2 p: }, J% N7 x3 ]5 G' d& i' o
function dohandshake($socket, $req)
p; _; ?& c% {9 y* r
{. h1 v' ?2 }! Z: u+ l ?
// 获取加密key
i, ~4 R6 G& g9 Y4 b
$acceptKey = $this->encry($req);* q" A+ q- K2 v) }8 Q. e
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .: o8 P5 E }- y5 h! {2 J
"Upgrade: websocket\r\n" .( D {/ v- d5 c
"Connection: Upgrade\r\n" .) i- h) ~4 D2 s F8 k+ w: k
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .
* C# b/ T+ P# {5 Y
"\r\n";. e; k# K# X1 q$ J% a
6 {3 ]/ T# g! [6 a$ F* x
echo "dohandshake ".$upgrade.chr(0);
2 c( [: j7 \: N; Y1 T( Y
// 写入socket" L. p1 r# X+ c- n3 d
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));- t4 [9 t% m( q3 Y
// 标记握手已经成功，下次接受数据采用数据帧格式+ v( X: g3 G6 ?7 ^& O5 v
$this->handshake = true;
- O/ u# D j0 X: n2 F4 c( q
}
3 Y7 d \2 p# N! I* T- X
1 t+ S' n0 j, Z
; c' D$ s$ m& V/ J! v' J! H2 @3 {
function encry($req)7 k+ m7 s9 N) Q4 s' c
{7 b& T& C# p. R2 j/ O
$key = $this->getKey($req);
3 Z1 d+ X D8 L/ m) |7 Q0 ^
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
^9 z- G% A- C
; ?8 S4 ^9 |! r4 x0 Y+ |
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
) h* O; n( X9 B7 m( k/ G; F
}
2 d* L& ?5 ], ^
: B' Z7 w8 U5 T: e5 N) G. j) n
function getKey($req)
8 B3 M% g# g: M2 Q3 _
{. C t" q* p" |" F- X
$key = null;
# c. M- e7 _* d0 R
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) { " t% w) t2 B* U0 R n
$key = $match[1];
$ i+ w9 @: M3 z7 c, d( `- Y
}
# x$ C8 g5 j' O3 h
return $key;
; s! x, z& {5 i! T- Y1 Q# o
}5 g/ b/ s$ O' [* s5 X
& d& M5 O) J% _0 v0 j
// 解析数据帧8 Y# Z4 B6 P' }
function decode($buffer) , c0 r8 k. T- V) C7 c0 Q
{
2 L- |3 m1 |% E( T, U
$len = $masks = $data = $decoded = null;. B$ P( Y) y0 X3 }# N2 b' z* S, z
$len = ord($buffer[1]) & 127;
, d$ k9 ?& L8 y; c& m: I
0 X8 f5 `- j9 z3 x# _
if ($len === 126) { Z, [) V, M" @# v* w" h) q- h
$masks = substr($buffer, 4, 4);
0 S+ d) J8 [! i
$data = substr($buffer, 8);
* F- W8 t" Y0 A+ Z* Q6 I
} else if ($len === 127) {! f6 L" i# w! A/ u5 y& T. K) G
$masks = substr($buffer, 10, 4);
0 U4 \$ ?. t5 h9 r4 W
$data = substr($buffer, 14);, o' t7 n: L* G% a6 g- E% D7 S
} else {
8 ? i) G* N7 W
$masks = substr($buffer, 2, 4);
: W( U4 x6 Q7 k
$data = substr($buffer, 6);
7 B k" X2 ?+ c( H$ L( U$ n6 k
}
C+ R/ b; S6 T' K( P! z7 H' K# g
for ($index = 0; $index < strlen($data); $index++) {
5 M6 E$ k- N1 Q- Z b* S+ o
$decoded .= $data[$index] ^ $masks[$index % 4];9 g/ ]" v( m3 X. J+ \2 w
}
- K+ l5 D9 q% n2 {- w% i
return $decoded;
1 |! C! ^% `; O1 j7 t# K# f% U0 e- ^! F
}
$ g! J) \- X0 t
: Q j. \, M: C, F- ]* t, J7 a
// 返回帧信息处理0 a6 T% z, _! E
function frame($s) 6 F' H% X* B( V1 H1 h# v5 @% g
{. g" {* A) i& E+ T B. B6 F
$a = str_split($s, 125);
1 i4 ~. U6 \ G6 R2 y' E
if (count($a) == 1) {$ G% u4 ~% X) o: W' {" V
return "\x81" . chr(strlen($a[0])) . $a[0];
8 b9 q/ Y0 i8 J- h* e
}7 y3 Q4 [) E' Z% `2 Y: Z5 q
$ns = "";" G% f- E* }* f' d
foreach ($a as $o) {$ \5 q, N# B5 b" B2 P: f
$ns .= "\x81" . chr(strlen($o)) . $o;
: L. Q" p3 T6 g0 [! Z( u
}
2 X8 Y3 q0 r+ i
return $ns;+ s7 d' R4 t2 I5 k
}
; x8 d' p" [ y6 o
/ H7 Q! i7 ~# }, F3 f! \
// 返回数据
" t& k N, [0 W8 v- T
function send($client, $msg)
/ K) l& ?2 X; `4 e/ ~! ]1 j4 N
{+ z! G, v& a& B* U& h5 Z
$msg = $this->frame($msg);- {- e, s. T6 h# o% m( x
socket_write($client, $msg, strlen($msg));
- ~% D& t0 f+ m8 H
}' _# v1 K; o6 B& ]7 ^5 e
}; O C4 l8 s8 @( z8 n
: L& L* U, y" ^$ N& M
测试 $ws = new WS("127.0.0.1",2000);& |5 v7 O4 @1 C1 c$ {
" R9 A6 p0 g8 d6 d) s# x

复制代码

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

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