我的TCP/IP客户端在写入套接字时挂起。即使服务器通过close()
(或shutdown()
)调用正确关闭接受的连接,也会发生这种情况。我一直认为在这种情况下,写入应该返回 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);
编辑:问题归结为我的编程错误。看来我未能正确开始接受线程。
每个 TCP 连接都有一个接收缓冲区,用于存储已接收但未传递到应用程序的数据。如果你在服务器中不执行 read(),那么数据就会累积在接收缓冲区中,并且在某一时刻,这个接收缓冲区会变满,导致 TCP 发送 Window=0 消息。
服务器线程代码应如下所示:
char a[10];
int connection = accept(s);
while(true)
if (read( connection , a, 7)<=0)
break;
close(connection);
为SIGPIPE
设置了一个处理程序,而不是将其设置为 SIG_IGN
?