然后通过在PHP问题中通过套接字回读

Question

我编写一个命令，然后通过PHP中的套接字从服务器回读。我们有20台服务器都运行一个Node JS脚本，它可以接收这些命令并执行它们。 Node JS脚本将返回PHP回读的“ok”以确认命令已经通过。

节点JS脚本侦听端口9000并设置为allow half open。

大多数这工作得很好，但是当命令的大批量发送，我们得到的错误回到偶尔会认为，这一时间：

Contents: Message received back from socket was 'Unexpected token {' 
Transport endpoint is not connected 

传输的端点消息建议，我认为它没有连接成功。

我不是插座专家，所以我不知道我使用的实现是否“正确”。它大多数时间都有效，但我知道有些功能可能会更好，但我不确定它们的功能，如socket_bind和socket_listen。

这是我们正在使用的PHP代码。任何建议将不胜感激。

public function sendDaemonCommand($address, $template_id, $params = array()) { 

    $hostname = $this->getHostnameFromPrivateIP($address); 
    $port = 9000; 
    $command = array('template_id' => $template_id, 'params' => $params); 
    $command = json_encode($command); 

    // Create a TCP Stream socket 
    if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) { 
     $this->mailError("Command Failed - " . $hostname, "Failed to create socket on " . $address . "\n\n" . socket_strerror(socket_last_error()) . "\n\nCommand:\n\n" . $command . "\n" . $this->functionTraceback()); 
     return false; 
    } 

    // Connect to socket 
    if (socket_connect($sock, $address, $port) === false) { 
     $this->mailError("Command Failed - " . $hostname, "Failed to connect to socket on " . $address . "\n\n" . socket_strerror(socket_last_error($sock)) . "\n\nCommand:\n\n" . $command. "\n" . $this->functionTraceback()); 
     socket_close($sock); 
     return false; 
    } 

    // Write command to socket 
    $_command = $command; 
    $length = strlen($_command); 

    while (true) { 
     $sent = socket_write($sock, $_command, $length); 

     if ($sent === false) { 
      $this->mailError("Command Failed - " . $hostname, "Failed to write command to socket on " . $address . "\n\n" . socket_strerror(socket_last_error($sock)) . "\n\nCommand:\n\n" . $command. "\n" . $this->functionTraceback()); 
      socket_shutdown($sock, 2); 
      socket_close($sock); 
      return false; 
     } 

     if ($sent < $length) { 
      $_command = substr($_command, $sent); 
      $length -= $sent; 
     } 
     else { 
      break; 
     } 
    } 

    socket_shutdown($sock, 1); 

    // Read back from socket 
    if (($out = socket_read($sock, 1024)) !== false) { 
     @socket_shutdown($sock, 0); 
     $out = trim($out); 
     if ($out !== "ok") { 
      $this->mailError("Command Failed - " . $hostname, "Message received back from socket was '" . $out . "' on " . $address . "\n\n" . socket_strerror(socket_last_error($sock)) . "\n\nCommand:\n\n" . $command. "\n" . $this->functionTraceback()); 
      socket_close($sock); 
      return false; 
     } 
    } 
    else { 
     $this->mailError("Command Failed - " . $hostname, "Failed to read from socket on " . $address . "\n\n" . socket_strerror(socket_last_error($sock)) . "\n\nCommand:\n\n" . $command. "\n" . $this->functionTraceback()); 
     socket_shutdown($sock, 0); 
     socket_close($sock); 
     return false; 
    } 

    socket_close($sock); 
    return $out; 
} 

Answer 1

对于一个简单的socket客户端，如这个，我更喜欢fsockopen() - 它大大降低了客户端代码的复杂性和不要求插槽的扩展，这是不是随处可见。这样做的主要缺点是你丢失了字符串错误信息，但是这些信息很少有用 - 你仍然会从创建套接字中得到一个错误字符串，并且如果读写操作失败，那是因为套接字已经断开连接。

我也不确定在这种情况下“允许半开放”有多么有用 - 我认为它可能会产生比解决问题更多的问题。对socket_shutdown()的调用在这里没有做任何有用的事情（并且可能是你的问题的根源） - 只有当你在一个不会关闭的套接字上运行时才会使用这个套接字，并且可以在稍后的时间点通过一些其他的代码。由于您创建了一个新的套接字并将其在同一个例程中销毁，情况并非如此。

这是你的代码改写为使用fsockopen() - 正如你所看到的，它更短，更简单。我也稍微修改了它，以便它总是返回一个布尔 - 你的代码返回bool FALSE或字符串ok，并且由于只有这两个选项，所以函数总是返回一个布尔值更有意义。

public function sendDaemonCommand($address, $template_id, $params = array()) { 

    // Prepare data 
    $hostname = $this->getHostnameFromPrivateIP($address); 
    $port = 9000; 
    $command = array('template_id' => $template_id, 'params' => $params); 
    $_command = $command = json_encode($command); 
    $length = strlen($_command); 

    // Connect to socket 
    if (!$sock = fsockopen($address, $port, $errNo, $errStr)) { 
     $this->mailError("Command Failed - " . $hostname, "Failed to connect to socket on " . $address . "\n\n" . $errStr . "\n\nCommand:\n\n" . $command. "\n" . $this->functionTraceback()); 
     return false; 
    } 

    // Write command to socket 
    while (true) { 

     // Try and write data to socket 
     $sent = fwrite($sock, $_command, $length); 

     // If it failed, error out 
     if ($sent === false) { 
      $this->mailError("Command Failed - " . $hostname, "Failed to write command to socket on " . $address . "\n\nCommand:\n\n" . $command. "\n" . $this->functionTraceback()); 
      fclose($sock); 
      return false; 
     } 

     // If there is data left to send, try again 
     if ($sent < $length) { 
      $_command = substr($_command, $sent); 
      $length -= $sent; 
      continue; 
     } 

     // If we get here the write operation was successful 
     break; 

    } 

    // Read back from socket and close it 
    $out = fread($sock, 1024); 
    fclose($sock); 

    // Test the response from the server 
    if ($out === false) { 
     $this->mailError("Command Failed - " . $hostname, "Failed to read from socket on " . $address . "\n\nCommand:\n\n" . $command. "\n" . $this->functionTraceback()); 
     return false; 
    } else if (($out = trim($out)) !== "ok") { 
     $this->mailError("Command Failed - " . $hostname, "Message received back from socket was '" . $out . "' on " . $address . "\n\nCommand:\n\n" . $command. "\n" . $this->functionTraceback()); 
     return false; 
    } else { 
     return true; 
    } 

}