如何在rpc server中使用自定义middleWare和exceptionHandler

[uuuuuuuu-s]

rpc interface 尽管是内部调用，依然存在参数验证 权限验证的需求，用validation middleware解藕可以很方便的解决掉这个问题，文档中关于middleWare和exceptionHandler的使用教程，但在rpc server中需要做一些调整后才能使用。使用方法如下：
1.配置middleware和exceptionHandler参考官方文档的介绍即可，
https://hyperf.wiki/2.1/#/zh-cn/middleware/middleware
https://hyperf.wiki/2.1/#/zh-cn/exception-handler
注意：middleware的配置可以配置成下边这种格式，这样就可以对每个server做单独处理。

return [
    'jsonrpc' => [
        new App\Middleware\FooMiddleware('jsonrpc'),
    ],
];

2.如果需要在middleware中截断请求，直接返回response，可参考以下代码：

<?php

declare(strict_types=1);
/**
 * This file is part of Hyperf.
 *
 * @link     https://www.hyperf.io
 * @document https://hyperf.wiki
 * @contact  [email protected]
 * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
 */
namespace App\Middleware;

use Hyperf\Contract\ConfigInterface;
use Hyperf\JsonRpc\ResponseBuilder;
use Hyperf\Utils\Reflection\ClassInvoker;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

class FooMiddleware implements MiddlewareInterface
{
    public function __construct(public string $server)
    {
    }

    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        return $this->getResponseBuilder()->buildResponse($request, 3);
    }

    protected function getConfig(): array
    {
        $config = di()->get(ConfigInterface::class)->get('server.servers');
        foreach ($config as $item) {
            if ($item['name'] === $this->server) {
                return $item;
            }
        }
        return [];
    }

    protected function getResponseBuilder(): ResponseBuilder
    {
        $proxy = new ClassInvoker(di()->get($this->getConfig()['callbacks']['receive'][0]));

        return $proxy->responseBuilder;
    }
}
```

总结：在hyperf中，json rpc response是遵照规范，由vendor/hyperf/json-rpc/src/ResponseBuilder.php 生成的，如果自定义的middleware返回的response对象不符合规范，会引起调用方异常。所以以上的示例中通过Hyperf\Utils\Reflection\ClassInvoker来获取到当前server中的ResponseBuilder对象。同理。自定义的exceptionHandler中也可以使用这个办法。

PS:感谢大佬@李铭昕提供的demo以及思路。大家有其他更好的办法欢迎讨论。