So implementieren Sie die benutzerdefinierte Projektinitialisierungsereignisbehandlung von Swoole (Code)

Der Inhalt dieses Artikels befasst sich mit der Implementierung der benutzerdefinierten Projektinitialisierungsereignisverarbeitung (Code). Freunde in Not können sich darauf beziehen.

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 bearbeitet, 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 Master-, Manager- und Worker-Prozesse unterteilt.

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

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

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

WorkerStart-Ereignisdefinition:

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

$worker_id ist eine Zahl zwischen 0 und $worker_num, die die ID dieses Worker-Prozesses angibt.

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

Nachdem Sie darüber nachgedacht und es ausprobiert haben, kann dieses Problem durch Aufhängen der Coroutine gelöst werden. 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 nicht, 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.

Verwandte Empfehlungen:

Detaillierte Erläuterung der Javascript-Implementierung benutzerdefinierter Ereignisse_Javascript-Fähigkeiten

So verwenden Sie benutzerdefinierte Angularjs-Anweisungen im Projekt Verwenden Sie

Das obige ist der detaillierte Inhalt vonSo implementieren Sie die benutzerdefinierte Projektinitialisierungsereignisbehandlung von Swoole (Code). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!