PHP 简单实现webSocket

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

1）客户端实现

<html>
* f) X2 s# U4 O9 N# Q
<head>
3 F( Q# D, G# s5 ^/ A6 H$ c3 ` P
<meta charset="UTF-8"> Y4 ]' T l2 f6 ^
<title>Web sockets test</title>
1 S& n1 ~$ E/ n4 j6 x. |
<script src="jquery-min.js" type="text/javascript"></script>5 r! F; t- f3 n) q. R, o' G7 }
<script type="text/javascript">
- c) p4 z, U# m+ ]5 U* g
var ws;4 G' }0 h7 j, O Q8 ^
function ToggleConnectionClicked() { , s' X* v; K3 F1 x
try {
' Y- L7 D, V- ] u3 p
ws = new WebSocket("ws://127.0.0.1:2000");//连接服务器
" E) `/ O8 {4 o: G e
ws.onopen = function(event){alert("已经与服务器建立了连接\r\n当前连接状态："+this.readyState);};
% S6 v0 y& v' E- D/ [9 B
ws.onmessage = function(event){alert("接收到服务器发送的数据：\r\n"+event.data);};
& ^4 F' Y! ~) e
ws.onclose = function(event){alert("已经与服务器断开连接\r\n当前连接状态："+this.readyState);};
5 g) c. z" J) y5 x
ws.onerror = function(event){alert("WebSocket异常！");};
7 d) R f% H: V4 f/ r1 ?; M
} catch (ex) {
8 t! C! L# T; ?! {) u. f) X
alert(ex.message);
* d; O# m# N( [2 Y! i9 U2 `, i
}
* s0 N+ Z9 B4 C% ]
};( W, [& L }0 K- e
, r; _9 S( O! ~- l8 o( @: n
function SendData() {8 C- n! I, n8 a
try{
. Z/ o% L( R* j. x
var content = document.getElementById("content").value;
& s7 ?* W$ O" o! x0 P( U2 O% ]
if(content){( [( }) Z% k+ s! J
ws.send(content);
# P0 D, t3 Y, m9 U3 B
}
$ [$ v4 ^* V( c& Y1 D/ _
' G* V f& [& S1 T3 j
}catch(ex){
0 R; }. F( b( H: ~, u
alert(ex.message);# u K* v& x4 x4 S9 E
}; _9 I% g; b$ c; o) v
};
' E, v0 z8 M( ?5 Y' p P1 B
/ L+ Q! q, [1 H- ?
function seestate(){$ w% A I# Q7 v& [7 H8 U, B
alert(ws.readyState);
^8 ]! O6 N( I0 G# g
}* U* R5 I: F1 U# J2 _* ?; T
7 v7 L2 w7 [6 Q5 S; ~4 p
</script>0 c: } d E7 H% Q; X5 n& N
</head>
2 _& f% p! u( U9 D0 K; D
<body>
, C @2 D9 F- x& G4 ~/ C" }0 y( l; O
<button id='ToggleConnection' type="button" onclick='ToggleConnectionClicked();'>连接服务器</button><br /><br />
( X( H8 M o9 Y: b# h% K2 Q
<textarea id="content" ></textarea>
5 o* }: D" |$ D) O* U& ?
<button id='ToggleConnection' type="button" onclick='SendData();'>发送我的名字：beston</button><br /><br />! S9 j Q% e+ t& e4 R X
<button id='ToggleConnection' type="button" onclick='seestate();'>查看状态</button><br /><br />
" v" `- S2 K7 _% r
/ y5 q' G* l# n. T6 g1 [
</body>0 y2 N% U8 w' `. p3 p+ j$ i% G
</html>
0 h0 Q1 j5 E" m; I

复制代码

2）服务器端实现

class WS {' y: B' x4 x3 g5 ~
var $master; // 连接 server 的 client
: f$ C0 p# V, L. s& u
var $sockets = array(); // 不同状态的 socket 管理
/ d! o' F/ C; e3 l' f- G
var $handshake = false; // 判断是否握手
& s! \2 ?+ S: V; C+ k% z$ Z
+ \+ H2 C% q U. j5 S; v
function __construct($address, $port){
6 P9 f! T$ P& P3 u
// 建立一个 socket 套接字
1 J: K8 O9 z' ?6 X
$this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) # @% J5 R# g" }4 k
or die("socket_create() failed"); m% a* d( e$ L, o. Y$ ?6 D
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) . t0 o, F" p5 c- c) \0 r
or die("socket_option() failed");
( x' J8 O* Y0 p% u
socket_bind($this->master, $address, $port)
M7 h% h/ Y3 S0 W
or die("socket_bind() failed");- y. h k3 V% L- e* ^ M" Z+ S, q
socket_listen($this->master, 2) 4 H) G$ J* l7 }4 _, y
or die("socket_listen() failed");( Q2 c+ o3 ^' o
3 d% v! h) J2 ?$ ]
$this->sockets[] = $this->master;
2 n9 l+ H9 a+ I, ]9 ~
9 \. M5 e3 a5 \" L& s7 y; T$ K, m
// debug0 u4 d% x' M1 _, h: u
echo("Master socket : ".$this->master."\n");. n- Z2 J5 g# D
" {8 {, n9 Z# K3 L% i5 k
while(true) {
H' K- @5 O6 \
//自动选择来消息的 socket 如果是握手自动选择主机8 k4 M- y6 }" O6 W S
$write = NULL;
8 J U* \7 ]7 ?5 }# n$ e7 O
$except = NULL;
+ k! A/ m2 m% p4 j3 Q8 E
socket_select($this->sockets, $write, $except, NULL);
( d# ]6 ^9 z$ L- J0 K y5 Q( d
# J: J2 i9 U# r: `: _ u% n
foreach ($this->sockets as $socket) {
, p" L k, g3 `- r3 _* j
//连接主机的 client $ z; p) Q& u. W% n3 v1 q& A
if ($socket == $this->master){
+ s0 H( r, \6 C4 z* q1 |, A
$client = socket_accept($this->master);( b8 _$ e. C6 a. O% }/ ?8 v
if ($client < 0) {+ t I* Y9 |5 B; B! a5 H5 `
// debug6 F7 D; t7 x J; o1 \6 i# O
echo "socket_accept() failed";$ l, \# ^3 B: R& g
continue;* f. S4 J8 R& [# Q7 y
} else {
# d+ H) @& `( w4 a, n
//connect($client);
$ a# u9 M) s8 b, ~$ `2 \% |' Q. G
array_push($this->sockets, $client);9 h- u+ m% C1 z1 m1 N
echo "connect client\n";
# d& R, @3 ]* h) B
}+ ~9 u/ I' J' \3 u% Q; c
} else {
) e9 m5 ?6 Q7 o! ~" S+ j- K; ]# P
$bytes = @socket_recv($socket,$buffer,2048,0);
1 @; P1 X* p x4 N2 P
print_r($buffer);8 k. d. |! U4 D/ w7 e C1 Y0 _. \3 E
if($bytes == 0) return;! I" A6 J$ i3 S, q1 b* l- D6 q
if (!$this->handshake) {
' ~: B- M6 j$ f' X0 E2 x# Y- `
// 如果没有握手，先握手回应, ]) g# n+ M/ M7 w' N, S$ A8 W
$this->doHandShake($socket, $buffer);: @. {: k+ L0 y
echo "shakeHands\n";9 K' p ]) J; P u
} else {- |! H5 b9 b9 D. z
2 J& u+ o' ]9 \- F; ^; w6 z
// 如果已经握手，直接接受数据，并处理
3 M2 ]0 ~# |, c
$buffer = $this->decode($buffer);
* Z3 A& t& j W' {9 {
//process($socket, $buffer); % o" v { s+ @6 f8 v" s
echo "send file\n";
1 T, K( g4 ~$ N+ k5 R
}
7 d4 l( Q# o' X8 j
}3 Q/ b1 u! q6 y, G* I
}
: f. L4 ^# S# q' J5 c5 K- @1 D
}* b' g/ b) y# {1 l$ Y8 h
}
- k9 @ z2 w6 O. H$ V7 H& k
* G. ~% s6 X" J4 ^4 b! U a/ n
function dohandshake($socket, $req)' W4 B' ?4 F7 A& l/ _
{
" p8 q. S( {* g, o0 s
// 获取加密key8 I0 e `5 E) c, N9 ]
$acceptKey = $this->encry($req);: u7 x3 }+ V, g+ k1 i
$upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .
5 n# _* |5 X; ^( u7 M# f( r
"Upgrade: websocket\r\n" .6 `& f0 I- ^" q. h* d
"Connection: Upgrade\r\n" .* K# i& y) G) Q, B; H7 X
"Sec-WebSocket-Accept: " . $acceptKey . "\r\n" .
/ D: B7 N) p% N6 A
"\r\n";
! s* V' T/ E1 m- B
/ o$ S1 W* @+ i$ C( f& x9 [
echo "dohandshake ".$upgrade.chr(0); ' o- s2 @+ j! M# _
// 写入socket5 I, q1 d+ f5 b
socket_write($socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
* V6 V$ s" f' [/ [# ]0 X a
// 标记握手已经成功，下次接受数据采用数据帧格式
; ]3 r7 Y- b1 q6 M; H
$this->handshake = true;
n- q, F" @: {
}/ z0 O8 ~( W) A! j
7 G; |: \1 M* p& e, ^7 k6 J
1 x$ P" G& }$ K/ m& D) }) [$ Q
function encry($req): x0 | r8 a0 ~ O% W8 e5 d6 m
{
+ `/ a6 r3 \9 h( i
$key = $this->getKey($req);
% a! m) K9 `5 W& A/ d
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";6 f3 h: a& ^: _
) i, ~4 W2 p) o+ t) q/ W: W
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));0 }9 N( H9 ~8 w& |$ W) I" N
}# c5 D, @; i1 Y3 \
" D1 Z: C! j! C6 G( M$ G# h3 T7 j
function getKey($req) % r9 }$ k4 H; }- n7 F$ b4 p4 n' A
{/ o( ^) a8 X6 }4 R- J! G
$key = null;
6 r; W7 X- E" T+ _4 g+ c; A
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) { 7 Z& s$ B4 w% }2 A6 A1 ?3 K& e
$key = $match[1]; ) l# ~. Y2 G/ S5 s% j/ e
}
. C, K. g0 S9 n- j& k- ~' P
return $key;
" T& B4 v6 P- a9 z5 a1 e5 @. x5 f
}0 w9 O' J5 w1 ~$ A6 _# F
2 U' d/ |" r0 z+ S$ q+ y$ {
// 解析数据帧
! k* D! J3 \) `
function decode($buffer) 9 k- B/ M: I# \( n/ t
{
8 Y3 i; R8 F/ J# D
$len = $masks = $data = $decoded = null;6 a8 I* U& \5 A! Q+ E# Z
$len = ord($buffer[1]) & 127;
2 k1 o6 V5 V- l: _, Q
" R \* Q* j8 ^1 u% e: A$ N
if ($len === 126) {
& l4 q7 E+ `4 ]* k$ u: E1 S6 w, k
$masks = substr($buffer, 4, 4);
( z8 n# O6 x7 W9 O
$data = substr($buffer, 8);" h# E! {$ E7 R0 K. B6 q
} else if ($len === 127) {
( B% n6 [3 b# ]+ A; r0 ]% G7 N5 x
$masks = substr($buffer, 10, 4);
$ W# e% E g% P# p
$data = substr($buffer, 14); b$ Y8 e, `5 q- f5 w$ ^& M# q/ h, J
} else {
# ~6 S2 O' J( J+ }2 W X
$masks = substr($buffer, 2, 4);) b u8 V7 t8 z
$data = substr($buffer, 6);, c6 Q- R" K' f* d. }! @ l1 R) b
}
% G$ k0 B5 D: R4 _' Y \- W7 g
for ($index = 0; $index < strlen($data); $index++) {
7 e R3 i: L6 @4 r- S; E* z% Q' S
$decoded .= $data[$index] ^ $masks[$index % 4];
9 ?9 `( T4 R k6 c6 ?" d9 d
}
2 N/ Z' Z3 m& q) p& H
return $decoded;
& C/ C( C. x; V( H, C9 b0 o0 W: V+ U) U
}
: g$ ]! l9 ?* W+ N% p% ^: T* Q
0 J2 C8 e9 s9 h* l3 U0 x1 n
// 返回帧信息处理/ J/ ~* T" g, p9 l8 q( u1 R
function frame($s) - U }0 W2 l3 K4 Q
{
* |9 B# H% w! w, o; A
$a = str_split($s, 125);
; Z5 \' l- f8 W2 I. D
if (count($a) == 1) {
4 G, G+ ], S |
return "\x81" . chr(strlen($a[0])) . $a[0];
9 n2 q/ h) f0 z8 e2 a7 u7 ^
}
9 a6 ^9 C! s' p. @5 f" P
$ns = "";
6 k0 o% U) T$ j$ v) J
foreach ($a as $o) {3 d) B6 r+ `1 C6 `4 S
$ns .= "\x81" . chr(strlen($o)) . $o;
+ ]5 `/ [- n, t8 P5 L- S
}8 e/ ^1 {5 f/ p3 f# Y! R, v; A
return $ns;
5 f0 Y( \) G( y( `; c
}
6 {! b9 g5 ?) \) O1 ^
8 Q m; |4 F1 R8 D% C# Z' W
// 返回数据; W) [! z; t. k/ y2 E
function send($client, $msg)6 C( e* G1 B: L: y1 q8 X
{
/ b1 M( d) p3 t* r/ A3 |$ v4 Y
$msg = $this->frame($msg);
8 d6 }6 A" t) t. F6 @2 `
socket_write($client, $msg, strlen($msg));
4 f; ^: k+ @- s0 Y
}8 H8 ~. |/ D3 q! l# o
}
% |) }; P# D* X8 x5 u6 N+ ]
& L8 g5 V. g+ c% U6 B3 y
测试 $ws = new WS("127.0.0.1",2000);. e) m# n2 w: E+ @& y

复制代码

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

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