c++ - 一台服务器向一个客户端发送数据。使用 select() 实现非阻塞 I/O

Question

我正在尝试开发一个简单的应用程序，其中一个服务器将数据发送到一个客户端，使用 select() 在没有任何内容可读时停止客户端事件。我能够发送/读取数据，但 select() 系统调用似乎没有效果，因为当服务器的写操作完成时，客户端不会在 select() 系统调用之前停止并继续执行 select() 之后的操作(在本例中为 printf )。

这是服务器代码

void initSocket()
{
    printf("socket initialized\n");
    sockFd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockFd < 0)
    sockError("ERROR opening socket");

    bzero((char*)&servAddr, sizeof(servAddr));
    portNum = 7550;
    servAddr.sin_family = AF_INET;
    servAddr.sin_addr.s_addr = INADDR_ANY;
    servAddr.sin_port = htons(portNum);

    if (bind(sockFd, (struct sockaddr*)&servAddr, sizeof(servAddr)) < 0)
    sockError("ERROR on blinding");

    listen(sockFd, 5);
    cliLen = sizeof(clientAddr);
    newsockFd = accept(sockFd, (struct sockaddr*)&clientAddr, &cliLen);
    if (newsockFd < 0)
    sockError("ERROR on accept");
    printf("Request received\n");
}

void sendGpsCoord(char* line)
{
    int n;

    n = write(newsockFd, line, sizeof(nmeaPOS));
    if (n < 0)
      printf("ERROR in writing socket");
}

void closeSocket()
{
    close(newsockFd);
    close(sockFd);
    printf("sockets closed\n");
}

int main()
{
    printf("main started\n");
    initSocket();

    char line[256];
    while (fgets(line, sizeof(line), stdin) != NULL) {

        sendGpsCoord(&line);
    }

    closeSocket();
    return 0;
}

它工作正常。它发送文件中的所有数据，然后退出。

---

以下是客户端代码。它接收并正确打印所有数据，但是当服务器结束发送数据时，客户端继续在 while 循环中打印字符串 I'm not blocking，而我希望它在 select() 系统之前停止调用，因为套接字上不再写入数据，因此文件描述符 gpsSockRight 不应再更改。

 fd_set readSetRight;
 struct sockaddr_in gpsServAddrLeft;
 int gpsServPortRight = 7550;
 int gpsSockRight;



 bool initGpsSocket()
 {
     bool ret = false;

     gpsSockRight = socket(AF_INET, SOCK_STREAM, 0);
     if (gpsSockRight < 0) {
         error("ERROR opening socket");
         ret = true;
     }

     gpsServRight = gethostbyname("192.168.2.91");

     bzero((char *) &gpsServAddrRight, sizeof(gpsServAddrRight));
     gpsServAddrRight.sin_family = AF_INET;

     bcopy((char *)gpsServRight->h_addr, 
           (char *)&gpsServAddrRight.sin_addr.s_addr,
           gpsServRight->h_length);

     gpsServAddrRight.sin_port = htons(gpsServPortRight);

     if (connect(gpsSockRight, (struct sockaddr *)   
         &gpsServAddrRight,sizeof(gpsServAddrRight)) < 0) {

         error("ERROR connecting");
         ret = true;
     }

     // To set the socket to be non blocking
     int on = 1;
     ioctl(gpsSockRight, FIONBIO, (char*)&on);

     return ret; 
}

void runGpsSocketRight()
{
    int n;
    string line;

    while(gRun) {  
        FD_ZERO(&readSetRight);
        FD_SET(gpsSockRight, &readSetRight);

        if (select(gpsSockRight +1 , &readSetRight, NULL, NULL, NULL) < 0) {
            error("select\n");
            exit(1);
        }

        printf("I'm not blocking\n");

        if (FD_ISSET(gpsSockRight, &readSetRight)) {
            FD_CLR(gpsSockRight, &readSetRight);
            n = read(gpsSockRight, &line, sizeof(line));
            if (n < 0)
                error("ERROR reading from socket");
            else if (n == 0)
                ;
            else if (n > 0) {
                printf("Here is the line: %s\n", line);

            }
        }
    }
}

Answer 1

当套接字关闭时，Select 返回，因为 EOF 将套接字标记为准备好读取。后续读取然后返回大小 0，表明套接字已在另一侧关闭。

在您的代码中，您检查了 if (n == 0) 并且什么都不做。您必须在那里跳出循环，因为关闭的套接字在关闭之前将保持可读状态。