如果之前有人问过这个问题,我很抱歉。我正在编写一个使用选择多路复用的非阻塞套接字客户端。让我困惑的一件事是,无论服务器在线还是离线,无阻塞连接都会成功。我搜索了很多帖子,并遵循他们的解决方案,但没有一个在我的linux ubuntu机器上工作。非阻塞套接字连接总是成功?
static void callback_on_select_write(int connect_fd) {
// Client write event arrived;
int error = -1;
socklen_t len = sizeof(error);
if(getsockopt(connect_fd, SOL_SOCKET, SO_ERROR, &error, &len) == -1) {
return;
}
// getsockopt puts the errno value for connect into erro so 0 means no-error.
if(error == 0) {
// Connection ok.
}
else {
cerr << "Failed to connect\n";
return;
}
// Ready to write/read
}
每次选择返回并调用这个回调总是成功,即,将“准备读/写”块,而不是cerring故障。为什么会发生?如何设计便携式机制来检测连接是否真的成功?以下是我创建连接器的方式。
int make_socket_client(const ::std::string& hostname, const ::std::string& port) {
struct addrinfo hints;
struct addrinfo* res {nullptr};
struct addrinfo* ptr {nullptr};
memset(&hints, 0, sizeof(struct addrinfo));
hints.ai_family = AF_UNSPEC;
hints.ai_socktype = SOCK_STREAM;
hints.ai_protocol = IPPROTO_TCP;
int rv;
int connector;
if((rv = getaddrinfo(hostname.c_str(), port.c_str(), &hints, &res)) != 0) {
return -1;
}
// Try to get the first available client connection.
for(ptr = res; ptr != nullptr; ptr = ptr->ai_next) {
// Ignore undefined ip type.
if(ptr->ai_family != AF_INET && ptr->ai_family != AF_INET6) {
continue;
}
// Create a listener socket and bind it to the localhost as the server.
if((connector = socket(ptr->ai_family, ptr->ai_socktype, ptr->ai_protocol)) == -1){
continue;
}
make_fd_nonblocking(connector);
if(connect(connector, (struct sockaddr*)ptr->ai_addr, ptr->ai_addrlen) < 0) {
// This is what we expect.
if(errno == EINPROGRESS) {
break;
}
else {
close(connector);
continue;
}
}
else {
break;
}
}
freeaddrinfo(res);
if(ptr == nullptr) {
return -1;
}
return connector;
}
当然,你应该看看'connect_fd'上的SO_ERROR?什么是'事件'?此代码不够完整,无法回答问题。 – EJP
对不起。它只应该是connect_fd。 – Jes
原始'connect()'返回零吗? – EJP