0

私はウェブソケットが初めてです。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;
}

クライアントが「こんにちは」をサーバーに送信すると、サーバーは単純に「こんにちは」と返信します。そして、wireshark でキャプチャされたパケットは 81 02 68 69 です。ワイヤ上のビットは、プロトコルが示すとおりのようです。サーバーが "hi from server" などの長い文字列を送信しようとすると、クライアントはエラー: undefined で応答します。

誰でも助けることができますか？どうもありがとう。

これはサーバーのコードです：

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;
}

これらの 2 つの関数は、クライアントのハンドシェイクを取得し、ソケットによってユーザー オブジェクトを取得します。

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;
}
4

2 に答える 2

0

私はそれを解決しました。

奇妙な問題に苦しんでいる人には、これが答えです。

ハンドシェイク関数から socket_write($user->socket,$upgrade.chr(0),strlen($upgrade.chr(0))) の chr(0) を削除します。

彼は私にインスピレーションを与えたので、私はまだシムノックの答えを正しいものとしてマークします。ありがとう

于 2013-04-04T11:15:37.853 に答える