PHP 简单实现webSocket

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

1）客户端实现

<html>
9 v4 C9 P# U' o
<head>
5 q5 x/ ?9 X9 E1 |; q4 T
<meta charset="UTF-8">4 d. @: |3 C' G
<title>Web sockets test</title>
& \& q q5 [0 M$ D4 [3 |
<script src="jquery-min.js" type="text/javascript"></script>
2 A4 ]$ ^5 G2 X8 ]( D
<script type="text/javascript">
+ L, N$ w* ?6 p/ p
var ws;
3 A" M$ m8 f# [/ \
function ToggleConnectionClicked() {
) m: S2 U6 \" t5 y5 G) l; i
try {
) l8 d- X$ c8 Y, W. z8 R4 B
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器 ; p% @' \9 J3 e% d
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};
* C, D' L# ~! ~$ m M- b
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};: S0 e, z$ B) u& m3 L g; ~
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};5 F. D3 w: q0 Y+ g) ]
ws.onerror = function(event){alert("WebSocket异常！");};0 f& S) V# I! x
} catch (ex) {
5 k, L% a5 E9 t! O i; |
alert(ex.message);
8 W( e& \9 p4 M2 W$ B. d; z# h9 A
}
( D$ R7 V# w( L4 M+ h! m. s
};& A* r, ]& [1 ~. O' @' O' @5 M
1 m- Q& t; ]. \2 O1 Y; U: p
function SendData() {
. b0 D7 l% ~% a9 v+ N
try{5 d& m% n. _: r1 D* L6 b) N2 u
var content = document.getElementById("content").value;- s0 r" T1 @2 t& h; V0 X
if(content){. q4 J0 Q' h8 g' H' J3 ^) t
ws.send(content);. @% q1 z4 `4 x* o9 F, H' k
}& W9 R, }( a5 d& E3 O, u5 b
- z5 W9 Y1 |$ ]* t- l) M
}catch(ex){
+ E; N0 ]' v7 T- f$ b
alert(ex.message);
; j& e1 m' v! s" A" n1 S
}$ o/ |" E; |: I$ j
};
; T- X$ a4 z3 ?4 I
4 z; T( M1 m5 @. T3 O+ H4 r
function seestate(){! j& M" `1 F9 `; f4 C/ n
alert(ws.readyState);
" Y8 s5 T0 Z4 m
}
. J" F! Z! n+ b$ E2 r3 F7 T+ D
& e" S7 a% [4 V6 w2 v5 L5 D
</script>6 F. I* g* g- V$ u6 D; c& A
</head>
# g. i) V% b6 F p% U& B0 B
<body>2 J3 E2 c2 U& l
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />
/ Y X( r8 \+ Z4 T, f2 ]& F
<textarea id="content" ></textarea>7 Q `+ V& B3 u6 Z% S# [" l+ b# h
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br /># D3 F# D% l( `7 `
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />9 i6 a. x. n' Z( X3 Z
4 ^. z6 a. _; ]
</body>
. S- n% R8 d/ A6 y5 _8 i7 o/ h( n
</html>7 n& c5 H# \& S0 e, b

复制代码

2）服务器端实现

class WS {
" V1 a3 b( r8 s( I" l
var $master; // 连接 server 的 client
8 w( M1 d4 |0 y( p# C1 I
var $sockets = array(); // 不同状态的 socket 管理
/ R6 W* ~5 e) N! w
var $handshake = false; // 判断是否握手. F& Q& x& F2 E' l1 i- Z
8 Z' w, O* v+ s- T8 s
function __construct($address, $port){+ F- U( F: }/ v) i: ^+ o
// 建立一个 socket 套接字
6 K( A1 i/ z/ C: }
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) ) ]) K6 R$ p/ M% H
or die("socket_create() failed");7 O, S$ n4 q/ ?% g x4 ?9 J9 Q3 ~
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) # R: ^7 C2 B' h7 n: L1 f8 q9 l
or die("socket_option() failed");
8 @$ T7 K t" n' G
socket_bind($this->master, $address, $port) : o( }, g. G% k& c. z- G: j
or die("socket_bind() failed");! o8 P, @/ q( @
socket_listen($this->master, 2)
9 R) S2 V& z9 H* \9 t' {
or die("socket_listen() failed");' I+ x. V( z! q: [* T- R
% p9 l; V% c. |' R. l/ R
$this->sockets[] = $this->master;$ I# v! ~0 ?: R* A% K
9 |6 |: O) v9 F6 e
// debug
& t! o% {( w) a; T1 l; `
echo("Master socket : ".$this->master."\n");0 M9 N' M) ]# k/ [& M( y' ]+ V9 O
. d& }. }& m8 j9 p) l; H
while(true) {
3 p! `( n* {# D" B
//自动选择来消息的 socket 如果是握手自动选择主机
7 G: v; O1 O2 G- T# p+ g8 W/ w5 y
$write = NULL;+ Y: P" r4 @( N" z
$except = NULL;+ w: J& T' T: ]/ u4 i G5 X
socket_select($this->sockets, $write, $except, NULL);; V" j d! @$ n2 B3 }+ d3 Z
5 E9 o3 C& _. q4 o {
foreach ($this->sockets as $socket) {, p$ Q! c2 e. \& @
//连接主机的 client 4 @ ^7 {& I' a, \
if ($socket == $this->master){
* t. j n& Q. i8 n* G# s8 E+ L5 s
$client = socket_accept($this->master);5 e' U( Z) L6 w' X# V. r
if ($client < 0) {7 x8 D0 m. }- q H- W4 b' B
// debug: X8 T# A0 ?) T. a j
echo "socket_accept() failed";
4 s( \, k0 F; K# \# v
continue;9 O4 X6 G: ^/ g A6 r
} else {% I6 ]! X: x8 f. g. M
//connect($client);
* X p, q9 E$ D5 {( [+ }6 v
array_push($this->sockets, $client);
) R8 t& Y D/ u7 z9 U" f
echo "connect client\n";. \. k+ Q5 V& z0 ~
}8 r6 l* x! v- w8 l2 U# U
} else {4 G6 E2 \) f* I$ r
$bytes = @socket_recv($socket,$buffer,2048,0);, |% z$ P8 V% k# x; e. M! ~
print_r($buffer);/ O1 c0 y5 `* x% m6 g1 A) _
if($bytes == 0) return;
) @( k8 x' j+ l; H$ S0 U
if (!$this->handshake) {
# P5 }, e5 {. M# X8 d
// 如果没有握手，先握手回应
0 |$ G, M! b7 V' P4 |: x
$this->doHandShake($socket, $buffer);. f2 v3 ? d& p9 ?
echo "shakeHands\n";3 ? F) ?( |) _$ o. V7 Y& w
} else {9 Y. d: q6 \" a7 ^
$ M9 J8 ?. o* W- _6 y- U2 i6 V4 a
// 如果已经握手，直接接受数据，并处理
- M8 o0 m$ L3 c2 Z
$buffer = $this->decode($buffer);3 b* `+ l7 S4 f' n% y, W+ ~
//process($socket, $buffer); 4 u+ b) n. ]4 s1 ~* V; M
echo "send file\n";5 r; g/ P, F9 k0 @1 f# a
}
+ d& \& C; O6 y4 P2 q4 x, y
}/ h& M5 g" y3 h5 ]2 P
}1 M( ~; O2 W( b% [" ?6 V' }
}
) s) G: r; `8 c, Z
}
/ f/ h# z3 W3 h K$ M2 X$ q9 Q
2 s0 L6 I2 P! o0 e) b
function dohandshake($socket, $req) s& w1 G6 {8 Y; g9 b
{7 ]* i( B% F5 }0 L
// 获取加密key; i; Z' L I* x& ^6 _9 Z
$acceptKey = $this->encry($req);6 |! B1 u& c e U2 ^# i a
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .
, ` c4 q" V! P. D+ o
"Upgrade: websocket\r\n" .+ t2 n" u: ~9 H6 P J6 e. J: k
"Connection: Upgrade\r\n" .
S( A, b- ~: O% T
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .( ~( l! J4 f) o, n
"\r\n";
: f( c8 z" g1 v$ |. \
. A- M3 B3 A$ `- {: q* }# T
echo "dohandshake ".$upgrade.chr(0); 0 Q+ r l! Z/ C- a g, I
// 写入socket4 h! M2 u; A' N7 ]
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));4 B# X, V# k) W2 K
// 标记握手已经成功，下次接受数据采用数据帧格式1 }* c k: \, J' r' {1 o
$this->handshake = true;2 a+ g3 J/ q- |
}
% b1 o8 X- l3 \, f$ |
/ m5 i! h/ o; }- v* x1 W
- R3 u+ m' J5 w6 K
function encry($req)
{7 x1 |9 O4 I" s; i' Q
$key = $this->getKey($req);
0 I) v9 c4 ^, G- S
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";; q( w: C* U6 B3 C
4 B, f& I2 `. j. m0 |
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));3 I$ w1 c, K% A2 e
}
4 t! S4 c/ J6 {' n0 H' m( H
6 t5 a1 I- `, o# v7 N7 S3 M
function getKey($req)
' `" b. j% x+ B b3 }2 [( P2 x1 h
{1 K) K* @* r1 e3 d d) @: D( a
$key = null;
1 m; {, R# y6 b. G
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) {
+ _, q5 B4 c1 {# R; ^. y
$key = $match[1];
, h9 J7 x" n6 D3 X8 J$ |
}3 R# ]0 t E8 G. N/ c4 t7 K
return $key;0 f- i1 h& e2 E O* @6 A) ~4 i
}
& B7 z! o0 b% M5 q# B! }. ~
2 E" d% q x4 m) h( J4 f
// 解析数据帧
2 e- M. s4 O) I- l. i( H' j
function decode($buffer) o) i! e9 G& X6 V
{3 d3 A5 `0 K0 E, w% U
$len = $masks = $data = $decoded = null;
) f+ T- f8 I5 z
$len = ord($buffer[1]) & 127;
% N$ j1 m4 ~! `( K2 Y* R
. [5 r$ h; J0 ~
if ($len === 126) {+ V/ O5 K# Q( @6 u! n# F$ u
$masks = substr($buffer, 4, 4);: u+ Q+ x4 F+ U( m( E8 X M
$data = substr($buffer, 8);" ]# W/ n4 x: n) Z
} else if ($len === 127) {
% M4 w; [& i9 ^) t/ ^+ i/ q
$masks = substr($buffer, 10, 4);
0 |9 l, ?% L: {4 i) h
$data = substr($buffer, 14);1 P0 [+ [& Z5 _5 g- e! k( a" l
} else {
% u7 \- s6 N- p% Z& u( T& j4 t
$masks = substr($buffer, 2, 4);
4 O; u+ x1 G# J" ^( x: s% X
$data = substr($buffer, 6);
* ?2 m$ T6 Z& w8 \- g
}1 c4 @- @& r( i6 a
for ($index = 0; $index < strlen($data); $index++) {
$ Y; Q7 G' ^4 |! Y9 \% o
$decoded .= $data[$index] ^ $masks[$index % 4];7 A. ?' K6 A3 T
}. ^! y3 {' A" o7 |9 v, o. O Y" ?
return $decoded;& o& \: w* W5 ]# |
}7 L( |. b+ f9 w# o. w* ?
3 K( y5 e. f" K+ q& K
// 返回帧信息处理" z; {* {" s# F" W- j
function frame($s)
; e' q5 m" u1 b& s; a. O7 W3 P3 m* E6 _
{
/ x) P* X4 ]$ ^& K3 f, }+ W
$a = str_split($s, 125);& b8 ]- Y2 S+ t
if (count($a) == 1) {
7 ?/ e( O+ }0 k# V1 j4 Z
return "\x81" . chr(strlen($a[0])) . $a[0];' T n A: [- b. @# [) r
}* w- [* o- H$ |/ X/ D1 ~
$ns = "";
& J% v4 v3 J. b: z1 o+ V
foreach ($a as $o) {
) C% F6 o/ [ U U. z5 p
$ns .= "\x81" . chr(strlen($o)) . $o; c( P- i3 @3 i: a8 ^
}3 I1 T0 ?; M7 d9 z
return $ns;" e: Q( k" W! m8 j4 p
}
+ [. X' t9 y& m6 x- g
9 w$ V4 Q) X6 B* D
// 返回数据. f/ }: m% d" e- w
function send($client, $msg)
1 M7 O1 l1 a6 m3 Q& Z. O+ L- N! Z
{
/ Q- E, P/ b0 I1 X; i( g
$msg = $this->frame($msg);
7 v0 } j) k# H5 l$ x
socket_write($client, $msg, strlen($msg));
; U" i0 _: d# h# s; b$ ?' S
}
+ z5 G8 g# A; O& i g* g
}
- Y3 ` @, q& E4 w
5 j* e( Y, u7 a# m
测试 $ws = new WS("127.0.0.1",2000);
n4 c$ Q( c' K5 c0 e o5 w
/ x# U. M. M* k- b- ^

复制代码

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

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