Linux C socket在使用epoll时如何防止2个fork进程接受同一个连接？

Question

for (int t = 0; t < physicalCoreCount; t++) {
        int pid = fork();
        if (pid==0) {
            // setting up epoll    
            epoll_fd = epoll_create1(0);                
            event.data.fd = listenSocketfd;
            event.events = EPOLLIN | EPOLLET;
            ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, listenSocketfd, &event);                
            events = (epoll_event*)calloc(LISTENQ, sizeof(event));
           
            //*****/
            while (1) {
                int ndfs = epoll_wait(epoll_fd, events, curfdCount, -1);
                if (ndfs==-1) {                        
                    continue;
                }
                for (int i=0; i < ndfs; i++) {
                    if (events[i].data.fd == listenSocketfd) { // original listener
                        int new_connfd = accept(events[i].data.fd, (sockaddr*)&clientaddr, &clientlen);
                        if (new_connfd==-1) {
                            if (errno==EAGAIN || errno==EWOULDBLOCK) {
                                continue;
                            }
                            else exitPerrorLog("accept()");
                        }

                        set_non_block(new_connfd);
                        event.events = EPOLLIN | EPOLLET;
                        event.data.fd = new_connfd;
                        if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, new_connfd, &event) < 0)
                            exitPerrorLog("epoll_ctl");

                        clientaddrOfFd[new_connfd] = new sockaddr_in();
                        memcpy(clientaddrOfFd[new_connfd], &clientaddr, sizeof(clientaddr));
                        curfdCount++;
                    }   
                    else {
                        process(events[i].data.fd, clientaddrOfFd[events[i].data.fd]);
                        //epoll_ctl(epoll_fd, EPOLL_CTL_DEL, events[i].data.fd, &event);                           
                        if (curfdCount > 10000) curfdCount = 10000; //curfdCount--;
                    }
                }
            }
        }
    }

出现问题是因为我正在尝试实现持久连接（响应后未关闭）。然而，孩子 0 可以接受（）一个套接字文件描述符 X，处理它，但后来孩子 1 可以接受（）相同的文件描述符。由于我没有关闭子 0 上的连接（以实现 HTTP1.1 keep-alive），现在 2 个子正在读取/写入同一个文件描述符。

有什么方法可以防止这个问题？谢谢。

编辑： 重要更新：所以主要问题是我认为 2 个相同的 FD 意味着它是相同的连接，我想避免这种情况，因为它会导致 2 个孩子读/写相同的东西.如果这种情况没有发生（读/写重叠），那么我认为问题已经解决。有人可以确认吗？

Answer 1

您正在创建多个 epoll 实例并在每个实例的侦听套接字上注册边缘触发事件。自然地，当一个新的连接可以接受时，你会从每个人那里得到一个事件。但是，只有一个进程可以成功接受每个连接。正如在 cmets 中观察到的，两个不同的子进程可能会接受在各自进程中分配了相同文件描述符编号的连接，但这并不意味着它们引用的是同一个套接字。

您有多种选择，但其中最突出的是：

• 使用单个 epoll 实例，由所有进程共享。您可以通过让父级在分叉任何子级之前创建它来自动获得它。在这种情况下，只有一个孩子会收到每个边缘触发的事件。当然，如果孩子们打算注册只应该由他们接收的事件，那么这将不会很好地工作。

• 只需接受（没有双关语）当连接可用时多个进程将接收事件并处理它。这似乎就是你现在正在做的事情（通过忽略来自accept() 的EAGAIN 和EWOULDBLOCK 错误），我看不出你不应该继续这样做的特别原因。