スウールをスムーズに再開する方法

swoole スムーズな再起動

swoole では、メインプロセスにさまざまなシグナルを送信することができ、メインプロセスはさまざまなシグナルを受け取ります。信号タイプが処理されます。 たとえば、次の

SIGTERM (洗練された終了シグナル) は、プロセスを直接終了するのではなく、現在のプログラムの実行が終了した後にプロセスを中断します (推奨学習: swoole ビデオ チュートリアル)

SIGUSR1、すべてのワーカー プロセスをスムーズに再起動します

SIGUSR2、すべてのタスク プロセスをスムーズに再起動します

スムーズな再起動の原則は、メイン プロセスが SIGUSR1 シグナルを受信すると、メイン プロセスが子プロセスに安全な終了シグナルを送信することです。いわゆる安全な終了とは、メイン プロセスがワーカー プロセスは直接強制終了されませんが、子プロセスが現在の作業の処理を完了するのを待ってから、見事に「引退」させ、最後に新しい子プロセスを開始します (新しい PHP プログラム コードをリロードします)。

次に、「retirement」コマンドを他の子プロセスに送信し、すべての子プロセスを順番に再起動します。

スムーズな再起動とは、実際には、古い子プロセスを 1 つずつ終了させ、新しいプロセスを再作成することを意味することに気づきました。スムーズな再起動中にユーザーに影響を与えないようにするには、ユーザー関連のステータス情報がプロセスに保存されないようにする必要があります。つまり、プロセスの終了による情報の損失を避けるために、ビジネス プロセスをステートレスにする必要があります。

非常に良い感じです。再起動するにはメインプロセスにシグナルを送信するだけです。

swoole では、再起動は Worker プロセスの開始後にロードされたファイルに対してのみ有効です。これはどういう意味ですか? 再起動は、onWorkerStart コールバックの後にロードされたファイルに対してのみ意味があることを意味します。ワーカー プロセスが開始される前にメモリにロードされたファイルを再度有効にしたい場合は、サーバーをシャットダウンして再起動するしかありません。

ここまで述べたので、ワーカー プロセスを効果的に再起動するために SIGUSR1 シグナルをメイン プロセスに送信する方法を確認する例を書いてみましょう。

まず、onReceive コールバックのデータを処理するための Test クラスを作成します。なぜ onReceive コールバック ビジネスを取り出して別に記述する必要があるのでしょうか? サンプルを読めば理解できると思います。

<?php

class Test
{
    public function run($data)
    {
        echo $data;
    }
}

Test::run メソッドの最初のステップは、swoole_server によって受信されたデータをエコーすることです。

<?php
require_once("Test.php");
class NoReload
{
    private $_serv;
    private $_test;
    /**
     * init
     */
    public function __construct()
    {
        $this->_serv = new Swoole\Server("127.0.0.1", 9501);
        $this->_serv->set([
            &#39;worker_num&#39; => 1,
        ]);
        $this->_serv->on(&#39;Receive&#39;, [$this, &#39;onReceive&#39;]);
        $this->_test = new Test;
    }
    /**
     * start server
     */
    public function start()
    {
        $this->_serv->start();
    }
    public function onReceive($serv, $fd, $fromId, $data)
    {
        $this->_test->run($data);
    }
}
$noReload = new NoReload;
$noReload->start();

new Swoole\Server

このスタイルの書き方は、下線の書き方と同等です。Swoole は両方の書き方をサポートしています。

new swoole_server

さらに、クラスの前に、サーバーのコード ロジックを見てみましょう。 Workerプロセスをセットアップする際に、swoole_serverのonReceiveコールバックとしてNoReload::onReceiveメソッドを登録し、onReceiveコールバックで受信したデータをTest::runメソッドに渡しました。処理。

以上がスウールをスムーズに再開する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。