Swooleを使用して複数のサーバーのコードを同時に更新する

この記事では主に、Swoole を使用して複数のサーバーを同時に更新するためのコードを紹介します。これには一定の参考値があります。ここで共有します。必要な友人は参照できます。

The Architecture of a小規模な Web サイトです。フロントにロードバランサーがあり、バックに複数の Web サーバーがあります。コードの更新が問題になります。1 つの FTP を 1 つずつ転送するのは現実的ではなく、転送漏れが発生しやすくなります。 2 つの WEB サーバーのコードが矛盾しています。

簡単なアイデア:

Websocket サーバーを使用して更新指示を送信し、Websocket クライアントが更新指示を受信して​​、git pull を実行します。コードを更新します。

WebSocket クライアントにはいくつかの役割があります:

• Solider: コマンドを受信しますが、コマンドは送信できません

• Commander : コマンドの送信

フローチャート:

コードの一部の実装:

<?php 
//Server.php
require_once &#39;./Table.php&#39;;

use Swoole\WebSocket\Server as WebSocketServer;

class Server
{
    protected $server;

    protected $table;

    public function __construct($config)
    {
        $this->table = new Table();
        $this->server = new WebSocketServer($config[&#39;host&#39;], $config[&#39;port&#39;]);
        $this->server->set($config[&#39;configuration&#39;]);
        $this->addEventListener();
    }

    public function addEventListener()
    {
        $this->server->on(&#39;open&#39;, Closure::fromCallable([$this, &#39;onOpen&#39;]));
        $this->server->on(&#39;message&#39;, Closure::fromCallable([$this, &#39;onMessage&#39;]));
        $this->server->on(&#39;close&#39;, Closure::fromCallable([$this, &#39;onClose&#39;]));
    }

    private function onOpen($server, $request)
    {
        if ($request->get[&#39;role&#39;] == &#39;commander&#39;) {
            $this->table->commander = $request->fd;
        } else {
            $soliders = $this->table->soliders;

            $soliders[] = $request->fd;

            $this->table->soliders = $soliders;
        }
    }

    private function onMessage($server, $frame)
    {
        if ($frame->fd == $this->table->commander) {
            $command = $frame->data;

            foreach ($this->table->soliders as $solider) {
                $this->server->push($solider, $command);
            }
        } else {
            $this->server->push($frame->fd, "You don not have any right to send message");
        }
    }

    private function onClose($server, $fd)
    {
        $soliders = $this->table->soliders;

        if (in_array($fd, $soliders)) {
            unset($soliders[array_search($fd, $soliders)]);
        }
    }

    public function run()
    {
        $this->server->start();
    }
}

$server = new Server([
    &#39;host&#39; => &#39;0.0.0.0&#39;,
    &#39;port&#39; => 8015,
    &#39;configuration&#39; => [
        &#39;daemonize&#39; => 1,
    ]
]);

$server->run();

<?php 
//Client.php
use Swoole\Http\Client as WebSocketClient;

class Client
{
    protected $protocol;

    protected $host;

    protected $port;

    protected $query;

    protected $client;

    protected $allow_events = [&#39;onOpen&#39;, &#39;onMessage&#39;, &#39;onClose&#39;];

    public function __construct($url)
    {
        list(&#39;scheme&#39; => $this->protocol, &#39;host&#39; => $this->host, &#39;port&#39; => $this->port, &#39;query&#39; => $this->query) = parse_url($url);

        if ($this->protocol == &#39;wss&#39;) {
            echo &#39;unsupport protocol&#39;;
        }

        $this->client = new WebSocketClient($this->host, $this->port);
    }

    public function start(Callable $callback)
    {
        $this->client->upgrade(&#39;/?&#39; . $this->query, $callback);
    }

    public function __set($field, $value)
    {
        if (in_array($field, $this->allow_events) && is_callable($value)) {
            $this->client->on(strtolower(substr($field, 2)), $value);
        } else {
            echo &#39;Unsupport Event&#39;;
        }        
    }
}

<?php 
//Solider.php
require_once &#39;./Client.php&#39;;

function parseCommand($data)
{
    return json_decode($data, true);
}

function updateCommand()
{
    //you can do something here
    exec(&#39;git pull&#39;);
    // exec(&#39;composer update&#39;);
    // exec(&#39;npm install&#39;);
}

$ws = new Client(&#39;ws://192.168.1.142:8015?role=solider&#39;);

$ws->onMessage = function($client, $frame) {
    list(&#39;command&#39; => $command, &#39;params&#39; => $params) = parseCommand($frame->data);

    echo $command;

    switch ($command) {
        case &#39;update&#39;:
            updateCommand();
            break;
    }
};

$ws->onClose = function($client) {

};

$ws->start(function ($client) {
    
});

\Swoole\Process::daemon();

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Document</title>
</head>
<body>
    <button class="btn btn-primary" onclick="update();">更新</button>

    <script type="text/javascript">
        function update()
        {
            var ws = new WebSocket("ws://192.168.1.142:8015?role=commander");
                
           ws.onopen = function()
           {
              // Web Socket 已连接上，使用 send() 方法发送数据
              ws.send(JSON.stringify({"command": "update", "params": {}}));
           };
            
           ws.onmessage = function (evt) 
           { 
              var received_msg = evt.data;
              alert(received_msg);
           };
            
           ws.onclose = function()
           { 
              // 关闭 websocket
              alert("连接已关闭..."); 
           };


        }
    </script>
</body>
</html>

完全なコード:

https://gitee.com/shuizhuyu/P...

以上がこの記事の全内容です。皆様の学習に少しでもお役に立てれば幸いです。関連コンテンツをさらにご覧になりたい場合は、お支払いください。 PHP 中国語 Web サイトに注意してください。

関連する推奨事項:

PHP の shmop 拡張機能を有効にして共有メモリを実装する

RoadRunner を使用して Laravel アプリケーションを高速化する

#mixphp を使用してマルチプロセスの非同期メール送信を作成する##

以上がSwooleを使用して複数のサーバーのコードを同時に更新するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。