Linux C++如何实现网络编程中的非阻塞IO

在Linux中，使用C++实现网络编程的非阻塞IO通常涉及以下几个步骤：

创建套接字：首先，你需要创建一个套接字。这可以通过调用socket()函数来完成。
设置套接字选项：为了使套接字变为非阻塞模式，你需要使用fcntl()函数来修改套接字的文件描述符标志。
绑定地址：使用bind()函数将套接字绑定到特定的IP地址和端口上。
监听连接：如果你的服务器需要接受来自客户端的连接，使用listen()函数开始监听。
接受连接：使用accept()函数接受连接。在非阻塞模式下，如果没有连接请求，accept()会立即返回一个错误。
读写数据：使用read()和write()函数进行数据的读取和写入。在非阻塞模式下，如果没有数据可读或缓冲区已满，这些函数也会立即返回。
处理事件：通常，非阻塞IO会与事件通知机制（如select(), poll(), epoll()等）结合使用，以便在IO操作就绪时得到通知。

下面是一个简单的例子，展示了如何创建一个非阻塞的TCP服务器：

#include <iostream>
#include <sys/socket.h>
#include <netinet/in.h>
#include <fcntl.h>
#include <unistd.h>
#include <cstring>

int main() {
    int server_fd, new_socket;
    struct sockaddr_in address;
    int opt = 1;
    int addrlen = sizeof(address);
    char buffer[1024] = {0};

    // 创建套接字文件描述符
    if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
        perror("socket failed");
        exit(EXIT_FAILURE);
    }

    // 设置套接字选项为非阻塞
    if (fcntl(server_fd, F_SETFL, O_NONBLOCK) < 0) {
        perror("fcntl failed");
        exit(EXIT_FAILURE);
    }

    // 绑定套接字到地址和端口
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons(8080);

    if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
        perror("bind failed");
        exit(EXIT_FAILURE);
    }

    // 监听连接
    if (listen(server_fd, 3) < 0) {
        perror("listen");
        exit(EXIT_FAILURE);
    }

    while (true) {
        // 接受连接
        if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) {
            if (errno == EAGAIN || errno == EWOULDBLOCK) {
                // 没有连接请求，继续循环
                sleep(1);
                continue;
            }
            perror("accept");
            exit(EXIT_FAILURE);
        }

        // 非阻塞读写操作
        ssize_t valread = read(new_socket, buffer, 1024);
        if (valread <= 0) {
            if (errno == EAGAIN || errno == EWOULDBLOCK) {
                // 没有数据可读，继续循环
                close(new_socket);
                continue;
            }
            perror("read");
            exit(EXIT_FAILURE);
        }

        // 处理数据...
        // ...

        // 发送响应
        send(new_socket, "Hello from server", 17, 0);
        std::cout << "Message sent\n";

        // 关闭套接字
        close(new_socket);
    }

    return 0;
}

请注意，这个例子是非常基础的，实际的网络服务器会更加复杂，可能需要处理多个客户端连接、更高效的事件通知机制（如epoll），以及更好的错误处理和资源管理。此外，为了提高性能，通常会使用多线程或多进程来处理并发连接。

最新问答

相关标签