在 PHP 中设置 TCP 监听器

Question

我们目前使用的系统通过 TCP 接收传入的 JSON 请求并也使用 JSON 进行响应。目前，我已经在 PHP 中像这样设置了套接字：

$socket = fsockopen($host, $port, $errno, $errstr, $timeout);

if(!$socket)
{
  fwrite($socket, $jsonLoginRequest); // Authentication JSON

  while(json_decode($loginResponse) == false) // We know we have all packets when it's valid JSON.
  {
     $loginResponse .= fgets($socket, 128);
  }

  // We are now logged in.

  // Now call a test method request
  fwrite($socket, $jsonMethodRequest);

  while(json_decode($methodResponse) == false) // We know we have all packets when it's valid JSON.
  {
     $methodResponse .= fgets($socket, 128);
     echo $methodResponse; // print response out
  }

  // Now we have the response to our method request.
  fclose($socket);
}
else
{
  // error with socket
}

目前可以正常工作，并且服务器响应方法请求。然而，有些方法会像这样响应来确认调用，但稍后也会响应我所追求的结果。所以我真正需要的是一个 TCP 监听器。谁能建议我如何像上面那样使用 fsock 编写 TCP 侦听器？

谢谢

Answer 1

要创建监听套接字，请使用以下函数：

• socket_create_listen （这个很酷）
• socket_accept

我不确定是否fwrite()/fread() 正在使用这些套接字，否则您必须使用以下函数：

• socket_recv
• socket_send

消息循环

我现在编写了一些函数来读取单个 JSON 响应，并假设多个响应由 CRLF 分隔。
我将这样做（假设您的 php 脚本具有无限的执行时间）：

// ... your code ... 

function readJson($socket) {
    $readData = true;
    $jsonString = '';
    while(true) {
        $chunk = fgets($socket, 2048); 
        $jsonString .= $chunk;

        if(($json = json_decode($jsonString)) !== false) {
            return $json;
        } elseif(empty($chunk)) {
            // eof
            return false;
        }
    }
}

// ....
// Now call a test method request
fwrite($socket, $jsonMethodRequest);

$execMessageLoop = true;
while($execMessageLoop) {
    $response = readJson($socket);
    if($response === false) {
        $execMessageLoop = false;
    } else {
        handleMessage($socket, $response);
    }
}

function handleMessage($socket, $response) {
    // do what you have to do
}

现在您可以实现“handleMessage”函数，该函数分析响应并对其进行操作。