客户端/服务器应用程序：在 msys2/mingw64 下的 Windows 上 read() 不会阻塞

问题描述

我们创建了一个显示客户端/服务器的 MWE。网络封装在IPV4Socket.cc、Request.cc和Socket.cc中

完整代码在github上：https://github.com/StevensDeptECE/simpleclientserver

服务器打开一个具有已知端口的套接字并等待。我们发送一个 4 字节整数，它在 Linux 中通过并回复一条消息。使用 Winsock 在服务器上读取不会阻塞，并返回一个负数。在读取后打印 errno 时，它声称存在错误的文件描述符（在客户端和服务器端）。两个读取错误都发生在 Request.cc 中（分别为服务器和客户端的第 17 行和第 32 行）。

// Send from server
void IPV4Socket::send(uint32_t reqn) { write(sckt,&reqn,sizeof(uint32_t)); }

// Send from client
void IPV4Socket::sendAndAwait(uint32_t reqn,Request &r) {
  send(reqn);
  r.handle(sckt);
}

// Client function (Request::handle) is the nearly the same,// but does not write back
void Request::handleServer(int returnsckt) {
  char buf[256];

  // FAILS HERE
  // first read incoming message from client
  int bytesRead = read(returnsckt,buf,256);
  if (bytesRead < 1) perror("Read error: ");
  cout << "bytes read: " << bytesRead << ' ';
  
  // Now write back to client
  const char answer[] = "testing";
  write(returnsckt,answer,sizeof(answer));
}

// Server socket constructor
IPV4Socket::IPV4Socket(uint16_t port) : Socket(port) {
  struct addrinfo *result = NULL;
  struct addrinfo hints;

  char port_string[8];
  itoa(port,port_string,10);

  ZeroMemory(&hints,sizeof(hints));
  hints.ai_family = AF_INET;
  hints.ai_socktype = SOCK_STREAM;
  hints.ai_protocol = IPPROTO_TCP;
  hints.ai_flags = 1;  // Todo: Originally AI_PASSIVE,convert to macro

  testResult(getaddrinfo(NULL,&hints,&result),__FILE__,__LINE__,Errcode::SOCKET);

  sckt = INVALID_SOCKET;
  sckt = socket(result->ai_family,result->ai_socktype,result->ai_protocol);

  if (sckt == INVALID_SOCKET) {
    freeaddrinfo(result);
    throw Ex1(Errcode::SOCKET);
  }

  // Setup the TCP listening socket
  if (bind(sckt,result->ai_addr,(int)result->ai_addrlen) == SOCKET_ERROR) {
    freeaddrinfo(result);
    closesocket(sckt);
    throw Ex1(Errcode::SOCKET_BIND);
  }

  freeaddrinfo(result);
  if (listen(sckt,SOMAXCONN) == SOCKET_ERROR) {
    cerr << "listen Failed with error: " << WSAGetLastError() << endl;
    closesocket(sckt);
    return;
  }
}

// Client socket constructor
IPV4Socket::IPV4Socket(const char *addr,uint16_t port) : Socket(addr,port) {
  // Same code as the Server socket constructor up to testresult(getaddrinfo)

  for (ptr = result; ptr != NULL; ptr = ptr->ai_next) {
    // Create a SOCKET for connecting to server
    sckt = socket(ptr->ai_family,ptr->ai_socktype,ptr->ai_protocol);
    testResult(sckt == INVALID_SOCKET,Errcode::SOCKET);

    if (connect(sckt,ptr->ai_addr,(int)ptr->ai_addrlen) == SOCKET_ERROR) {
      closesocket(sckt);
      sckt = INVALID_SOCKET;
      continue;
    }
    break;
  }

  testResult(sckt == INVALID_SOCKET,Errcode::SOCKET);
  freeaddrinfo(result);
}

编辑：我没有在这个简化的存储库中展示所有内容，但我们正在处理的原始项目（其中大部分来自）现在正在运行。我确实在套接字 I/O 中添加了一些错误处理，以便它现在在出现问题时启动，但最终修复它的是将读取/写入调用替换为发送/接收调用。它看起来像 Winsock 套接字（至少在 mingw64 下），对正在使用的读/写反应不佳。这似乎已经解决了大部分问题，但如果它再次中断，我会在这里再次进行编辑。

另外，感谢 Remy 向我指出另一个问题，我用 using socket_t = decltype(socket(0,0)); 替换了套接字类型，因此它现在可以独立于操作系统找出正确的套接字类型。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）