diff --git a/app/Console/Commands/Cluster/CleanOffline.php b/app/Console/Commands/Cluster/CleanOffline.php index 54d46c2..4b3e2a4 100644 --- a/app/Console/Commands/Cluster/CleanOffline.php +++ b/app/Console/Commands/Cluster/CleanOffline.php @@ -36,6 +36,12 @@ public function handle(): int if ($now - $node['last_heartbeat'] > 30) { $this->info("节点 {$node['id']} 已离线,将被清理。"); ClusterSupport::removeNode($node['id']); + + if ($node['type'] == 'edge') { + // 移除前 5 个字符,即 "edge-"。 + $id = substr($node['id'], 5); + ClusterSupport::removeNode($id); + } } }