1. 多进程编程基础概念在Linux系统中进程是程序执行的基本单位。每个进程都拥有独立的地址空间、数据栈和其他用于跟踪执行的辅助数据。理解多进程编程首先需要明确几个核心概念1.1 进程与线程的区别进程是资源分配的基本单位它拥有独立的虚拟地址空间独立的文件描述符表独立的信号处理方式独立的用户ID和组ID而线程则是CPU调度的基本单位属于同一进程的线程共享相同的地址空间相同的全局变量相同的文件描述符相同的信号处理方式关键区别进程间通信(IPC)需要特殊机制而线程间可以直接通过共享的全局变量通信1.2 进程的生命周期一个Linux进程通常经历以下状态变化创建通过fork()或exec()系列函数创建就绪等待CPU时间片运行正在CPU上执行阻塞等待I/O等事件终止正常退出或被信号终止2. 进程创建与终止2.1 进程创建方式2.1.1 system()函数最简单的进程创建方式但效率较低#include stdlib.h int system(const char *command);示例执行ls命令#include stdio.h #include stdlib.h int main(void) { system(ls -l); printf(Command completed\n); return 0; }注意事项会创建一个shell进程来执行命令存在安全风险命令注入不适合高性能场景2.1.2 fork()系统调用创建子进程的标准方式#include unistd.h pid_t fork(void);典型使用模式#include stdio.h #include unistd.h #include sys/wait.h int main() { pid_t pid fork(); if (pid 0) { // 子进程 printf(Child process (PID%d)\n, getpid()); exit(0); } else if (pid 0) { // 父进程 printf(Parent process (PID%d)\n, getpid()); wait(NULL); // 等待子进程结束 } else { perror(fork failed); return 1; } return 0; }关键点fork()返回两次父进程返回子进程PID子进程返回0子进程获得父进程的完整副本写时复制父子进程执行相同的代码可通过返回值区分2.1.3 exec系列函数替换当前进程映像#include unistd.h int execl(const char *path, const char *arg, ...); int execv(const char *path, char *const argv[]); // 其他变体execlp, execvp, execle, execve示例#include unistd.h #include stdio.h int main() { printf(Before exec\n); execl(/bin/ls, ls, -l, NULL); printf(This wont be printed\n); // exec成功则不返回 return 0; }使用场景需要完全替换当前进程常与fork()配合使用fork后子进程调用exec2.2 进程终止方式正常终止从main返回调用exit()调用_exit()或_Exit()异常终止调用abort()被信号终止区别exit()会执行atexit注册的函数刷新I/O缓冲区_exit()直接终止不做清理3. 进程间通信(IPC)机制3.1 消息队列内核维护的优先级队列特点消息有类型和优先级支持非阻塞读写消息持久化直到被读取API示例#include mqueue.h mqd_t mq_open(const char *name, int oflag, mode_t mode, struct mq_attr *attr); int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, unsigned msg_prio); ssize_t mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned *msg_prio);典型问题消息大小限制可通过mq_getattr检查队列满时的阻塞行为需要手动删除mq_unlink3.2 共享内存最快的IPC方式特点零拷贝直接内存访问需要同步机制如信号量基于文件系统或匿名映射API流程shm_open创建共享内存对象ftruncate设置大小mmap映射到进程地址空间示例#include sys/mman.h #include sys/stat.h #include fcntl.h int main() { int fd shm_open(/myshm, O_CREAT | O_RDWR, 0666); ftruncate(fd, 4096); char *ptr mmap(NULL, 4096, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); // 使用ptr访问共享内存 sprintf(ptr, Hello shared memory); munmap(ptr, 4096); shm_unlink(/myshm); return 0; }注意事项必须处理同步问题竞态条件注意内存对齐和缓存一致性及时释放资源3.3 UNIX域套接字类似网络套接字但更高效特点基于文件系统路径全双工通信支持流式(SOCK_STREAM)和数据报(SOCK_DGRAM)服务端示例#include sys/socket.h #include sys/un.h int main() { int sockfd socket(AF_UNIX, SOCK_STREAM, 0); struct sockaddr_un addr; memset(addr, 0, sizeof(addr)); addr.sun_family AF_UNIX; strncpy(addr.sun_path, /tmp/mysocket, sizeof(addr.sun_path)-1); bind(sockfd, (struct sockaddr*)addr, sizeof(addr)); listen(sockfd, 5); int client accept(sockfd, NULL, NULL); // 与client通信 close(client); close(sockfd); unlink(/tmp/mysocket); return 0; }优势比TCP套接字更高效无协议栈开销支持传递文件描述符可靠的字节流通信3.4 管道3.4.1 匿名管道用于有亲缘关系的进程#include unistd.h int pipe(int pipefd[2]); // pipefd[0]读端pipefd[1]写端典型用法int fd[2]; pipe(fd); if (fork() 0) { close(fd[1]); // 子进程关闭写端 read(fd[0], buf, sizeof(buf)); } else { close(fd[0]); // 父进程关闭读端 write(fd[1], hello, 6); }限制单向通信只能在父子进程间使用容量有限通常4KB3.4.2 命名管道(FIFO)通过文件系统可见#include sys/stat.h int mkfifo(const char *pathname, mode_t mode);使用示例// 进程A写 int fd open(/tmp/myfifo, O_WRONLY); write(fd, hello, 6); close(fd); // 进程B读 int fd open(/tmp/myfifo, O_RDONLY); read(fd, buf, sizeof(buf)); close(fd);特点可以用于任意进程间阻塞式打开除非指定O_NONBLOCK内核缓冲有限3.5 信号量用于进程同步POSIX信号量API#include semaphore.h sem_t *sem_open(const char *name, int oflag, mode_t mode, unsigned int value); int sem_wait(sem_t *sem); // P操作 int sem_post(sem_t *sem); // V操作典型使用模式sem_t *sem sem_open(/mysem, O_CREAT, 0666, 1); sem_wait(sem); // 进入临界区 // 访问共享资源 sem_post(sem); // 离开临界区 sem_close(sem);注意事项有名信号量需要唯一名称必须正确处理错误返回避免死锁锁定顺序一致4. IPC机制比较与选型机制适用场景性能复杂度同步需求消息队列结构化消息传递中中低共享内存大数据量、高性能需求高高高UNIX域套接字流式数据、复杂通信模式中高中中管道简单数据传递、命令行工具链中低中信号量进程同步高高必须选型建议需要最高性能 → 共享内存信号量结构化消息传递 → 消息队列流式通信 → UNIX域套接字简单工具集成 → 管道同步控制 → 信号量5. 实战经验与陷阱5.1 常见问题排查问题1消息队列消息丢失检查队列是否已满errnoEAGAIN确认接收方优先级设置正确检查消息大小是否超过限制问题2共享内存数据损坏确保使用了同步机制检查内存对齐问题验证缓存一致性可能需要内存屏障问题3管道阻塞确认所有写端都已关闭读端收到EOF检查进程是否死锁考虑使用非阻塞模式5.2 性能优化技巧共享内存使用大页内存Hugepages适当调整共享区域大小考虑缓存友好的数据布局UNIX域套接字启用SO_SNDBUF/SO_RCVBUF调优考虑使用sendmsg/recvmsg批量传输对于高性能场景使用SCM_RIGHTS传递文件描述符消息队列合理设置消息优先级批量处理消息减少上下文切换监控队列深度避免积压5.3 安全注意事项所有IPC资源都应设置适当权限命名资源如消息队列、共享内存使用唯一名称及时清理不再使用的资源unlink/close验证输入数据防止缓冲区溢出考虑使用能力(Capabilities)限制进程权限6. 高级主题与扩展6.1 进程组与会话进程组一组相关进程共享同一个PGID会话一个或多个进程组的集合控制终端会话可能有一个关联的终端相关系统调用pid_t setsid(void); // 创建新会话 pid_t getsid(pid_t pid); int setpgid(pid_t pid, pid_t pgid); // 设置进程组6.2 守护进程编写要点调用fork()然后退出父进程调用setsid()创建新会话再次fork()避免获取控制终端更改工作目录到根目录重设文件权限掩码关闭继承的文件描述符重定向标准I/O到/dev/null或日志文件6.3 实时进程调度Linux支持多种调度策略SCHED_OTHER默认分时调度SCHED_FIFO先进先出实时调度SCHED_RR轮转实时调度设置方法#include sched.h struct sched_param param { .sched_priority 50 }; sched_setscheduler(pid, SCHED_FIFO, param);注意事项需要CAP_SYS_NICE能力错误使用可能导致系统不稳定实时进程应定期让出CPU在实际项目中我曾遇到一个性能关键型应用通过合理组合共享内存和实时调度将处理延迟从毫秒级降低到微秒级。关键在于使用SHM_HUGETLB分配大页内存进程设置为SCHED_FIFO优先级80使用内存屏障确保数据一致性精心设计无锁数据结构这种深度优化需要对硬件和操作系统有深入理解建议在充分测试后再投入生产环境。