5

我有套接字处理程序类，它用于借助几个套接字函数与具有特定 IP 和端口的客户端进行通信。在我第一次使用writetosocket()函数时，它运行良好。

但是当我重新启动客户端（使用 ip 和端口）时。并尝试使用writetosocket()它返回我损坏的管道错误，错误代码为 32。但是在成功执行一些socket_write功能之后。意味着我在一段时间后在套接字上写入数据时收到此错误。我阅读了一些解决方案并尝试了我正在使用的最常见的解决方案，socket_shutdown并socket_close在我发现客户端没有响应时正确终止套接字连接。之后我再次调用 startconnection，这给了我新的套接字。但我仍然遇到管道损坏错误。

function startconnection(){
     /* Create a socket in the AF_INET family, using SOCK_STREAM for TCP connection */
     $this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
     if ($this->socket === false) {
            $errorcode = socket_last_error();
            $errormsg = socket_strerror($errorcode);
            echo "$errorcode : $errormsg";
            return false;
     }
     else {
            echo "Socket successfully created.";
     }

     /* Accept incoming connections */
     $this->result = socket_connect($this->socket, $this->ipaddress, $this->port);
     if($this->result === false){
            $errorcode = socket_last_error();
            $errormsg = socket_strerror($errorcode);
            echo "$errorcode : $errormsg";
            return false;
     }
     else {
            echo "successfully connected to $this->ipaddress, $this->port";
     }
     return true;
}


function writetosocket($input){
      $sent = socket_write($this->socket, $input, strlen($input));
      if($sent === false) {
            $errorcode = socket_last_error();
            $errormsg = socket_strerror($errorcode);
            echo "$errorcode : $errormsg";
            return false;
      }
      else {
            echo "Message Sent : $input";
      }
      return true;
}

帮助我理解和解决这个问题，以便函数可以处理损坏的管道错误。

4

1 回答 1

0

您收到该错误是因为服务器套接字已关闭并且不再侦听，并且客户端套接字在关闭后但在端口可以再次空闲使用之前尝试将数据发送到服务器套接字（当它处于TIME_WAIT）。

服务器套接字和客户端套接字在可用于 I/O 之前都经过不同的步骤：

服务器

  1. 插座（）
  2. 绑定（）
  3. 听（）
  4. 接受（）

客户

  1. 插座（）
  2. bind() [可选，见下文]
  3. connect() [如果尚未绑定，则在临时端口上进行隐式绑定]
于 2013-07-21T07:20:28.047 回答