如何在 php 中处理套接字损坏的管道 [错误 32]?

Vin*_*nay 5 php sockets

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

但是当我重新启动客户端(使用 ip 和端口)时。并尝试使用writetosocket()它返回错误代码为 32 的管道损坏错误。但是在成功执行了一些socket_write功能之后。意味着当我在套接字上写入数据时,我在一段时间后收到此错误。我阅读了一些解决方案并尝试了我正在使用的最常见的解决方案,socket_shutdownsocket_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;
}
Run Code Online (Sandbox Code Playgroud)

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

Cha*_*dis 0

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

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

服务器

  1. 插座()
  2. 绑定()
  3. 听()
  4. 接受()

客户

  1. 插座()
  2. bind() [可选,见下文]
  3. connect() [如果尚未绑定,则在临时端口上进行隐式绑定]