Revert "改名"

This reverts commit fdf58326

Annotation/JsonRpc.php

@@ -0,0 +1,91 @@
+<?php
+
+namespace Kiri\Rpc\Annotation;
+
+use Kiri\Abstracts\Config;
+use Kiri\Core\Network;
+use Kiri\Exception\ConfigException;
+use Kiri;
+use Kiri\Rpc\RpcManager;
+use Kiri\Annotation\Attribute;
+use ReflectionException;
+
+#[\Attribute(\Attribute::TARGET_CLASS)] class JsonRpc extends Attribute
+{
+
+
+	private string $uniqueId = '';
+
+
+	/**
+	 * @param string $service
+	 * @param string $driver
+	 * @param array $tags
+	 * @param array $meta
+	 * @param array $checkOptions
+	 * @param string $checkUrl
+	 */
+	public function __construct(public string $service, public string $driver, public array $tags = [], public array $meta = [], public array $checkOptions = [], public string $checkUrl = '')
+	{
+		$this->uniqueId = preg_replace('/(\w{11})(\w{4})(\w{3})(\w{8})(\w{6})/', '$1-$2-$3-$4-$5', md5(__DIR__ . 'Annotation' . md5(Network::local())));
+	}
+
+
+	/**
+	 * @param mixed $class
+	 * @param mixed|string $method
+	 * @return mixed
+	 * @throws ReflectionException
+	 * @throws ConfigException
+	 */
+	public function execute(mixed $class, mixed $method = ''): bool
+	{
+		return Kiri::getDi()->get(RpcManager::class)->add($this->service, $class, $this->create());
+	}
+
+
+	/**
+	 * @throws ConfigException
+	 */
+	protected function create(): array
+	{
+		$rpcPort = Config::get('rpc.port');
+		if (empty($this->checkUrl)) {
+			$this->checkUrl = Network::local() . ":" . Config::get('rpc.port');
+		}
+		$defaultConfig = [
+			"ID"                => "rpc.json.{$this->service}." . $this->uniqueId,
+			"Name"              => $this->service,
+			"EnableTagOverride" => false,
+			"TaggedAddresses"   => [
+				"lan_ipv4" => [
+					"address" => "127.0.0.1",
+					"port"    => $rpcPort
+				],
+				"wan_ipv4" => [
+					"address" => Network::local(),
+					"port"    => $rpcPort
+				]
+			],
+			"Check"             => [
+				"CheckId"                        => "service:rpc.json.{$this->service}." . $this->uniqueId,
+				"Name"                           => "service " . $this->service . ' health check',
+				"Notes"                          => "Script based health check",
+				"ServiceID"                      => $this->service,
+				"TCP"                            => $this->checkUrl,
+				"Interval"                       => "5s",
+				"Timeout"                        => "1s",
+				"DeregisterCriticalServiceAfter" => "30s"
+			],
+		];
+		if (!empty($this->meta)) {
+			$defaultConfig["Meta"] = $this->meta;
+		}
+		if (!empty($this->tags)) {
+			$defaultConfig["tags"] = $this->tags;
+		}
+		return $defaultConfig;
+	}
+
+
+}

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;
@@ -41,7 +41,7 @@ class ClientPool extends Component
 	 */
 	public function get($config, callable $callback): mixed
 	{
-		$coroutineName = $this->name(self::POOL_NAME . '::' . $config['ServiceAddress'] . '::' . $config['ServicePort'], true);
+		$coroutineName = $this->name(self::POOL_NAME . '::' . $config['Address'] . '::' . $config['Port'], true);
 
 		$pool = $config['pool'] ?? ['min' => 1, 'max' => 100];
 

JsonRpcConsumers.php

@@ -4,11 +4,10 @@ namespace Kiri\Rpc;
 
 
 use Exception;
-use Http\Message\ServerRequest;
+use Kiri\Message\ServerRequest;
-use Http\Message\Stream;
+use Kiri\Message\Stream;
-use Kiri\Consul\Agent;
 use Kiri\Core\Number;
-use Kiri\Kiri;
+use Kiri;
 use Kiri\Pool\Pool;
 use Psr\Http\Client\ClientExceptionInterface;
 use Psr\Http\Message\ResponseInterface;
@@ -55,6 +54,7 @@ abstract class JsonRpcConsumers implements OnRpcConsumerInterface
 	/**
 	 * @param array $data
 	 * @return ServerRequestInterface
+	 * @throws \ReflectionException
 	 */
 	private function requestBody(array $data): ServerRequestInterface
 	{
@@ -109,32 +109,42 @@ abstract class JsonRpcConsumers implements OnRpcConsumerInterface
 	/**
 	 * @param $service
 	 * @return array
+	 * @throws RpcServiceException|\ReflectionException
 	 * @throws Exception
 	 */
 	private function get_consul($service): array
 	{
 		if (empty($service)) {
-			throw new Exception('You need set rpc service name if used.');
+			throw new RpcServiceException('You need set rpc service name if used.');
 		}
-		$sf = Kiri::getDi()->get(Agent::class);
+		$sf = Kiri::getDi()->get(RpcManager::class)->getServices($service);
+		if (empty($sf) || !is_array($sf)) {
+			throw new RpcServiceException('You need set rpc service name if used.');
+		}
+		return $this->_loadRand($sf);
+	}
 
-		$response = $sf->service->setQuery('filter=Service == ' . $service)->list();
+
-		if ($response->getStatusCode() != 200 || $response->getBody()->getSize() <= 2) {
+	/**
-			throw new Exception('No microservices found [' . $service . '].');
+	 * @param $services
-		}
+	 * @return array
+	 */
+	private function _loadRand($services): array
+	{
 		$array = [];
-
+		foreach ($services as $value) {
-		$content = json_decode($response->getBody()->getContents(), true);
+			$value['Weight'] = $value['Weights']['Passing'];
-		foreach ($content as $value) {
+			$array[] = $value;
-			$array[] = ['id' => $value['ID'], 'Weights' => $value['Weights']['Passing']];
 		}
-
 		if (count($array) < 2) {
 			$luck = $array[0];
 		} else {
-			$luck = Luckdraw::luck($array, 'Weights');
+			$luck = Luckdraw::luck($array, 'Weight');
 		}
-		return ['Address' => $luck['Address'], 'Port' => $luck['Port']];
+		return [
+			'Address' => $luck['TaggedAddresses']['wan_ipv4']['Address'],
+			'Port'    => $luck['TaggedAddresses']['wan_ipv4']['Port']
+		];
 	}
 
 }

JsonRpcPoolTransporter.php

@@ -2,10 +2,10 @@
 
 namespace Kiri\Rpc;
 
-use Annotation\Inject;
+use Kiri\Annotation\Inject;
 use Exception;
-use Http\Message\Response;
+use Kiri\Message\Response;
-use Http\Message\Stream;
+use Kiri\Message\Stream;
 use Kiri\Abstracts\Config;
 use Kiri\Exception\ConfigException;
 use Psr\Http\Client\ClientInterface;
@@ -45,7 +45,7 @@ class JsonRpcPoolTransporter implements ClientInterface
 
 		$response = $this->request($client = $this->getClient(), $content, false);
 
-		$this->pool->push($client, $this->config['ServiceAddress'], $this->config['ServicePort']);
+		$this->pool->push($client, $this->config['Address'], $this->config['Port']);
 
 		return (new Response())->withBody(new Stream($response));
 	}

JsonRpcTransporter.php

@@ -2,8 +2,8 @@
 
 namespace Kiri\Rpc;
 
-use Http\Message\Response;
+use Kiri\Message\Response;
-use Http\Message\Stream;
+use Kiri\Message\Stream;
 use Psr\Http\Client\ClientInterface;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\ResponseInterface;

RpcJsonp.php

@@ -2,26 +2,33 @@
 
 namespace Kiri\Rpc;
 
-use Annotation\Annotation;
+use Kiri;
-use Annotation\Inject;
-use Http\Handler\Router;
 use Kiri\Abstracts\Component;
 use Kiri\Abstracts\Config;
+use Kiri\Annotation\Annotation;
+use Kiri\Annotation\Inject;
 use Kiri\Consul\Agent;
-use Psr\Container\ContainerExceptionInterface;
+use Kiri\Context;
-use Psr\Container\ContainerInterface;
-use Kiri\Events\EventProvider;
 use Kiri\Exception\ConfigException;
-use Kiri\Kiri;
+use Kiri\Message\Constrict\RequestInterface;
+use Kiri\Message\Handler\Handler;
+use Kiri\Message\Handler\Router;
+use Kiri\Message\ServerRequest;
+use Kiri\Server\Contract\OnCloseInterface;
+use Kiri\Server\Contract\OnConnectInterface;
+use Kiri\Server\Contract\OnReceiveInterface;
+use Kiri\Server\Events\OnBeforeShutdown;
+use Kiri\Server\Events\OnServerBeforeStart;
+use Kiri\Server\Events\OnTaskerStart;
+use Kiri\Server\Events\OnWorkerExit;
+use Kiri\Server\Events\OnWorkerStart;
+use Psr\Container\ContainerExceptionInterface;
 use Psr\Container\NotFoundExceptionInterface;
-use Server\Events\OnBeforeShutdown;
+use Psr\Http\Message\ServerRequestInterface;
-use Server\Events\OnStart;
-use Server\Contract\OnCloseInterface;
-use Server\Contract\OnConnectInterface;
-use Server\Contract\OnReceiveInterface;
 use Swoole\Coroutine;
 use Swoole\Coroutine\Channel;
 use Swoole\Server;
+use Swoole\Timer;
 
 
 /**
@@ -39,12 +46,10 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
 	public Annotation $annotation;
 
 
-	#[Inject(EventProvider::class)]
+	private RpcManager $manager;
-	public EventProvider $eventProvider;
 
 
-	#[Inject(ContainerInterface::class)]
+	private int $timerId;
-	public ContainerInterface $container;
 
 	/**
 	 *
@@ -54,40 +59,65 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
 	{
 		$this->eventProvider->on(OnBeforeShutdown::class, [$this, 'onBeforeShutdown']);
 
-		scan_directory(APP_PATH . 'rpc', 'Rpc');
+		scan_directory(APP_PATH . 'rpc', 'app\Rpc');
+
+		$this->eventProvider->on(OnWorkerStart::class, [$this, 'consulWatches']);
+		$this->eventProvider->on(OnWorkerExit::class, [$this, 'onWorkerExit']);
+		$this->eventProvider->on(OnServerBeforeStart::class, [$this, 'register']);
+
+		$this->manager = Kiri::getDi()->get(RpcManager::class);
 	}
 
 
 	/**
 	 * @param OnBeforeShutdown $beforeShutdown
+	 * @return void
 	 * @throws ContainerExceptionInterface
 	 * @throws NotFoundExceptionInterface
 	 */
 	public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown)
 	{
-		$doneList = RpcManager::doneList();
+		$doneList = $this->manager->doneList();
 		$agent = $this->container->get(Agent::class);
 		foreach ($doneList as $value) {
-			$agent->service->deregister($value);
+			$agent->service->deregister($value['config']['ID']);
+			$agent->checks->deregister($value['config']['Check']['CheckId']);
 		}
 	}
 
 
 	/**
-	 * @param OnStart $server
+	 * @param OnWorkerStart|OnTaskerStart $server
 	 * @throws ConfigException
-	 * @throws ContainerExceptionInterface
-	 * @throws NotFoundExceptionInterface
 	 */
-	public function register(OnStart $server)
+	public function consulWatches(OnWorkerStart|OnTaskerStart $server)
 	{
-		$config = Config::get('rpc');
+		if ($server->workerId != 0) {
-
+			return;
-		$agent = $this->container->get(Agent::class);
-		$data = $agent->service->register($config['registry']['config']);
-		if ($data->getStatusCode() != 200) {
-			$server->server->shutdown();
 		}
+		$async_time = (int)Config::get('consul.async_time', 1000);
+		$this->timerId = Timer::tick($async_time, static function () {
+			Kiri::getDi()->get(RpcManager::class)->tick();
+		});
+	}
+
+
+	/**
+	 * @param OnWorkerExit $exit
+	 * @return void
+	 */
+	public function onWorkerExit(OnWorkerExit $exit)
+	{
+		Timer::clear($this->timerId);
+	}
+
+
+	/**
+	 * @param OnServerBeforeStart $server
+	 */
+	public function register(OnServerBeforeStart $server)
+	{
+		$this->manager->register();
 	}
 
 
@@ -177,11 +207,13 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
 	private function dispatch($data): array
 	{
 		try {
-			[$handler, $params, $_] = RpcManager::get($data['service'], $data['method']);
+			[$handler, $params] = $this->container->get(RpcManager::class)->get($data['service'], $data['method']);
 			if (is_null($handler)) {
 				throw new \Exception('Method not found', -32601);
 			} else {
-				return $this->handler($handler, $data);
+				Context::setContext(RequestInterface::class, $this->createServerRequest($params));
+
+				return $this->handler($handler);
 			}
 		} catch (\Throwable $throwable) {
 			$code = $throwable->getCode() == 0 ? -32603 : $throwable->getCode();
@@ -191,18 +223,27 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
 
 
 	/**
-	 * @param array $handler
+	 * @param $params
-	 * @param $data
+	 * @return ServerRequestInterface
-	 * @return array
+	 * @throws \Exception
-	 * @throws \ReflectionException
 	 */
-	private function handler(array $handler, $data): array
+	private function createServerRequest($params): ServerRequestInterface
 	{
-		$controller = Kiri::getDi()->get($handler[0]);
+		return (new ServerRequest())->withParsedBody($params);
+	}
 
-		$dispatcher = $controller->{$handler[1]}(...$data['params']);
 
-		return ['jsonrpc' => '2.0', 'result' => $dispatcher, 'id' => $data['id'] ?? null];
+	/**
+	 * @param Handler $handler
+	 * @return array
+	 */
+	private function handler(Handler $handler): array
+	{
+		return [
+			'jsonrpc' => '2.0',
+			'result'  => call_user_func($handler->callback, ...$handler->params),
+			'id'      => $data['id'] ?? null
+		];
 	}
 
 
@@ -231,10 +272,9 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
 
 
 	/**
-	 * @param Server $server
 	 * @param int $fd
 	 */
-	public function onClose(Server $server, int $fd): void
+	public function onClose(int $fd): void
 	{
 		// TODO: Implement onClose() method.
 	}

RpcManager.php

@@ -0,0 +1,166 @@
+<?php
+
+namespace Kiri\Rpc;
+
+use Exception;
+use Kiri;
+use Kiri\Abstracts\Component;
+use Kiri\Consul\Agent;
+use Kiri\Consul\Health;
+use Kiri\Message\Handler\Handler;
+use ReflectionException;
+
+class RpcManager extends Component
+{
+
+
+	/**
+	 * @var array
+	 */
+	private array $_rpc = [];
+
+
+	/**
+	 * @param $serviceName
+	 * @return void
+	 * @throws Exception
+	 */
+	public function async($serviceName): void
+	{
+		$this->reRegister($serviceName);
+
+		$lists = Kiri::getDi()->get(Health::class)->setQuery('passing=true')->service($serviceName);
+		if ($lists->getStatusCode() != 200) {
+			return;
+		}
+		$body = json_decode($lists->getBody(), true);
+		$file = storage('.rpc.clients.' . md5($serviceName), 'rpc');
+		if (!empty($body) && is_array($body)) {
+			file_put_contents($file, json_encode(array_column($body, 'Service')), LOCK_EX);
+		} else {
+			file_put_contents($file, json_encode([]), LOCK_EX);
+		}
+	}
+
+
+	/**
+	 * @param string $serviceName
+	 * @return void
+	 * @throws Exception
+	 */
+	public function reRegister(string $serviceName)
+	{
+		$config = $this->_rpc[$serviceName] ?? [];
+		if (empty($config)) {
+			return;
+		}
+		$service = Kiri::getDi()->get(Agent::class);
+
+		$info = $service->service->service_health($config['config']['ID']);
+		if ($info->getStatusCode() == 200) {
+			return;
+		}
+		$service->service->register($config['config']);
+	}
+
+
+	/**
+	 * @throws Exception
+	 */
+	public function tick(): void
+	{
+		try {
+			foreach ($this->_rpc as $name => $list) {
+				$this->async($name);
+			}
+		} catch (\Throwable $throwable) {
+			$this->logger()->error(error_trigger_format($throwable));
+		}
+	}
+
+
+	/**
+	 * @param $serviceName
+	 * @return array
+	 * @throws Exception
+	 */
+	public function getServices($serviceName): array
+	{
+		$file = storage('.rpc.clients.' . md5($serviceName), 'rpc');
+		if (!file_exists($file) || filesize($file) < 10) {
+			$this->async($serviceName);
+		}
+		$content = json_decode(file_get_contents($file), true);
+		if (empty($content) || !is_array($content)) {
+			return [];
+		}
+		return $content;
+	}
+
+
+	/**
+	 * @param string $name
+	 * @param string $class
+	 * @param array $serviceConfig
+	 * @return bool
+	 * @throws ReflectionException
+	 */
+	public function add(string $name, string $class, array $serviceConfig): bool
+	{
+		$methods = Kiri::getDi()->getReflect($class);
+		$lists = $methods->getMethods(\ReflectionMethod::IS_PUBLIC);
+
+		if (!isset($this->_rpc[$name])) {
+			$this->_rpc[$name] = ['methods' => [], 'id' => $serviceConfig['ID'], 'config' => $serviceConfig];
+		}
+
+		foreach ($lists as $reflection) {
+			if ($reflection->getDeclaringClass() != $class) {
+				continue;
+			}
+			$methodName = $reflection->getName();
+			$this->_rpc[$name]['methods'][$methodName] = [new Handler('/', [$class, $methodName]), null];
+		}
+		return true;
+	}
+
+
+	/**
+	 * @return array
+	 */
+	public function doneList(): array
+	{
+		$array = [];
+		foreach ($this->_rpc as $list) {
+			$array[] = $list;
+		}
+		return $array;
+	}
+
+
+	/**
+	 */
+	public function register()
+	{
+		$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;
+			}
+		}
+	}
+
+
+	/**
+	 * @param string $name
+	 * @param string $method
+	 * @return mixed
+	 */
+	public function get(string $name, string $method): array
+	{
+		return $this->_rpc[$name]['methods'][$method] ?? [null, null];
+	}
+
+}

RpcServiceException.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace Kiri\Rpc;
+
+class RpcServiceException extends \Exception
+{
+
+}

TraitTransporter.php

@@ -14,6 +14,9 @@ trait TraitTransporter
 	protected array $config;
 
 
+	protected array $clients = [];
+
+
 	/**
 	 * @param $config
 	 * @return $this
@@ -48,24 +51,14 @@ trait TraitTransporter
 	 */
 	private function newClient(): Coroutine\Client|Client
 	{
-		if (Context::inCoroutine()) {
+		$alias = $this->alias($this->config);
-			$client = $this->clientOnCoroutine($this->config);
+		$client = $this->clients[$alias] ?? null;
-		} else {
+		if (is_null($client)) {
-			$client = $this->clientNotCoroutine($this->config);
+			$client = Context::inCoroutine() ? new Coroutine\Client(SWOOLE_SOCK_TCP) : new Client(SWOOLE_SOCK_TCP);
+			$this->clients[$alias] = $client;
 		}
-		return $client;
+		[$host, $port] = [$this->config['Address'], $this->config['Port']];
-	}
+		if (!$client->isConnected() && !$client->connect($host, $port, 60)) {
-
-
-	/**
-	 * @param $config
-	 * @return Coroutine\Client
-	 * @throws Exception
-	 */
-	private function clientOnCoroutine($config): Coroutine\Client
-	{
-		$client = new Coroutine\Client(SWOOLE_SOCK_TCP);
-		if (!$client->connect($config['ServiceAddress'], $config['ServicePort'], 60)) {
 			throw new Exception('connect fail.');
 		}
 		return $client;
@@ -73,17 +66,12 @@ trait TraitTransporter
 
 
 	/**
-	 * @param $config
+	 * @param array $config
-	 * @return Client
+	 * @return string
-	 * @throws Exception
 	 */
-	private function clientNotCoroutine($config): Client
+	private function alias(array $config): string
 	{
-		$client = new Client(SWOOLE_SOCK_TCP);
+		return $config['Address'] . '::' . $config['Port'];
-		if (!$client->connect($config['ServiceAddress'], $config['ServicePort'], 60)) {
-			throw new Exception('connect fail.');
-		}
-		return $client;
 	}
 
 

composer.json

@@ -11,13 +11,12 @@
   "require": {
     "php": ">=8.0",
     "ext-json": "*",
-    "game-worker/kiri-consul": "^v1.0",
     "psr/http-client": "^1.0",
     "psr/http-message": "^1.0"
   },
   "autoload": {
     "psr-4": {
-      "Kiri\\Rpc\\": "src/"
+      "Kiri\\Rpc\\": "./"
     }
   },
   "require-dev": {

config.php

@@ -0,0 +1,77 @@
+<?php
+
+
+use Kiri\Rpc\RpcJsonp;
+use Kiri\Rpc\TestRpcService;
+use Kiri\Server\Constant;
+
+return [
+	'rpc' => [
+		'name'     => 'json-rpc',
+		'type'     => Constant::SERVER_TYPE_BASE,
+		'mode'     => SWOOLE_SOCK_TCP,
+		'host'     => '0.0.0.0',
+		'port'     => 9526,
+		'settings' => [
+
+		],
+		'events'   => [
+			Constant::RECEIVE => [RpcJsonp::class, 'onReceive']
+		],
+
+
+		'consumers' => [
+			'class'    => TestRpcService::class,
+			'name'     => 'test-rpc',
+			'package'  => 'test',
+			'register' => [
+				'host' => '',
+				'port' => ''
+			]
+		]
+	],
+
+
+	'service' => [
+		[
+			"datacenter"     => "dc1",
+			"id"             => "40e4a748-2192-161a-0510-9bf59fe950b5",
+			"node"           => "FriendRpcService",
+			"skipNodeUpdate" => false,
+			"service"        => [
+				"id"              => "redis1",
+				"service"         => "FriendRpcService",
+				"address"         => "172.26.221.211",
+				"taggedAddresses" => [
+					"lan" => [
+						"address" => "127.0.0.1",
+						"port"    => 8000
+					],
+					"wan" => [
+						"address" => "172.26.221.211",
+						"port"    => 80
+					]
+				],
+				"meta"            => [
+					"redis_version" => "4.0"
+				],
+				"port"            => 8000
+			],
+			"check"          => [
+				"node"       => "t2.320",
+				"checkId"    => "service:redis1",
+				"name"       => "Redis health check",
+				"Annotations"      => "Script based health check",
+				"status"     => "passing",
+				"serviceID"  => "redis1",
+				"definition" => [
+					"http"                           => "172.26.221.211:9527",
+					"interval"                       => "5s",
+					"timeout"                        => "1s",
+					"deregisterCriticalServiceAfter" => "30s"
+				],
+			],
+		]
+
+	]
+];

src/Annotation/JsonRpc.php

@@ -1,74 +0,0 @@
-<?php
-
-namespace Kiri\Rpc\Annotation;
-
-use Annotation\Attribute;
-use Kiri\Abstracts\Config;
-use Kiri\Consul\Agent;
-use Kiri\Exception\ConfigException;
-use Kiri\Kiri;
-use Kiri\Rpc\RpcManager;
-use ReflectionException;
-
-#[\Attribute(\Attribute::TARGET_CLASS)] class JsonRpc extends Attribute
-{
-
-
-	/**
-	 * @param string $service
-	 * @param string $driver
-	 * @param array $checkOptions
-	 */
-	public function __construct(public string $service, public string $driver, public array $checkOptions = [
-		"DeregisterCriticalServiceAfter" => "1m",
-		"Http"                           => "http://127.0.0.1:9527",
-		"Interval"                       => "1s",
-		"Timeout"                        => "1s"
-	])
-	{
-
-	}
-
-
-	/**
-	 * @param mixed $class
-	 * @param mixed|string $method
-	 * @return mixed
-	 * @throws ReflectionException
-	 * @throws ConfigException
-	 */
-	public function execute(mixed $class, mixed $method = ''): bool
-	{
-		$default = $this->create();
-		$agent = Kiri::getDi()->get(Agent::class);
-		$data = $agent->service->register($default);
-		if ($data->getStatusCode() != 200) {
-			exit($data->getBody()->getContents());
-		}
-		return RpcManager::add($this->service, $class, $default['id']);
-	}
-
-
-	/**
-	 * @throws ConfigException
-	 */
-	protected function create(): array
-	{
-		$content = current(swoole_get_local_ip());
-		return [
-			"id"                => "rpc.json.{$this->service}." . md5(__DIR__ . '.' . md5($content)),
-			"name"              => $this->service,
-			"address"           => $content,
-			"port"              => 9526,
-			"enableTagOverride" => true,
-			"check"             => [
-				"DeregisterCriticalServiceAfter" => "1m",
-				"TCP"                            => $content . ":" . Config::get('rpc.port'),
-				"Interval"                       => "1s",
-				"Timeout"                        => "1s"
-			]
-		];
-	}
-
-
-}

src/RpcManager.php

@@ -1,57 +0,0 @@
-<?php
-
-namespace Kiri\Rpc;
-
-use Kiri\Kiri;
-use ReflectionException;
-
-class RpcManager
-{
-
-	private static array $_rpc = [];
-
-
-	/**
-	 * @param string $name
-	 * @param string $class
-	 * @param string $serviceId
-	 * @return bool
-	 * @throws ReflectionException
-	 */
-	public static function add(string $name, string $class, string $serviceId): bool
-	{
-		$methods = Kiri::getDi()->getReflect($class);
-		$lists = $methods->getMethods(\ReflectionMethod::IS_PUBLIC);
-
-		if (!isset(static::$_rpc[$name])) static::$_rpc[$name] = ['methods' => [], 'id' => $serviceId];
-
-		foreach ($lists as $reflection) {
-			$methodName = $reflection->getName();
-
-			static::$_rpc[$name]['methods'][$methodName] = [[$class, $methodName], null];
-		}
-		return true;
-	}
-
-
-	public static function doneList(): array
-	{
-		$array = [];
-		foreach (static::$_rpc as $list) {
-			$array[] = $list['id'];
-		}
-		return $array;
-	}
-
-
-	/**
-	 * @param string $name
-	 * @param string $method
-	 * @return mixed
-	 */
-	public static function get(string $name, string $method): array
-	{
-		return static::$_rpc[$name]['methods'][$method] ?? [null, null];
-	}
-
-}

src/config.php

@@ -1,33 +0,0 @@
-<?php
-
-
-use Kiri\Rpc\RpcJsonp;
-use Kiri\Rpc\TestRpcService;
-use Server\Constant;
-
-return [
-	'rpc' => [
-		'name'     => 'json-rpc',
-		'type'     => Constant::SERVER_TYPE_BASE,
-		'mode'     => SWOOLE_SOCK_TCP,
-		'host'     => '0.0.0.0',
-		'port'     => 9526,
-		'settings' => [
-
-		],
-		'events'   => [
-			Constant::RECEIVE => [RpcJsonp::class, 'onReceive']
-		],
-
-
-		'consumers' => [
-			'class'    => TestRpcService::class,
-			'name'     => 'test-rpc',
-			'package'  => 'test',
-			'register' => [
-				'host' => '',
-				'port' => ''
-			]
-		]
-	]
-];