写入关闭的 TCP/IP 连接挂起

Question

我的 TCP/IP 客户端在写入套接字时挂起。即使服务器通过close()（或shutdown()）调用正确关闭了已接受的连接，也会发生这种情况。对于这种情况，我一直认为 write 应该返回 ECONNRESET 错误。

如何防止同步输出挂断？或者更确切地说，我做错了什么，以至于write() 没有报告错误？

我应该使用send() 而不是write() 还是它们可以互换？

我正在使用两个线程的单独应用程序中测试网络。 主线程启动服务器线程，接受连接并立即关闭它。然后主线程通过连接到监听端口来模仿客户端行为。

主线程代码：

sockaddr_in serv_addr;
bzero((char *) &serv_addr, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = INADDR_ANY;
serv_addr.sin_port = htons(port);
int s = socket(AF_INET, SOCK_STREAM, 0);
if (bind(s, (sockaddr*)(&serv_addr),  sizeof(serv_addr)) < 0) {
    close(s);
    throw runtime_error(strerror(errno));
}
listen(s,1);
start_thread(s); // posix thread accepting a connection on s is started here
//Code below imitates  TCP/IP client
struct hostent *hp;
struct sockaddr_in addr;
if((hp = gethostbyname(host.c_str())) == NULL){
    throw HErrno();
}
bcopy(hp->h_addr, &addr.sin_addr, hp->h_length);
addr.sin_port = htons(port);
addr.sin_family = AF_INET;
int _socket = ::socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
if (_socket < 0) {
    throw Errno();
}
assert(ENOTCONN==107);
assert(_socket>=0);
if(::connect(_socket, (const struct sockaddr *)&addr, sizeof(struct sockaddr_in)) == -1){
    throw Errno();
}

while(true) {
  const char a[] = "pattern";
  if (write( _socket, a, 7)<0) // Writes 30000 times, then hangs
     break;
}

服务器线程代码：

int connection = accept(s);
close(connection);

编辑： 问题归结为我的编程错误。看来我没能正确开始接受线程。

Answer 1

您是否为SIGPIPE 设置了一个处理程序，而不是设置为SIG_IGN？

Answer 2

每个 TCP 连接都有一个接收缓冲区，用于存储已接收但未传递给应用程序的数据。如果在您的服务器中您不执行 read()，则数据会累积在接收缓冲区中，并且在某一时刻此接收缓冲区已满，导致 TCP 发送 Window=0 消息。

您的服务器线程代码应如下所示：

char a[10];
int connection = accept(s);
while(true)
    if (read( connection , a, 7)<=0)
        break;
close(connection);