diff --git a/RpcJsonp.php b/RpcJsonp.php
index 4991192..b4c7c8c 100644
--- a/RpcJsonp.php
+++ b/RpcJsonp.php
@@ -5,7 +5,6 @@ namespace Kiri\Rpc;
 use Exception;
 use JetBrains\PhpStorm\ArrayShape;
 use Kiri;
-use Kiri\Di\LocalService;
 use Kiri\Abstracts\Component;
 use Kiri\Core\Json;
 use Kiri\Events\EventProvider;
@@ -31,23 +30,23 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
 {
 
 
-	public RouterCollector $collector;
+    public RouterCollector $collector;
 
 
-	/**
-	 * @param ContainerInterface $container
-	 * @param DataGrip $dataGrip
-	 * @param RpcManager $manager
-	 * @param EventProvider $eventProvider
-	 * @throws Exception
-	 */
-	public function __construct(public ContainerInterface $container,
-	                            public DataGrip           $dataGrip,
-	                            public RpcManager         $manager,
-	                            public EventProvider      $eventProvider)
-	{
-		parent::__construct();
-	}
+    /**
+     * @param ContainerInterface $container
+     * @param DataGrip $dataGrip
+     * @param RpcManager $manager
+     * @param EventProvider $eventProvider
+     * @throws Exception
+     */
+    public function __construct(public ContainerInterface $container,
+                                public DataGrip           $dataGrip,
+                                public RpcManager         $manager,
+                                public EventProvider      $eventProvider)
+    {
+        parent::__construct();
+    }
 
 
     /**
@@ -57,206 +56,186 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
      * @throws ReflectionException
      * @throws Exception
      */
-	public function init(): void
-	{
-		$this->eventProvider->on(OnBeforeShutdown::class, [$this, 'onBeforeShutdown']);
+    public function init(): void
+    {
+        $this->eventProvider->on(OnBeforeShutdown::class, [$this, 'onBeforeShutdown']);
 
-		$this->collector = $this->dataGrip->get('rpc');
-		$this->registerConsumers();
-	}
-
-
-	/**
-	 * @return void
-     * @throws ContainerExceptionInterface
-	 * @throws NotFoundExceptionInterface
-	 */
-	public function registerConsumers(): void
-	{
-		$consumers = \config('rpc.consumers', []);
-		if (!is_array($consumers)) {
-			return;
-		}
-
-		$local = $this->container->get(LocalService::class);
-		foreach ($consumers as $consumer) {
-			$local->set($consumer['id'], $consumer);
-		}
-	}
+        $this->collector = $this->dataGrip->get('rpc');
+    }
 
 
     /**
      * @param OnBeforeShutdown $beforeShutdown
      * @return void
      */
-	public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown): void
-	{
-		if (env('environmental') != Kiri::WORKER && env('environmental_workerId') != 0) {
-			return;
-		}
+    public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown): void
+    {
+        if (env('environmental') != Kiri::WORKER && env('environmental_workerId') != 0) {
+            return;
+        }
 
-	}
+    }
 
 
-	/**
-	 * @param OnServerBeforeStart $server
-	 */
-	public function register(OnServerBeforeStart $server)
-	{
-	}
+    /**
+     * @param OnServerBeforeStart $server
+     */
+    public function register(OnServerBeforeStart $server)
+    {
+    }
 
 
-	/**
-	 * @param Server $server
-	 * @param int $fd
-	 */
-	public function onConnect(Server $server, int $fd): void
-	{
-		// TODO: Implement onConnect() method.
-	}
+    /**
+     * @param Server $server
+     * @param int $fd
+     */
+    public function onConnect(Server $server, int $fd): void
+    {
+        // TODO: Implement onConnect() method.
+    }
 
 
-	/**
-	 * @param Server $server
-	 * @param int $fd
-	 * @param int $reactor_id
-	 * @param string $data
-	 * @return bool
-	 */
-	public function onReceive(Server $server, int $fd, int $reactor_id, string $data): bool
-	{
-		try {
-			$data = json_decode($data, true);
-			if (is_null($data)) return $server->send($fd, 'success', $reactor_id);
-			$data = json_decode($data, true);
-			if (!is_array($data)) {
-				throw new Exception('Parse error语法解析错误', -32700);
-			}
-			if (!isset($data['jsonrpc']) || !isset($data['method']) || $data['jsonrpc'] != '2.0') {
-				throw new Exception('Invalid Request无效请求', -32600);
-			}
-			return $server->send($fd, $this->batchDispatch($data), $reactor_id);
-		} catch (\Throwable $throwable) {
-			$response = Json::encode($this->failure(-32700, $throwable->getMessage()));
-			return $server->send($fd, $response, $reactor_id);
-		}
-	}
+    /**
+     * @param Server $server
+     * @param int $fd
+     * @param int $reactor_id
+     * @param string $data
+     * @return bool
+     */
+    public function onReceive(Server $server, int $fd, int $reactor_id, string $data): bool
+    {
+        try {
+            $data = json_decode($data, true);
+            if (is_null($data)) return $server->send($fd, 'success', $reactor_id);
+            $data = json_decode($data, true);
+            if (!is_array($data)) {
+                throw new Exception('Parse error语法解析错误', -32700);
+            }
+            if (!isset($data['jsonrpc']) || !isset($data['method']) || $data['jsonrpc'] != '2.0') {
+                throw new Exception('Invalid Request无效请求', -32600);
+            }
+            return $server->send($fd, $this->batchDispatch($data), $reactor_id);
+        } catch (\Throwable $throwable) {
+            $response = Json::encode($this->failure(-32700, $throwable->getMessage()));
+            return $server->send($fd, $response, $reactor_id);
+        }
+    }
 
 
-	/**
-	 * @param array $data
-	 * @return string|bool
-	 */
-	private function batchDispatch(array $data): string|bool
-	{
-		if (isset($data['jsonrpc'])) {
-			$result = $this->dispatch($data);
-			if (!isset($data['id'])) {
-				$result = [1];
-			}
-		} else {
-			$channel = new Channel($total = count($data));
-			foreach ($data as $datum) {
-				$this->_execute($channel, $datum);
-			}
-			$result = [];
-			for ($i = 0; $i < $total; $i++) {
-				$result[] = $channel->pop();
-			}
-		}
-		return json_encode($result, JSON_UNESCAPED_UNICODE);
-	}
+    /**
+     * @param array $data
+     * @return string|bool
+     */
+    private function batchDispatch(array $data): string|bool
+    {
+        if (isset($data['jsonrpc'])) {
+            $result = $this->dispatch($data);
+            if (!isset($data['id'])) {
+                $result = [1];
+            }
+        } else {
+            $channel = new Channel($total = count($data));
+            foreach ($data as $datum) {
+                $this->_execute($channel, $datum);
+            }
+            $result = [];
+            for ($i = 0; $i < $total; $i++) {
+                $result[] = $channel->pop();
+            }
+        }
+        return json_encode($result, JSON_UNESCAPED_UNICODE);
+    }
 
 
-	/**
-	 * @param $channel
-	 * @param $datum
-	 */
-	private function _execute($channel, $datum)
-	{
-		Coroutine::create(function () use ($channel, $datum) {
-			if (empty($datum) || !isset($datum['jsonrpc'])) {
-				$channel->push($this->failure(-32700, 'Parse error语法解析错误'));
-			} else if (!isset($datum['method'])) {
-				$channel->push($this->failure(-32700, 'Parse error语法解析错误'));
-			} else {
-				$dispatch = $this->dispatch($datum);
-				if (!isset($dispatch['id'])) {
-					$dispatch = [1];
-				}
-				$channel->push($dispatch);
-			}
-		});
-	}
+    /**
+     * @param $channel
+     * @param $datum
+     */
+    private function _execute($channel, $datum)
+    {
+        Coroutine::create(function () use ($channel, $datum) {
+            if (empty($datum) || !isset($datum['jsonrpc'])) {
+                $channel->push($this->failure(-32700, 'Parse error语法解析错误'));
+            } else if (!isset($datum['method'])) {
+                $channel->push($this->failure(-32700, 'Parse error语法解析错误'));
+            } else {
+                $dispatch = $this->dispatch($datum);
+                if (!isset($dispatch['id'])) {
+                    $dispatch = [1];
+                }
+                $channel->push($dispatch);
+            }
+        });
+    }
 
 
-	/**
-	 * @param $data
-	 * @return array
-	 */
-	private function dispatch($data): array
-	{
-		try {
-			$class = $this->container->get(LocalService::class)->get($data['service']);
-			if (!$this->container->has($class)) {
-				throw new Exception('Handler not found', -32601);
-			}
-			$controller = $this->container->get($class);
-			if (!method_exists($controller, $data['method'])) {
-				throw new Exception('Method not found', -32601);
-			}
-			if (!isset($data['params']) || !is_array($data['params'])) {
-				$data['params'] = [];
-			}
-			return $this->handler($controller, $data['method'], $data['params']);
-		} catch (\Throwable $throwable) {
-			$code = $throwable->getCode() == 0 ? -32603 : $throwable->getCode();
-			return $this->failure($code, jTraceEx($throwable), [], $data['id'] ?? null);
-		}
-	}
+    /**
+     * @param $data
+     * @return array
+     */
+    private function dispatch($data): array
+    {
+//        try {
+//            $class = $this->collector->query($data['service'], 'tcp');
+//            if (!$this->container->has($class)) {
+//                throw new Exception('Handler not found', -32601);
+//            }
+//            $controller = $this->container->get($class);
+//            if (!method_exists($controller, $data['method'])) {
+//                throw new Exception('Method not found', -32601);
+//            }
+//            if (!isset($data['params']) || !is_array($data['params'])) {
+//                $data['params'] = [];
+//            }
+//            return $this->handler($controller, $data['method'], $data['params']);
+//        } catch (\Throwable $throwable) {
+//            $code = $throwable->getCode() == 0 ? -32603 : $throwable->getCode();
+//            return $this->failure($code, jTraceEx($throwable), [], $data['id'] ?? null);
+//        }
+    }
 
 
-	/**
-	 * @param $controller
-	 * @param string $method
-	 * @param $params
-	 * @return array
-	 */
-	#[ArrayShape([])]
-	private function handler($controller, string $method, $params): array
-	{
-		$result = call_user_func([$controller, $method], ...$params);
-		return [
-			'jsonrpc' => '2.0',
-			'result'  => $result,
-			'id'      => $data['id'] ?? null
-		];
-	}
+    /**
+     * @param $controller
+     * @param string $method
+     * @param $params
+     * @return array
+     */
+    #[ArrayShape([])]
+    private function handler($controller, string $method, $params): array
+    {
+        $result = call_user_func([$controller, $method], ...$params);
+        return [
+            'jsonrpc' => '2.0',
+            'result'  => $result,
+            'id'      => $data['id'] ?? null
+        ];
+    }
 
 
-	/**
-	 * @param $code
-	 * @param $message
-	 * @param array $data
-	 * @param null $id
-	 * @return array
-	 */
-	#[ArrayShape([])]
-	protected function failure($code, $message, array $data = [], $id = null): array
-	{
-		$error = [
-			'jsonrpc' => '2.0',
-			'error'   => [
-				'code'    => $code,
-				'message' => $message,
-				'data'    => $data
-			]
-		];
-		if (!is_null($id)) {
-			$error['id'] = $id;
-		}
-		return $error;
-	}
+    /**
+     * @param $code
+     * @param $message
+     * @param array $data
+     * @param null $id
+     * @return array
+     */
+    #[ArrayShape([])]
+    protected function failure($code, $message, array $data = [], $id = null): array
+    {
+        $error = [
+            'jsonrpc' => '2.0',
+            'error'   => [
+                'code'    => $code,
+                'message' => $message,
+                'data'    => $data
+            ]
+        ];
+        if (!is_null($id)) {
+            $error['id'] = $id;
+        }
+        return $error;
+    }
 
 
     /**
@@ -264,8 +243,8 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
      * @param int $fd
      * @return void
      */
-	public function OnClose(Server $server, int $fd): void
-	{
-		// TODO: Implement onClose() method.
-	}
+    public function OnClose(Server $server, int $fd): void
+    {
+        // TODO: Implement onClose() method.
+    }
 }