ivampiresp/Lae
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

改进 IP 监听

Browse Source
This commit is contained in:
iVampireSP.com 2023-02-08 20:53:58 +08:00
parent 5762c8a3d6
commit 340b082ee8
No known key found for this signature in database
GPG Key ID: 2F7B001CA27A8132
1 changed files with 20 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
app/Console/Commands/Cluster/Work.php
View File

@ -32,7 +32,7 @@ class Work extends Command
public function handle(): int public function handle(): int
{ {
// 检测目录下是否有 rr // 检测目录下是否有 rr
if (! file_exists(base_path('rr'))) { if (!file_exists(base_path('rr'))) {
$this->warn('未找到 rr 文件，将自动下载。'); $this->warn('未找到 rr 文件，将自动下载。');
// 获取操作系统是 darwin 还是 linux // 获取操作系统是 darwin 还是 linux
@ -70,16 +70,27 @@ public function handle(): int
// 关闭 Octane // 关闭 Octane
Artisan::call('octane:stop'); Artisan::call('octane:stop');
if (! config('settings.node.ip')) { // 刷新配置缓存
$this->info('正在刷新配置缓存。');
Artisan::call('config:cache');
Artisan::call('route:cache');
$node_ip = config('settings.node.ip');
if (!$node_ip) {
$this->error('请先配置节点 IP。'); $this->error('请先配置节点 IP。');
return CommandAlias::FAILURE; return CommandAlias::FAILURE;
} }
// 刷新配置缓存 // 获取端口
$this->info('正在刷新配置缓存。'); $node_ips = explode(':', $node_ip);
Artisan::call('config:cache'); $node_host = $node_ips[0];
Artisan::call('route:cache'); if (count($node_ips) === 1) {
$node_port = 8000;
} else {
$node_port = $node_ips[1];
}
// redis 创建一个 hash // redis 创建一个 hash
$this->info('正在注册节点。'); $this->info('正在注册节点。');
@ -94,18 +105,18 @@ public function handle(): int
$this->error('无法创建子进程。'); $this->error('无法创建子进程。');
return CommandAlias::FAILURE; return CommandAlias::FAILURE;
} elseif ($pid === 0) { } else if ($pid === 0) {
// 再打开一个，负责 octane // 再打开一个，负责 octane
$pid = pcntl_fork(); $pid = pcntl_fork();
if ($pid === -1) { if ($pid === -1) {
$this->error('无法创建子进程。'); $this->error('无法创建子进程。');
return CommandAlias::FAILURE; return CommandAlias::FAILURE;
} elseif ($pid === 0) { } else if ($pid === 0) {
// 子进程 // 子进程
$this->info('正在启动 Web。'); $this->info('正在启动 Web。');
$command = 'php artisan octane:start --host=0.0.0.0 --rpc-port=6001 --port=8000'; $command = "php artisan octane:start --host=$node_host --port=$node_port";
$this->pipeCommand($command); $this->pipeCommand($command);
} else { } else {
$this->report(); $this->report();