C++跨平台（十一）：进程管理与IPC

创建进程fork与exec的哲学分歧在Unix世界中创建一个新进程分为两步fork()复制当前进程包括内存空间、文件描述符、信号处理等然后子进程调用exec()族函数用新程序镜像替换自身。这种先复制再替换的模式源于1970年代的Unix设计其精妙之处在于fork()之后、exec()之前可以做精细的环境设置如重定向标准输入输出、修改环境变量、设置进程组而这些操作自然地在子进程的上下文中进行不影响父进程。Windows从完全不同的设计理念出发。CreateProcess()一次性完成进程创建和新程序加载没有fork的概念。创建子进程需要传递一个STARTUPINFO结构体来配置标准句柄、窗口状态等。这两种范式在API层面的差异是根本性的无法简单地在其中一个平台上模拟另一个。在Unix上模拟CreateProcess是相对可行的forkexec 各种设置但在Windows上模拟fork几乎不可能——Cywin做了一个惊人复杂的实现但性能代价巨大。跨平台进程创建// 跨平台进程创建封装#includestring#includevector#includeoptionalstructProcessResult{intexit_code;std::string stdout_output;std::string stderr_output;};std::optionalProcessResultrun_process(conststd::stringexecutable,conststd::vectorstd::stringargs,conststd::optionalstd::stringstdin_inputstd::nullopt){ProcessResult result;#ifdef_WIN32// Windows: CreateProcess 管道HANDLE stdout_read,stdout_write;HANDLE stderr_read,stderr_write;HANDLE stdin_read,stdin_write;SECURITY_ATTRIBUTES sa{sizeof(sa),nullptr,TRUE};CreatePipe(stdout_read,stdout_write,sa,0);CreatePipe(stderr_read,stderr_write,sa,0);CreatePipe(stdin_read,stdin_write,sa,0);SetHandleInformation(stdout_read,HANDLE_FLAG_INHERIT,0);SetHandleInformation(stderr_read,HANDLE_FLAG_INHERIT,0);STARTUPINFOW si{sizeof(si)};si.dwFlagsSTARTF_USESTDHANDLES;si.hStdOutputstdout_write;si.hStdErrorstderr_write;si.hStdInputstdin_read;// 构建命令行Windows需要完整的命令行字符串std::wstring cmd_lineL\std::wstring(executable.begin(),executable.end())L\;for(constautoarg:args){cmd_lineL \std::wstring(arg.begin(),arg.end())L\;}PROCESS_INFORMATION pi{};wchar_t*cmd_buffercmd_line.data();if(!CreateProcessW(nullptr,cmd_buffer,nullptr,nullptr,TRUE,CREATE_NO_WINDOW,nullptr,nullptr,si,pi)){returnstd::nullopt;}CloseHandle(stdout_write);CloseHandle(stderr_write);CloseHandle(stdin_read);// 写入stdinif(stdin_input){DWORD written;WriteFile(stdin_write,stdin_input-data(),static_castDWORD(stdin_input-size()),written,nullptr);}CloseHandle(stdin_write);// 读取stdout/stderrcharbuffer[4096];DWORD bytes_read;while(ReadFile(stdout_read,buffer,sizeof(buffer),bytes_read,nullptr)bytes_read0){result.stdout_output.append(buffer,bytes_read);}while(ReadFile(stderr_read,buffer,sizeof(buffer),bytes_read,nullptr)bytes_read0){result.stderr_output.append(buffer,bytes_read);}WaitForSingleObject(pi.hProcess,INFINITE);DWORD exit_code;GetExitCodeProcess(pi.hProcess,exit_code);result.exit_codestatic_castint(exit_code);CloseHandle(pi.hProcess);CloseHandle(pi.hThread);CloseHandle(stdout_read);CloseHandle(stderr_read);#else// POSIX: fork exec 管道// 使用 popen 的增强版手动管道实现以获得stderr分离intstdout_pipe[2],stderr_pipe[2],stdin_pipe[2];if(pipe(stdout_pipe)0||pipe(stderr_pipe)0||pipe(stdin_pipe)0){returnstd::nullopt;}pid_t pidfork();if(pid0){returnstd::nullopt;}if(pid0){// 子进程设置管道并execdup2(stdin_pipe[0],STDIN_FILENO);dup2(stdout_pipe[1],STDOUT_FILENO);dup2(stderr_pipe[1],STDERR_FILENO);close(stdin_pipe[1]);close(stdout_pipe[0]);close(stderr_pipe[0]);std::vectorconstchar*argv;argv.push_back(executable.c_str());for(constautoa:args)argv.push_back(a.c_str());argv.push_back(nullptr);execvp(executable.c_str(),const_castchar*const*(argv.data()));_exit(127);// exec失败}// 父进程close(stdin_pipe[0]);close(stdout_pipe[1]);close(stderr_pipe[1]);if(stdin_input){write(stdin_pipe[1],stdin_input-data(),stdin_input-size());}close(stdin_pipe[1]);charbuffer[4096];ssize_t n;while((nread(stdout_pipe[0],buffer,sizeof(buffer)))0){result.stdout_output.append(buffer,n);}while((nread(stderr_pipe[0],buffer,sizeof(buffer)))0){result.stderr_output.append(buffer,n);}intstatus;waitpid(pid,status,0);result.exit_codeWIFEXITED(status)?WEXITSTATUS(status):-1;close(stdout_pipe[0]);close(stderr_pipe[0]);#endifreturnresult;}以上是手写实现。在实际项目中更推荐使用经过验证的跨平台库。Boost.ProcessBoost 1.64提供了全面的跨平台进程管理包括创建、管道重定向、环境变量控制、进程组管理和异步等待。它内部已经在Windows上使用了CreateProcess在POSIX上使用了forkexec并且处理了管道正确关闭、句柄泄漏等大量边缘情况。进程间通信IPC多个进程之间需要交换数据和同步状态这就是IPCInter-Process Communication的领域。各平台提供了丰富但互不兼容的IPC机制管道Pipes管道是最简单也最通用的IPC形式。匿名管道通常用于父子进程之间通过继承文件描述符/句柄传递命名管道则允许任意进程通信。Windows命名管道有自己独特的APICreateNamedPipe、ConnectNamedPipe支持网络透明同一网络中的不同机器可以通过命名管道通信并且支持同步和异步Overlapped I/O两种模式。POSIX命名管道FIFO通过mkfifo创建使用普通文件I/O APIopen、read、write操作不支持网络透明。对于跨平台命名管道推荐使用Unix Domain Socket见下文在POSIX上替代FIFO它在Linux和macOS上都支持。或者更进一步使用更高级的IPC库来屏蔽底层差异。Unix Domain Socket vs Windows Named PipeUnix Domain Socket是Linux/macOS上最强大和灵活的本地IPC机制。它支持流式SOCK_STREAM类似TCP和数据报SOCK_DGRAM类似UDP支持在进程间传递文件描述符SCM_RIGHTS辅助数据而且API与网络socket完全一致——这意味着你可以先在同一台机器上使用Domain Socket后续需要扩展到多机通信时仅需更换地址族。Windows Named Pipe的功能大致对应——它支持字节流和消息模式支持异步I/O和重叠I/O但在API设计上完全不同。如果不想处理这些差异以下库提供了跨平台IPC抽象ZeroMQØMQ将socket抽象为消息队列支持inproc://进程内、ipc://进程间、tcp://网络传输一套API覆盖所有场景。Boost.Interprocess提供共享内存、内存映射文件、命名互斥量、命名条件变量。gRPC基于HTTP/2的跨平台RPC框架同时适用于本地和远程通信。共享内存共享内存是最高性能的IPC机制——多个进程直接映射同一块物理内存数据传递无需内核中转。但共享内存也是最复杂的IPC方式你需要自己处理同步互斥锁、信号量和数据结构布局。// 共享内存的跨平台抽象概念性示例#includeboost/interprocess/shared_memory_object.hpp#includeboost/interprocess/mapped_region.hpp#includeboost/interprocess/sync/interprocess_mutex.hppnamespacebipboost::interprocess;structSharedData{bip::interprocess_mutex mutex;intcounter;charmessage[256];};// 创建方bip::shared_memory_objectshm(bip::create_only,my_shared_memory,bip::read_write);shm.truncate(sizeof(SharedData));bip::mapped_regionregion(shm,bip::read_write);auto*datanew(region.get_address())SharedData;// 访问方bip::shared_memory_objectshm2(bip::open_only,my_shared_memory,bip::read_write);bip::mapped_regionregion2(shm2,bip::read_write);auto*data2static_castSharedData*(region2.get_address());在Windows上boost::interprocess::shared_memory_object底层使用文件映射CreateFileMappingMapViewOfFile在POSIX上使用shm_openmmap。interprocess_mutex在Windows上基于InterlockedCompareExchange实现自旋锁事件回退在POSIX上基于pthread_mutex_t放置在共享内存中的特殊变体PTHREAD_PROCESS_SHARED。环境变量环境变量是向子进程传递配置的最简单方式。标准C/C提供了getenv和setenv/putenv但跨平台使用时需要注意#ifdef_WIN32// Windows: _putenv_s 或 SetEnvironmentVariable_putenv_s(MY_VAR,my_value);// 或者SetEnvironmentVariableA(MY_VAR,my_value);// 读取charbuf[256];size_t len;getenv_s(len,buf,sizeof(buf),MY_VAR);#else// POSIX: setenvsetenv(MY_VAR,my_value,1);// 1 覆盖已存在// 读取constchar*valgetenv(MY_VAR);#endifgetenv返回的指针在POSIX上指向进程环境块中的真实内存可以被后续的setenv/putenv改变。在Windows上这个行为不一致——应该将返回的指针视为失效时间不确定的临时缓冲。此外C标准并未将setenv标准化它在cstdlib的POSIX扩展中Windows用_putenv_s。如果需要更复杂的跨平台环境变量控制如修改当前进程的环境变量而不影响系统Boost.Process提供了boost::process::environment类。守护进程与服务将程序作为后台服务运行在Linux上是守护进程daemon在Windows上是Windows Service在macOS上是LaunchDaemon。三者在概念上相似但API和管理方式完全不同。Linux的守护进程是普通进程但通过调用daemon()或手动forksetsid脱离了控制终端。程序需要自己处理日志通常重定向到syslog、PID文件、信号SIGTERM优雅退出等。Windows Service由服务控制管理器SCM管理必须实现特定的回调函数ServiceMain、HandlerEx、响应SERVICE_CONTROL_STOP等控制码。服务程序需要通过StartServiceCtrlDispatcher注册这意味着main函数的控制流与普通程序完全不同。macOS的LaunchDaemon由launchdPID 1管理通过plistXML格式配置文件描述启动条件和行为。程序本身通常是普通进程由launchd负责启动、监控和重启。对跨平台项目而言如果程序需要作为后台服务运行通常的做法是核心逻辑保持平台无关用一个薄的平台适配层处理服务/守护进程的注册和管理。或者干脆用Docker/systemd这样的容器/编排系统来管理服务生命周期把后台运行的问题外移。