Verwenden Sie Swoole, um den Code mehrerer Server gleichzeitig zu aktualisieren

Dieser Artikel stellt hauptsächlich den Code zur gleichzeitigen Verwendung von Swoole vor. Er hat einen gewissen Referenzwert. Jetzt können Freunde in Not darauf verweisen.

Die Architektur von Es gibt eine kleine Website im Vordergrund und mehrere Webserver im Hintergrund. Es ist unrealistisch, jeden FTP einzeln zu übertragen, was dazu führt, dass Der Code der beiden WEB-Server ist inkonsistent.

Eine einfache Idee:

Verwenden Sie den Websocket-Server, um Aktualisierungsanweisungen zu senden, und führen Sie den git pullAktualisierungscode aus.

WebSocket Client hat mehrere Rollen:

• Solider: Befehl empfangen, Befehl kann nicht gesendet werden

• Commander: Befehl senden

Flussdiagramm:

Teilweise Code-Implementierung:

<?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>

Vollständiger Code:

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

Das Obige ist dieser Artikel Der gesamte Inhalt, ich hoffe, er wird für das Studium aller hilfreich sein. Weitere verwandte Inhalte finden Sie auf der chinesischen PHP-Website!

Verwandte Empfehlungen:

Shmop-Erweiterung für PHP aktivieren, um Shared Memory zu implementieren

Verwenden Sie RoadRunner, um Laravel-Anwendungen zu beschleunigen

Verwenden Sie mixphp, um asynchronen E-Mail-Versand mit mehreren Prozessen zu erstellen

Das obige ist der detaillierte Inhalt vonVerwenden Sie Swoole, um den Code mehrerer Server gleichzeitig zu aktualisieren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!