as2252258/kiri-rpc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

变更

Browse Source
This commit is contained in:
向林
2022-05-31 20:41:31 +08:00
parent 6715743843
commit 188742360e
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
RpcJsonp.php
+7 -3
View File
@@ -28,7 +28,6 @@ use Kiri\Server\Events\OnWorkerStart;
use Psr\Container\ContainerExceptionInterface; use Psr\Container\ContainerExceptionInterface;
use Psr\Container\ContainerInterface; use Psr\Container\ContainerInterface;
use Psr\Container\NotFoundExceptionInterface; use Psr\Container\NotFoundExceptionInterface;
use Kiri\Consul\Catalog\Catalog;
use Psr\Http\Message\ServerRequestInterface; use Psr\Http\Message\ServerRequestInterface;
use ReflectionException; use ReflectionException;
use Swoole\Coroutine; use Swoole\Coroutine;
@@ -96,14 +95,19 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
*/ */
public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown): void public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown): void
{ {
$agent = $this->container->get(Catalog::class); if ($beforeShutdown->server->worker_id != 0) {
return;
}
$agent = $this->container->get(Agent::class);
$value = Config::get("rpc.consul", []); $value = Config::get("rpc.consul", []);
if (empty($value)) { if (empty($value)) {
return; return;
} }
$this->logger->debug("disconnect consul."); $this->logger->debug("disconnect consul.");
$agent->deregister(["node" => $value['ID']]);
$agent->service->deregister($value['ID']);
$agent->checks->deregister($value['Check']['CheckId']);
} }