Revert "改名"

This reverts commit fdf58326

Annotation/JsonRpc.php

@@ -5,7 +5,7 @@ namespace Kiri\Rpc\Annotation;
 use Kiri\Abstracts\Config;
 use Kiri\Core\Network;
 use Kiri\Exception\ConfigException;
-use Kiri\Kiri;
+use Kiri;
 use Kiri\Rpc\RpcManager;
 use Kiri\Annotation\Attribute;
 use ReflectionException;
@@ -70,7 +70,7 @@ use ReflectionException;
 			"Check"             => [
 				"CheckId"                        => "service:rpc.json.{$this->service}." . $this->uniqueId,
 				"Name"                           => "service " . $this->service . ' health check',
-				"Annotations"                          => "Script based health check",
+				"Notes"                          => "Script based health check",
 				"ServiceID"                      => $this->service,
 				"TCP"                            => $this->checkUrl,
 				"Interval"                       => "5s",

ClientPool.php

@@ -6,7 +6,7 @@ use Exception;
 use Kiri\Abstracts\Component;
 use Kiri\Context;
 use Kiri\Exception\ConfigException;
-use Kiri\Kiri;
+use Kiri;
 use Kiri\Pool\Alias;
 use Kiri\Pool\Pool;
 use Swoole\Client;

JsonRpcConsumers.php

@@ -7,7 +7,7 @@ use Exception;
 use Kiri\Message\ServerRequest;
 use Kiri\Message\Stream;
 use Kiri\Core\Number;
-use Kiri\Kiri;
+use Kiri;
 use Kiri\Pool\Pool;
 use Psr\Http\Client\ClientExceptionInterface;
 use Psr\Http\Message\ResponseInterface;

RpcJsonp.php

@@ -12,7 +12,7 @@ use Kiri\Consul\Agent;
 use Kiri\Context;
 use Kiri\Events\EventProvider;
 use Kiri\Exception\ConfigException;
-use Kiri\Kiri;
+use Kiri;
 use Kiri\Annotation\Inject;
 use Kiri\Annotation\Annotation;
 use Psr\Container\ContainerExceptionInterface;
@@ -94,7 +94,7 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
 			return;
 		}
 		$async_time = (int)Config::get('consul.async_time', 1000);
-		Timer::tick($async_time, static function ($timeId) {
+		Timer::tick(5000, static function ($timeId) {
 			if (env('state', 'start') == 'exit') {
 				Timer::clear($timeId);
 				return;

RpcManager.php

@@ -2,11 +2,11 @@
 
 namespace Kiri\Rpc;
 
-use Kiri\Message\Handler\Handler;
 use Kiri\Abstracts\Component;
 use Kiri\Consul\Agent;
 use Kiri\Consul\Health;
-use Kiri\Kiri;
+use Kiri;
+use Kiri\Message\Handler\Handler;
 use ReflectionException;
 
 class RpcManager extends Component
@@ -117,6 +117,7 @@ class RpcManager extends Component
 	{
 		$agent = Kiri::getDi()->get(Agent::class);
 		foreach ($this->_rpc as $list) {
+			$agent->service->deregister($list['config']['ID']);
 			$data = $agent->service->register($list['config']);
 			if ($data->getStatusCode() != 200) {
 				return;