php把运行时重构成常驻内存 + 多进程 + 事件驱动（Reactor） 模式完整流程=workerman

纯手写版不靠 Workerman/Swoole。 只用 PHP 自带能力pcntl_fork stream_socket_server stream_select实现你要的 常驻内存 多进程 Reactor 事件驱动 --- 一、先说目标大白话 把 PHP 从“脚本模式”改成“服务模式” - 脚本模式请求来一次PHP 启一次用完就死 - 服务模式进程长期活着反复处理请求 并发靠两层1. 多进程主进程 fork 多个 worker吃多核2. 事件驱动每个 worker 用 stream_select 盯很多连接谁有数据就处理谁 --- 二、目录结构 mini-reactor/ ├── server.php └── src/ ├── Master.php ├── Worker.php ├── Reactor.php ├── Http.php └── App.php --- 三、完整代码可直接跑1)src/Reactor.php?php namespace MiniReactor;class Reactor{private array$readStreams[];private array$readHandlers[];private bool$runningtrue;publicfunctionadd($stream, callable$handler): void{$id(int)$stream;stream_set_blocking($stream,false);$this-readStreams[$id]$stream;$this-readHandlers[$id]$handler;}publicfunctiondel($stream): void{$id(int)$stream;unset($this-readStreams[$id],$this-readHandlers[$id]);}publicfunctionstop(): void{$this-runningfalse;}publicfunctionrun(): void{while($this-running){if(!$this-readStreams){usleep(10000);continue;}$readarray_values($this-readStreams);$write[];$except[];$nstream_select($read,$write,$except,1);if($nfalse||$n0){continue;}foreach($readas$stream){$id(int)$stream;if(isset($this-readHandlers[$id])){($this-readHandlers[$id])($stream,$this);}}}}}---2)src/Http.php?php namespace MiniReactor;class HttpRequest{public string$methodGET;public string$path/;public array$query[];public array$headers[];public string$body;}class Http{public staticfunctionparse(string$raw): ?HttpRequest{$partsexplode(\r\n\r\n,$raw,2);$head$parts[0]??;$body$parts[1]??;$linesexplode(\r\n,$head);if(count($lines)1)returnnull;$startarray_shift($lines);if(!preg_match(#^([A-Z])\s(\S)\sHTTP/1\.[01]$#,$start,$m)){returnnull;}$reqnew HttpRequest();$req-method$m[1];$uri$m[2];$req-pathparse_url($uri, PHP_URL_PATH)?:/;parse_str(parse_url($uri, PHP_URL_QUERY)?:,$req-query);foreach($linesas$line){if(!str_contains($line,:))continue;[$k,$v]explode(:,$line,2);$req-headers[strtolower(trim($k))]trim($v);}$req-body$body;return$req;}public staticfunctionresponse(int$status, array$data): string{$reasonmatch($status){200OK,400Bad Request,404Not Found,500Internal Server Error, defaultOK,};$jsonjson_encode($data, JSON_UNESCAPED_UNICODE);$headers[HTTP/1.1 {$status} {$reason},Content-Type: application/json; charsetutf-8,Content-Length: .strlen($json),Connection: close,,$json];returnimplode(\r\n,$headers);}}---3)src/App.php?php namespace MiniReactor;class App{private int$bootAt;private int$counter0;// 常驻内存状态这个worker处理了多少请求 publicfunction__construct(){$this-bootAttime();}publicfunctionhandle(HttpRequest$req): array{$this-counter;if($req-path/ping){return[status200,body[code0,msgpong,pidgetmypid(),uptime_sectime()-$this-bootAt,handled$this-counter,]];}if($req-path/hello){$name$req-query[name]??world;return[status200,body[code0,datahello {$name},pidgetmypid(),handled$this-counter,]];}return[status404,body[code404,msgnot found,pidgetmypid(),handled$this-counter,]];}}---4)src/Worker.php?php namespace MiniReactor;class Worker{private$listenSocket;private Reactor$reactor;private App$app;private bool$stoppingfalse;publicfunction__construct($listenSocket){$this-listenSocket$listenSocket;$this-reactornew Reactor();$this-appnew App();// 常驻内存对象只初始化一次}publicfunctionrun(): void{pcntl_async_signals(true);pcntl_signal(SIGTERM,function(){$this-stoppingtrue;$this-reactor-stop();});pcntl_signal(SIGINT,function(){$this-stoppingtrue;$this-reactor-stop();});// 监听“有新连接”$this-reactor-add($this-listenSocket,function($serverSock, Reactor$reactor){$connstream_socket_accept($serverSock,0);if(!$conn)return;stream_set_blocking($conn,false);$buffer;// 监听“这个连接上有数据可读”$reactor-add($conn,function($client, Reactor$reactor)use($buffer){$chunkfread($client,8192);if($chunk||$chunkfalse){$reactor-del($client);fclose($client);return;}$buffer.$chunk;// 简化版读到头部结束就处理演示够用if(!str_contains($buffer,\r\n\r\n)){return;}$reqHttp::parse($buffer);if(!$req){fwrite($client, Http::response(400,[code400,msgbad request]));$reactor-del($client);fclose($client);return;}try{$ret$this-app-handle($req);$rawHttp::response($ret[status],$ret[body]);}catch(\Throwable$e){$rawHttp::response(500,[code500,msginternal error]);}fwrite($client,$raw);$reactor-del($client);fclose($client);});});echo[worker .getmypid().] started\n;$this-reactor-run();echo[worker .getmypid().] stopped\n;}}---5)src/Master.php?php namespace MiniReactor;class Master{private string$host;private int$port;private int$workerNum;private$listenSocket;private array$workers[];private bool$stoppingfalse;publicfunction__construct(string$host, int$port, int$workerNum){$this-host$host;$this-port$port;$this-workerNum$workerNum;}publicfunctionstart(): void{$errno0;$errstr;$contextstream_context_create([socket[so_reuseport1,backlog1024,]]);$this-listenSocketstream_socket_server(tcp://{$this-host}:{$this-port},$errno,$errstr, STREAM_SERVER_BIND|STREAM_SERVER_LISTEN,$context);if(!$this-listenSocket){throw new\RuntimeException(listen failed: {$errstr}({$errno}));}stream_set_blocking($this-listenSocket,false);pcntl_async_signals(true);pcntl_signal(SIGINT, fn()$this-gracefulStop());pcntl_signal(SIGTERM, fn()$this-gracefulStop());pcntl_signal(SIGCHLD, fn()$this-reap());echo[master .getmypid().] listen {$this-host}:{$this-port}, workers{$this-workerNum}\n;for($i0;$i$this-workerNum;$i){$this-forkWorker();}while(!$this-stopping){sleep(1);}$this-shutdownAll();}privatefunctionforkWorker(): void{$pidpcntl_fork();if($pid0){throw new\RuntimeException(fork failed);}if($pid0){$workernew Worker($this-listenSocket);$worker-run();exit(0);}$this-workers[$pid]true;echo[master] fork worker {$pid}\n;}privatefunctionreap(): void{while(($pidpcntl_waitpid(-1,$status,WNOHANG))0){unset($this-workers[$pid]);echo[master] worker {$pid} exited\n;if(!$this-stopping){$this-forkWorker();// 自动补齐}}}privatefunctiongracefulStop(): void{$this-stoppingtrue;echo[master] stopping...\n;}privatefunctionshutdownAll(): void{foreach(array_keys($this-workers)as$pid){posix_kill($pid, SIGTERM);}while(count($this-workers)0){$this-reap();usleep(100000);}if(is_resource($this-listenSocket)){fclose($this-listenSocket);}echo[master] shutdown done\n;}}---6)server.php启动入口?php require_once __DIR__./src/Reactor.php;require_once __DIR__./src/Http.php;require_once __DIR__./src/App.php;require_once __DIR__./src/Worker.php;require_once __DIR__./src/Master.php;use MiniReactor\Master;$host0.0.0.0;$port8080;$cpu(int)trim(shell_exec(nproc 2/dev/null)?:4);$workerNummax(2,$cpu);$masternew Master($host,$port,$workerNum);$master-start();--- 四、怎么启动 php server.php 测试curlhttp://127.0.0.1:8080/pingcurlhttp://127.0.0.1:8080/hello?namejack你会看到 pid 变化说明请求被不同 worker 处理。 --- 五、完整流程超白话1. Master 启动并监听端口2. Master fork 出多个 Worker3. 每个 Worker 创建一个 Reactor 循环并常驻4. 有新连接时Reactor 收到“可读事件”5. accept 连接再监听这个连接的读事件6. 读到 HTTP 请求交给 App 处理7. 写回响应关闭连接8. 回到 Reactor 等下一波事件9. 某个 Worker 挂了Master 自动补一个 --- 六、这版是“自己写”的价值和边界 价值 - 你能完全理解底层模型不黑箱 - 任何框架Workerman/Swoole本质都能看懂 边界 这份代码是教学可运行版不是完整生产HTTP服务器。生产还要补 - Keep-Alive、分块传输、大包拆包、超时 - 连接限流、日志、监控、热重启 - 真正数据库连接池与慢查询保护 --- 一句话收尾 这份代码已经是纯手写的 PHP 常驻内存 多进程 Reactor 最小完整实现你可以直接在这个骨架上继续加协议细节和业务能力。