diff --git a/app/Console/Commands/Check.php b/app/Console/Commands/Cluster/Init.php similarity index 90% rename from app/Console/Commands/Check.php rename to app/Console/Commands/Cluster/Init.php index 442ab4a..e5e6473 100644 --- a/app/Console/Commands/Check.php +++ b/app/Console/Commands/Cluster/Init.php @@ -1,28 +1,26 @@ $type, ]); - $this->info('节点注册成功'); + $this->warn('节点注册成功'); } else { - $this->info('节点已注册'); + $this->warn('节点已注册'); // 如果 IP 不同,则更新 IP if ($node['ip'] != $addr) { diff --git a/app/Console/Commands/Cluster/Sync.php b/app/Console/Commands/Cluster/Sync.php new file mode 100644 index 0000000..7252cb4 --- /dev/null +++ b/app/Console/Commands/Cluster/Sync.php @@ -0,0 +1,42 @@ +getCpuUsage(), 2); + + $redis->publish('cluster_ready', json_encode([ + 'instance_id' => $instance_id, + 'cpu' => $cpu, + ])); + + sleep(1); + } + } + + public function getCpuUsage() + { + $load = sys_getloadavg(); + return $load[0]; + } +} diff --git a/app/Console/Kernel.php b/app/Console/Kernel.php index 0d7452c..9dcbbc7 100644 --- a/app/Console/Kernel.php +++ b/app/Console/Kernel.php @@ -4,7 +4,7 @@ use App\Console\Commands\BanUser; use App\Console\Commands\CalcModule; -use App\Console\Commands\Check; +use App\Console\Commands\Cluster; use App\Console\Commands\Count; use App\Console\Commands\GetUser; use App\Console\Commands\ReduceBalance; @@ -40,7 +40,9 @@ class Kernel extends ConsoleKernel ReduceBalance::class, Count::class, Status::class, - Check::class, + Cluster\Init::class, + Cluster\Worker::class, + Cluster\Sync::class, Commands\System\Down::class, Commands\System\Up::class, ];