최근 Swoole을 기반으로 개발된 imi 프레임워크를 사용하여 프로젝트를 개발하던 중 프로젝트 초기화 처리를 해야 한다는 요구사항이 발생했습니다. 초기화 프로세스가 완료되기 전에 Swoole이 요청을 처리하는 것을 원하지 않습니다. 일부 로드되지 않은 값이 있을 수 있으므로 요청 처리에 문제가 발생할 가능성이 높습니다.
문제 해결을 위한 사고 과정과 데모 코드는 아래와 같습니다.
먼저 분석 후 Swoole은 다중 프로세스 모드로 실행되며 Master
, Manager
, Worker
프로세스로 구분됩니다. Master
、Manager
、Worker
进程。
Master 进程就是我们启动服务的 cli 命令文件所在进程,在这里面初始化有一个问题,这里所有加载的类、全局变量,其它 Worker 进程里都可以使用,无法热重启生效。
Manager 进程的情况基本和上面差不多。
那么只有在 Worker 进程做处理了,但如果写在 WorkerStart 事件里,每个 Worker 进程都会去执行。
<strong>WorkerStart</strong>
마스터 프로세스는 서비스를 시작하는 cli 명령 파일이 위치한 프로세스입니다. 여기서 초기화에 문제가 있습니다. 로드된 모든 클래스와 전역 변수는 다른 작업자 프로세스에서 사용될 수 있으며 적용을 위해 핫 재시작될 수 없습니다. .
<p>WorkerStart</p>
이벤트 정의:
function onWorkerStart(swoole_server $server, int $worker_id);$worker_id는 이 작업자 프로세스의 ID를 나타내는 0-$worker_num 사이의 숫자입니다🎜🎜이것은 처리하기 쉽습니다. 프로젝트 초기화 이벤트를 트리거하려면 작업자 ID가 0입니다. 남은 질문은 초기화 실행이 완료될 때까지 모든 작업자 프로세스가 요청을 처리하지 못하도록 하는 방법입니다. 🎜🎜생각해보고 시도해 보니 이 문제는 코루틴을 걸면 해결될 수 있습니다. 데모 코드는 다음과 같습니다. 🎜
<?php use Swoole\Coroutine; $http = new swoole_http_server('127.0.0.1', 8080); $http->on('WorkerStart', function(swoole_http_server $server, $workerId){ $initFlagFile = __DIR__ . '/init.flag'; if(0 === $server->worker_id && (!is_file($initFlagFile) || file_get_contents($initFlagFile) != $server->manager_pid)) { // 处理项目初始化事件 initApp(); // 写入文件,保证不再重复触发项目初始化事件 file_put_contents($initFlagFile, $server->manager_pid); // 当前worker进程恢复协程 resumeCos(); // 通知其它worker进程 for($i = 1; $i < $server->setting['worker_num']; ++$i) { $server->sendMessage('init', $i); } } }); $http->on('PipeMessage', function(swoole_http_server $server, $srcWorkerId, $data) { if(0 === $srcWorkerId && 'init' === $data && !defined('APP_INITED')) { // 其它worker进程恢复协程 resumeCos(); } }); $http->on('request', function (swoole_http_request $request, swoole_http_response $response) { // 判断未初始化完毕,则挂起协程 if(!defined('APP_INITED')) { $GLOBALS['WORKER_START_END_RESUME_COIDS'][] = Coroutine::getuid(); Coroutine::suspend(); } $response->header('content-type', 'text/html;charset=utf-8'); $response->end('IMI 是一款基于 Swoole 开发的协程 PHP 开发框架,拥有常驻内存、协程异步非阻塞IO等优点。官方网站:<a href="https://imiphp.com" target="_blank">https://imiphp.com</a>'); }); $http->start(); /** * 处理项目初始化事件,比如这里延时5秒,模拟初始化处理 * * @return void */ function initApp() { $count = 5; for($i = 0; $i < $count; ++$i) { echo 'initing ', ($i + 1), '/', $count, PHP_EOL; sleep(1); } } /** * 恢复协程 * * @return void */ function resumeCos() { define('APP_INITED', true); $coids = $GLOBALS['WORKER_START_END_RESUME_COIDS'] ?? []; fwrite(STDOUT, 'suspend co count: ' . count($coids) . PHP_EOL); foreach($coids as $id) { Coroutine::resume($id); } }🎜요청 이벤트에서 초기화가 완료되었는지 판단하여 그렇지 않은 경우 현재 코루틴을 일시 중지합니다. 코루틴은 ID가 전역 변수에 추가됩니다. 🎜🎜0번째 작업자 프로세스가 초기화를 완료하면 초기화 기간 동안 들어온 요청이 이때 다른 작업자 프로세스에 메시지를 보내 일시 중단된 코루틴을 깨웁니다. 🎜
위 내용은 Swoole 맞춤형 프로젝트 초기화 이벤트 처리 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!