当前位置：首页 > news >正文

多进程服务器

news 2025/7/20 12:46:58

深入理解并发服务器与进程管理：从僵尸进程到多任务处理

并发服务器的三种实现方式

现代服务器需要同时处理多个客户端请求，主要有三种实现方式：

多进程服务器：为每个客户端创建一个独立进程
多路复用服务器：使用单个进程通过事件驱动处理多个连接
多线程服务器：为每个客户端创建一个线程

僵尸进程

什么是僵尸进程？

当一个进程完成任务后没有被正确销毁，它就成了僵尸进程。就像完成工作的工人没有被妥善安置，仍在系统中占据着进程表项。

产生原因解析

进程正常终止需要满足以下条件之一：

调用exit函数
在main函数中执行return语句

终止时，进程会产生一个返回值，这个值需要传递给父进程。关键在于：操作系统不会主动传递返回值，而是等待父进程主动索取。如果父进程不索取，子进程就会成为僵尸进程。

消灭僵尸进程的方法

1. 使用wait函数

pid_t wait(int *status);

wait函数会：

主动获取子进程返回值（存储在status指向的内存）
如果没有终止的子进程，父进程将阻塞等待
如果没有子进程也调用wait，进程会一直阻塞

2. 使用waitpid函数

pid_t waitpid(pid_t pid, int *status, int options);

waitpid提供了更多控制：

可以指定等待特定子进程
使用WNOHANG选项可非阻塞调用

信号机制：操作系统的"即时通讯"

当使用wait函数等待时，父进程会被阻塞。信号机制解决了这个问题。

signal函数：注册信号处理器

void (*signal(int sig, void (*func)(int)))(int);

这个看似复杂的声明实际上表示：

参数1：信号类型（如SIGALRM、SIGINT、SIGCHLD）
参数2：信号处理函数指针
返回：之前的信号处理函数指针

alarm函数：定时信号

unsigned int alarm(unsigned int seconds);

设置一个定时器，指定时间后产生SIGALRM信号。特别说明：

参数为0会取消之前的定时器
如果没有注册处理函数，默认会终止进程

sigaction函数：更强大的信号处理

int sigaction(int signum, const struct sigaction *act, struct sigaction *oldact);

sigaction结构体包含：

sa_handler：基本信号处理函数
sa_sigaction：扩展的信号处理函数
sa_mask：处理期间要阻塞的信号集
sa_flags：控制信号行为的标志位

基于多任务的并发服务器实现

fork创建子进程

pid_t fork(void);

关键特性：

复制父进程的文件描述符
不复制套接字本身（套接字是系统级的）
父子进程的文件描述符指向同一个套接字

正确的资源管理

重要原则：

子进程应关闭服务器套接字
父进程应关闭客户端套接字
只有当所有相关描述符都关闭，套接字才会真正销毁

分割TCP的I/O程序

在客户端程序中可以采用：

父进程负责发送数据
子进程负责接收数据

这样设计的优势：

实现全双工通信
任何时候都可以进行数据传输
提高响应速度

实际应用示例

并发服务器框架

while(1) {// 接受新连接clnt_sock = accept(serv_sock, ...);// 创建子进程pid = fork();if(pid == 0) {  // 子进程close(serv_sock);  // 关闭服务器套接字handle_client(clnt_sock);close(clnt_sock);exit(0);  // 子进程退出}else {  // 父进程close(clnt_sock);  // 关闭客户端套接字// 注册SIGCHLD处理函数防止僵尸进程signal(SIGCHLD, handle_child_term);}
}

信号处理示例

void handle_child_term(int sig) {int status;pid_t pid = waitpid(-1, &status, WNOHANG);if(WIFEXITED(status))printf("Child %d terminated\n", pid);
}int main() {struct sigaction act;act.sa_handler = handle_child_term;sigemptyset(&act.sa_mask);act.sa_flags = 0;sigaction(SIGCHLD, &act, 0);// ...服务器代码...
}