Implementierung der benutzerdefinierten Projektinitialisierungsereignisbehandlung von Swoole

Als ich kürzlich das auf Swoole basierende imi -Framework zur Entwicklung eines Projekts verwendete, stieß ich auf eine Anforderung, nämlich die Projektinitialisierungsverarbeitung durchzuführen. Sie möchten nicht, dass Swoole die Anfrage verarbeitet, bevor der Initialisierungsprozess abgeschlossen ist. Da möglicherweise einige Werte nicht geladen werden, besteht eine hohe Wahrscheinlichkeit, dass bei der Verarbeitung der Anfrage Probleme auftreten.

Der Denkprozess und der Democode zur Lösung des Problems sind unten aufgeführt.

Nach der Analyse läuft Swoole zunächst im Multiprozessmodus und ist in die Prozesse Master, Manager und Worker unterteilt.

Der Master-Prozess ist der Prozess, in dem sich die CLI-Befehlsdatei befindet, in der wir den Dienst starten. Hier liegt ein Problem mit der Initialisierung vor. Alle geladenen Klassen und globalen Variablen können in anderen Worker-Prozessen verwendet werden heiß neu gestartet, um wirksam zu werden.

Die Situation des Manager-Prozesses ist grundsätzlich dieselbe wie oben.

Dann übernimmt nur der Worker-Prozess die Verarbeitung, aber wenn sie im WorkerStart-Ereignis geschrieben ist, wird sie von jedem Worker-Prozess ausgeführt.

<strong>WorkerStart</strong>Ereignisdefinition:

function onWorkerStart(swoole_server $server, int $worker_id);

$worker_id ist eine Zahl von 0-$worker_num, die die ID dieses Worker-Prozesses angibt

Dann Dies ist einfach zu handhaben. Stellen Sie direkt fest, dass die Worker-ID 0 ist, um das Projektinitialisierungsereignis auszulösen. Die verbleibende Frage ist, wie verhindert werden kann, dass alle Worker-Prozesse Anforderungen verarbeiten, bis die Initialisierungsausführung abgeschlossen ist.

Ich habe darüber nachgedacht und versucht, dieses Problem zu lösen, indem ich die Coroutine aufhänge. Der Democode lautet wie folgt:

<?php
 
use Swoole\Coroutine;
 
$http = new swoole_http_server(&#39;127.0.0.1&#39;, 8080);
 
$http->on(&#39;WorkerStart&#39;, function(swoole_http_server $server, $workerId){
    $initFlagFile = __DIR__ . &#39;/init.flag&#39;;
    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[&#39;worker_num&#39;]; ++$i)
        {
            $server->sendMessage(&#39;init&#39;, $i);
        }
    }
});
 
$http->on(&#39;PipeMessage&#39;, function(swoole_http_server $server, $srcWorkerId, $data) {
    if(0 === $srcWorkerId && &#39;init&#39; === $data && !defined(&#39;APP_INITED&#39;))
    {
        // 其它worker进程恢复协程
        resumeCos();
    }
});
 
$http->on(&#39;request&#39;, function (swoole_http_request $request, swoole_http_response $response) {
    // 判断未初始化完毕，则挂起协程
    if(!defined(&#39;APP_INITED&#39;))
    {
        $GLOBALS[&#39;WORKER_START_END_RESUME_COIDS&#39;][] = Coroutine::getuid();
        Coroutine::suspend();
    }
    $response->header(&#39;content-type&#39;, &#39;text/html;charset=utf-8&#39;);
    $response->end(&#39;IMI 是一款基于 Swoole 开发的协程 PHP 开发框架，拥有常驻内存、协程异步非阻塞IO等优点。官方网站：<a href="https://imiphp.com" target="_blank">https://imiphp.com</a>&#39;);
});
 
$http->start();
 
/**
 * 处理项目初始化事件，比如这里延时5秒，模拟初始化处理
 *
 * @return void
 */
function initApp()
{
    $count = 5;
    for($i = 0; $i < $count; ++$i)
    {
        echo &#39;initing &#39;, ($i + 1), &#39;/&#39;, $count, PHP_EOL;
        sleep(1);
    }
}
 
/**
 * 恢复协程
 *
 * @return void
 */
function resumeCos()
{
    define(&#39;APP_INITED&#39;, true);
    $coids = $GLOBALS[&#39;WORKER_START_END_RESUME_COIDS&#39;] ?? [];
    fwrite(STDOUT, &#39;suspend co count: &#39; . count($coids) . PHP_EOL);
    foreach($coids as $id)
    {
        Coroutine::resume($id);
    }
}

Durch Beurteilung, ob die Initialisierung im Anforderungsereignis abgeschlossen ist. Wenn die Initialisierung nicht abgeschlossen ist, hängen Sie die aktuelle Coroutine auf und fügen Sie die Coroutine-ID zur globalen Variablen hinzu.

Wenn der 0. Worker-Prozess die Initialisierung abschließt, weckt er die angehaltenen Coroutinen auf, indem er Nachrichten an andere Worker-Prozesse sendet. Die während des Initialisierungszeitraums eingegangenen Anforderungen werden zu diesem Zeitpunkt ausgeführt.

Das obige ist der detaillierte Inhalt vonImplementierung der benutzerdefinierten Projektinitialisierungsereignisbehandlung von Swoole. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!