1

因为我目前只用 C 语言做这个项目，所以到目前为止我只将我的网络服务器用作单线程应用程序。不过，我不想再这样了！所以我有以下代码来处理我的工作。

void BeginListen()
{
        CreateSocket();

        BindSocket();

        ListenOnSocket();

        while ( 1 )
        {
            ProcessConnections();
        }
}

现在我fork();在开始之前添加了ProcessConnection();这有助于我允许多个连接！但是，当我添加用于守护此答案中找到的应用程序的代码时。我遇到了一个小问题，使用fork()将创建我整个正在运行的应用程序的副本，这就是fork(). 所以，我想解决这个问题。

我的ProcessConnection()长相是这样的

void ProcessConnections()
{
        fork();

        addr_size = sizeof(connector);

        connecting_socket = accept(current_socket, (struct sockaddr *)&connector, &addr_size);

        if ( connecting_socket < 0 )
        {
                perror("Accepting sockets");
                exit(-1);
        }

        HandleCurrentConnection(connecting_socket);


        DisposeCurrentConnection();
}

我将如何简单地在上面或之后添加几行connecting=socket = accept......以使其同时接受多个连接？我可以使用fork();但归结为DisposeCurrentConnection();我想终止该进程并让父线程运行。

4

5 回答 5

4

我不是 100% 确定你想要做什么，买了我的头，我宁愿在接受后做叉子，然后在你完成后简单地 exit() 。但请记住，当子进程退出时，您需要对 SIGCHLD 信号做出反应，否则您将有大量的僵尸进程徘徊，等待将它们的退出状态传递给父进程。C-伪代码：

for (;;) {
  connecting_socket = accept(server_socket);
  if (connecting_socket < 0)
    {
      if (errno == EINTR)
        continue;
      else
        {
          // handle error
          break;
        }
    }

  if (! (child_pid = fork ()))
    {
       // child process, do work with connecting socket
       exit (0);
    }
  else if (child_pid > 0)
    {
      // parent process, keep track of child_pid if necessary.
    }
  else
    {
      // fork failed, unable to service request, send 503 or equivalent.
    }
}

child_pid 需要（如前所述）杀死子进程，但如果您希望使用 waitpid 来收集退出状态。

关于僵尸进程，如果您对该进程发生的事情不感兴趣，您可以为 SIGCHLD 安装一个信号处理程序，然后使用 -1 在 waitpid 上循环，直到它不再有子进程，就像这样

while (-1 != waitpid (-1, NULL, WNOHANG))
  /* no loop body */ ;

waitpid 函数将返回退出的子进程的 pid，因此如果您希望将其与有关连接的其他一些信息相关联（如果您确实跟踪了 pid）。请记住，如果捕获到 SIGCHLD，accept 可能会在 errno 设置为 EINTR 的情况下退出，而没有有效的连接，因此请记住在接受返回时检查这一点。

编辑：
不要忘记检查错误情况，即 fork 返回-1。

于 2009-01-11T19:33:43.807 回答
2

在 unix 上谈论 fork() 和线程并不完全正确。Fork 创建了一个全新的进程，它与父进程没有共享地址空间。

我认为您正在尝试实现按请求处理的模型，很像传统的 unix Web 服务器，例如 NCSA httpd 或 Apache 1.x，或者可能构建具有共享全局内存的多线程服务器：

按请求处理服务器：

当您调用 fork() 时，系统会创建父进程的克隆，包括文件描述符。这意味着您可以接受套接字请求然后分叉。子进程有套接字请求，它可以回复然后终止。

这在 unix 上相对有效，因为进程的内存不是物理复制的 - 页面在进程之间共享。当子进程写入内存时，系统使用一种称为写时复制的机制来逐页复制。因此，unix 上的每请求进程服务器的开销并不大，许多系统都使用这种架构。

于 2009-01-11T19:42:05.350 回答
1

最好使用 select() 函数，它使您能够在一个程序中侦听和连接不同的请求......它避免了阻塞，但分叉会为程序的副本创建一个新的地址空间，这会导致内存效率低下......

select(Max_descr, read_set, write_set, exception_set, time_out);

即你可以

fd_set* time_out;
fd_set* read_set;
listen(1);
listen(2);
while(1)
{
  if(select(20, read_set, NULL,NULL, timeout) >0)
  {
    accept(1);
    accept(2); .....
    pthread_create(func);....
  }
  else
}
于 2010-11-16T08:34:46.033 回答
0

检查 fork() 的返回值。如果为零，则您是子进程，您可以在完成工作后退出（）。如果它是一个正数，那么它是新创建的进程的进程 ID。如果子进程由于某种原因停留时间过长，这可以让您 kill() 子进程。

于 2009-01-11T19:27:21.323 回答
0

根据我的评论，这个服务器并不是真正的多线程，它是多进程的。

如果你想要一种简单的方法让它接受多个连接（并且你不太关心性能），那么你可以让它与inetd一起工作。这将产生进程和作为守护进程的工作留给inetd，您只需要编写一个处理和处理单个连接的程序。编辑：或者如果这对你来说是一个编程练习，你可以获取 inetd 的源代码，看看它是如何做到的

您也可以使用 select 来做您想做的事，而无需线程或新进程。

这是一篇解释如何使用 select 的文章（与 fork 或线程相比开销非常低 - 这是一个以这种方式编写的轻量级 Web 服务器的示例）

此外，如果您不喜欢在 C 中执行此操作，并且 C++ 也可以，您可以考虑将代码移植到使用ACE。这也是寻找如何做到这一点的设计模式的好地方，因为我相信它几乎支持任何连接处理模型并且非常便携。

于 2009-01-11T19:42:23.787 回答