我是 websocket 的新手。我在 PHP 上做了一个简单的 websocket 实现。握手工作正常，并且连接肯定是打开的，因为我的服务器可以从客户端获取消息。
但是，一旦我尝试将消息发送回客户端，客户端根本没有响应。
这是屏蔽消息并将其发送回客户端的代码。
function myProcess($user,$buffer)
{
//$buffer=unwrap($buffer);
console("Request Caught.");
console("Content Length: ".strlen($buffer));
console("Content: ".unmask($buffer));
console("First 8 bits: ".ord($buffer[0]));
console("Opcode: ".opcode($buffer,true));
//console("Full Text: ".$buffer);
//socket_write($user->socket,mask(unmask($buffer)));
console("Masking: ");
$tmp=unmask($buffer);
console($tmp);
$masked=mask($tmp);
opcode($masked);
for($i=0;$i<strlen($masked);$i++)
{
console($i.": ".ord($masked[$i]));
}
console("length: ".strlen($masked));
console("Sending Response: ");
console(socket_write($user->socket,$masked,strlen($masked)));
}
function mask($text)
{
$first8bit=0x81;
$header;
console("mask: payload length:".strlen($text));
if(strlen($text)<=125)
{
$header=pack("CC",$first8bit,strlen($text));
}
else if(strlen($text)<65536)
{
$header=pack("CCS",$first8bit,126,strlen($text));
}
else
{
$header=pack("CCN",$first8bit,127,strlen($text));
}
return $header.$text;
}
如果客户端向服务器发送“hi”，服务器将简单地回复“hi”。使用wireshark捕获的数据包是81 02 68 69。看来线路上的位正如协议所说的那样。如果服务器尝试发送更长的字符串，例如“hi from server”，客户端会响应错误：未定义。
任何人都可以帮忙吗？非常感谢。
这是服务器的代码：
while(true){
$changed = $sockets;
socket_select($changed,$write=NULL,$except=NULL,NULL);
foreach($changed as $socket){
if($socket==$master){
console("Master Socket Changed.");
$client=socket_accept($master);
if($client<0){ console("socket_accept() failed"); continue; }
else{ connect($client); }
}
else{
console($socket." Socket Changed.");
$str=socket_read($socket,2048);
$user=getuserbysocket($socket);
if(strlen($str)==0) disconnect($socket);
else if(!$user->handshake){ dohandshake($user,$str); }
else
{
myProcess($socket,$str);
}
console("Comunication Ends Here.");
}
}
}
这是接受部分的计算：
function calc_accept($key)
{
$tmp=$key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
$tmp=sha1($tmp,true);
//console($tmp);
$tmp=base64_encode($tmp);
//console($tmp);
return $tmp;
}
这是握手：
function dohandshake($user,$buffer){
console("\nRequesting handshake...");
console($buffer);
list($resource,$host,$origin,$strkey,$data) = getheaders($buffer);
console("Handshaking...");
$upgrade="HTTP/1.1 101 Switching Protocols\r\n".
"Upgrade: websocket\r\n".
"Connection: Upgrade\r\n".
"Sec-WebSocket-Accept: ".calc_accept($strkey)."\r\n\r\n";
socket_write($user->socket,$upgrade.chr(0),strlen($upgrade.chr(0)));
$user->handshake=true;
console($upgrade);
console("Done handshaking...");
return true;
}
这两个函数获取客户端的握手并通过套接字获取用户对象：
function getheaders($req){
$r=$h=$o=null;
if(preg_match("/GET (.*) HTTP/" ,$req,$match)){ $r=$match[1]; }
if(preg_match("/Host: (.*)\r\n/" ,$req,$match)){ $h=$match[1]; }
if(preg_match("/Origin: (.*)\r\n/",$req,$match)){ $o=$match[1]; }
if(preg_match("/Sec-WebSocket-Key: (.*)\r\n/",$req,$match)){ $key=$match[1]; }
if(preg_match("/\r\n(.*?)\$/",$req,$match)){ $data=$match[1]; }
return array($r,$h,$o,$key,$data);
}
function getuserbysocket($socket){
global $users;
$found=null;
foreach($users as $user){
if($user->socket==$socket){ $found=$user; break; }
}
return $found;
}