jsonRpc is supported

src/BeforeServerListener.php

@@ -7,16 +7,19 @@
 use Closure;
 use Hyperf\Context\ApplicationContext;
 use Hyperf\Contract\ConfigInterface;
+use Hyperf\Contract\StdoutLoggerInterface;
 use Hyperf\DTO\Event\AfterDtoStart;
 use Hyperf\DTO\Event\BeforeDtoStart;
-use Hyperf\DTO\Router\TcpRouter;
+use Hyperf\DTO\Router\JsonRpcHttpRouter;
+use Hyperf\DTO\Router\JsonRpcTcpRouter;
 use Hyperf\DTO\Scan\Scan;
 use Hyperf\Event\Contract\ListenerInterface;
 use Hyperf\Framework\Event\BeforeServerStart;
 use Hyperf\HttpServer\Router\DispatcherFactory;
 use Hyperf\HttpServer\Router\Handler;
+use Hyperf\JsonRpc\HttpServer;
+use Hyperf\JsonRpc\TcpServer;
 use Hyperf\Server\Event\MainCoroutineServerStart;
-use Hyperf\Stringable\Str;
 use Psr\EventDispatcher\EventDispatcherInterface;
 use RuntimeException;
 use Throwable;
@@ -45,21 +48,33 @@ public function process(object $event): void
 
         $container = ApplicationContext::getContainer();
         $config = $container->get(ConfigInterface::class);
+        $logger = $container->get(StdoutLoggerInterface::class);
         $eventDispatcher = $container->get(EventDispatcherInterface::class);
         $scanAnnotation = $container->get(Scan::class);
         $serverConfig = collect($config->get('server.servers'))->where('name', $serverName)->first();
-        if (isset($serverConfig['callbacks']['receive'][0]) && Str::contains($serverConfig['callbacks']['receive'][0], 'TcpServer')) {
+
+        if (($serverConfig['callbacks']['receive'][0] ?? '') == TcpServer::class) {
+            try {
+                $tcpRouter = $container->get(JsonRpcTcpRouter::class);
+                $router = $tcpRouter->getRouter($serverName);
+            } catch (Throwable $throwable) {
+                $logger->warning($throwable);
+                return;
+            }
+        } elseif (($serverConfig['callbacks']['request'][0] ?? '') == HttpServer::class) {
             try {
-                $tcpRouter = $container->get(TcpRouter::class);
+                $tcpRouter = $container->get(JsonRpcHttpRouter::class);
                 $router = $tcpRouter->getRouter($serverName);
-            } catch (Throwable) {
+            } catch (Throwable $throwable) {
+                $logger->warning($throwable);
                 return;
             }
         } else {
             $router = $container->get(DispatcherFactory::class)->getRouter($serverName);
         }
-        $data = $router->getData();
-        array_walk_recursive($data, function ($item) use ($scanAnnotation) {
+
+        $routerData = $router->getData();
+        array_walk_recursive($routerData, function ($item) use ($scanAnnotation) {
             if ($item instanceof Handler && ! ($item->callback instanceof Closure)) {
                 $prepareHandler = $this->prepareHandler($item->callback);
                 if (count($prepareHandler) > 1) {

src/Router/JsonRpcHttpRouter.php

@@ -0,0 +1,40 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Hyperf\DTO\Router;
+
+use Hyperf\JsonRpc\HttpServer;
+use Hyperf\Rpc\Protocol;
+use Hyperf\RpcServer\Router\DispatcherFactory;
+use Psr\Container\ContainerInterface;
+
+use function Hyperf\Support\make;
+
+class JsonRpcHttpRouter
+{
+    private HttpServer $server;
+
+    private $protocol;
+
+    public function __construct(ContainerInterface $container)
+    {
+        $this->server = $container->get(HttpServer::class);
+    }
+
+    public function getRouter($serverName)
+    {
+        $data = make(DispatcherFactory::class, [
+            'pathGenerator' => $this->getProtocol()->getPathGenerator(),
+        ]);
+        return $data->getRouter($serverName);
+    }
+
+    protected function getProtocol(): Protocol
+    {
+        $getResponseBuilder = function () {
+            return $this->protocol;
+        };
+        return $getResponseBuilder->call($this->server);
+    }
+}

src/Router/TcpRouter.php → src/Router/JsonRpcTcpRouter.php

@@ -8,8 +8,9 @@
 use Hyperf\Rpc\Protocol;
 use Hyperf\RpcServer\Router\DispatcherFactory;
 use Psr\Container\ContainerInterface;
+use function Hyperf\Support\make;
 
-class TcpRouter
+class JsonRpcTcpRouter
 {
     private TcpServer $tcpServer;
 
@@ -22,7 +23,7 @@ public function __construct(ContainerInterface $container)
 
     public function getRouter($serverName)
     {
-        $data = \Hyperf\Support\make(DispatcherFactory::class, [
+        $data = make(DispatcherFactory::class, [
             'pathGenerator' => $this->getProtocol()->getPathGenerator(),
         ]);
         return $data->getRouter($serverName);