我有套接字处理程序类,它用于在几个套接字函数的帮助下与具有特定 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;
}
Run Code Online (Sandbox Code Playgroud)
帮助我理解并解决这个问题,以便函数可以处理管道损坏错误。
您收到该错误是因为服务器套接字已关闭并且不再侦听,并且客户端套接字在关闭后但在端口可以再次使用之前(当它处于TIME_WAIT状态时)尝试将数据发送到服务器套接字)。
服务器套接字和客户端套接字在可用于 I/O 之前都会经历不同的步骤: