이 글에서는 Swoole을 사용하여 동시에 여러 서버를 업데이트하는 방법에 대한 코드를 소개합니다. 이는 특정 참고 가치가 있습니다. 이제 도움이 필요한 친구들이 참고할 수 있습니다.
앞으로 몇 개의 웹 서버에서 코드를 업데이트하는 것이 문제가 되었고 FTP를 하나씩 전송하는 것은 비현실적이며 전송을 놓치기 쉽고 두 웹 서버의 코드가 일치하지 않습니다.
간단한 아이디어:
Websocket 서버를 사용하여 업데이트 지침을 보냅니다. Websocket 클라이언트는 업데이트 명령을 받고 git pull
부분 코드 구현:
<?php //Server.php require_once './Table.php'; 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['host'], $config['port']); $this->server->set($config['configuration']); $this->addEventListener(); } public function addEventListener() { $this->server->on('open', Closure::fromCallable([$this, 'onOpen'])); $this->server->on('message', Closure::fromCallable([$this, 'onMessage'])); $this->server->on('close', Closure::fromCallable([$this, 'onClose'])); } private function onOpen($server, $request) { if ($request->get['role'] == 'commander') { $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([ 'host' => '0.0.0.0', 'port' => 8015, 'configuration' => [ 'daemonize' => 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 = ['onOpen', 'onMessage', 'onClose']; public function __construct($url) { list('scheme' => $this->protocol, 'host' => $this->host, 'port' => $this->port, 'query' => $this->query) = parse_url($url); if ($this->protocol == 'wss') { echo 'unsupport protocol'; } $this->client = new WebSocketClient($this->host, $this->port); } public function start(Callable $callback) { $this->client->upgrade('/?' . $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 'Unsupport Event'; } } }
<?php //Solider.php require_once './Client.php'; function parseCommand($data) { return json_decode($data, true); } function updateCommand() { //you can do something here exec('git pull'); // exec('composer update'); // exec('npm install'); } $ws = new Client('ws://192.168.1.142:8015?role=solider'); $ws->onMessage = function($client, $frame) { list('command' => $command, 'params' => $params) = parseCommand($frame->data); echo $command; switch ($command) { case 'update': 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...
The 위는 이 글의 전체 내용이 모든 분들의 학습에 도움이 되기를 바랍니다. 관련 내용은 PHP 중국어 홈페이지를 참고해주세요!
관련 권장 사항:
PHP용 shmop 확장을 활성화하여 공유 메모리 구현RoadRunner를 사용하여 Laravel 애플리케이션 가속화mixphp를 사용하여 다중 프로세스 비동기 이메일 전송 만들기위 내용은 Swoole을 사용하여 동시에 여러 서버의 코드 업데이트의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!