mirror of
https://gitee.com/hyperf/hyperf.git
synced 2024-12-04 20:58:13 +08:00
204 lines
7.8 KiB
Markdown
204 lines
7.8 KiB
Markdown
# JSON RPC 服务
|
||
|
||
JSON RPC 是一种基于 JSON 格式的轻量级的 RPC 协议标准，易于使用和阅读。在 Hyperf 里由 [hyperf/json-rpc](https://github.com/hyperf-cloud/json-rpc) 组件来实现，可自定义基于 HTTP 协议来传输，或直接基于 TCP 协议来传输。
|
||
|
||
# 安装
|
||
|
||
```bash
|
||
composer require hyperf/json-rpc
|
||
```
|
||
|
||
该组件只是 JSON RPC 的协议处理的组件，通常来说，您仍需配合 [hyperf/rpc-server](https://github.com/hyperf-cloud/rpc-server) 或 [hyperf/rpc-client](https://github.com/hyperf-cloud/rpc-client) 来满足 服务端 和 客户端的场景，如同时使用则都需要安装：
|
||
|
||
要使用 JSON RPC 服务端：
|
||
|
||
```bash
|
||
composer require hyperf/rpc-server
|
||
```
|
||
|
||
要使用 JSON RPC 客户端：
|
||
|
||
```bash
|
||
composer require hyperf/rpc-client
|
||
```
|
||
|
||
# 使用
|
||
|
||
服务有两种角色，一种是 `服务提供者(ServiceProvider)`，即为其它服务提供服务的服务，另一种是 `服务消费者(ServiceConsumer)`，即依赖其它服务的服务，一个服务既可能是 `服务提供者(ServiceProvider)`，同时又是 `服务消费者(ServiceConsumer)`。而两者直接可以通过 `服务契约` 来定义和约束接口的调用，在 Hyperf 里，可直接理解为就是一个 `接口类(Interface)`，通常来说这个接口类会同时出现在提供者和消费者下。
|
||
|
||
## 定义服务提供者
|
||
|
||
目前仅支持通过注解的形式来定义 `服务提供者(ServiceProvider)`，后续迭代会增加配置的形式。
|
||
我们可以直接通过 `@RpcService` 注解对一个类进行定义即可发布这个服务了：
|
||
|
||
```php
|
||
<?php
|
||
|
||
namespace App\JsonRpc;
|
||
|
||
use Hyperf\RpcServer\Annotation\RpcService;
|
||
|
||
/**
|
||
* 注意，如希望通过服务中心来管理服务，需在注解内增加 publishTo 属性
|
||
* @RpcService(name="CalculatorService", protocol="jsonrpc-http", server="jsonrpc-http")
|
||
*/
|
||
class CalculatorService implements CalculatorServiceInterface
|
||
{
|
||
// 实现一个加法方法，这里简单的认为参数都是 int 类型
|
||
public function add(int $a, int $b): int
|
||
{
|
||
// 这里是服务方法的具体实现
|
||
return $a + $b;
|
||
}
|
||
}
|
||
```
|
||
|
||
`@RpcService` 共有 `4` 个参数：
|
||
`name` 属性为定义该服务的名称，这里定义一个全局唯一的名字即可，Hyperf 会根据该属性生成对应的 ID 注册到服务中心去；
|
||
`protocol` 属性为定义该服务暴露的协议，目前仅支持 `jsonrpc` 和 `jsonrpc-http`，分别对应于 TCP 协议和 HTTP 协议下的两种协议，默认值为 `jsonrpc-http`，这里的值对应在 `Hyperf\Rpc\ProtocolManager` 里面注册的协议的 `key`，这两个本质上都是 JSON RPC 协议，区别在于数据格式化、数据打包、数据传输器等不同。
|
||
`server` 属性为绑定该服务类发布所要承载的 `Server`，默认值为 `jsonrpc-http`，该属性对应 `config/autoload/server.php` 文件内 `servers` 下所对应的 `name`，这里也就意味着我们需要定义一个对应的 `Server`，我们下一章节具体阐述这里应该怎样去处理；
|
||
`publishTo` 属性为定义该服务所要发布的服务中心，目前仅支持 `consul` 或为空，为空时代表不发布该服务到服务中心去，但也就意味着您需要手动处理服务发现的问题，当值为 `consul` 时需要对应配置好 [hyperf/consul](./consul.md) 组件的相关配置，要使用此功能需安装 [hyperf/service-governance](https://github.com/hyperf-cloud/service-governance) 组件，具体可参考 [服务注册](./service-register.md) 章节；
|
||
|
||
> 使用 `@RpcService` 注解需 `use Hyperf\RpcServer\Annotation\RpcService;` 命名空间。
|
||
|
||
### 定义 JSON RPC Server
|
||
|
||
HTTP Server (适配 `jsonrpc-http` 协议)
|
||
|
||
```php
|
||
<?php
|
||
|
||
use Hyperf\Server\Server;
|
||
use Hyperf\Server\SwooleEvent;
|
||
|
||
return [
|
||
// 这里省略了该文件的其它配置
|
||
'servers' => [
|
||
[
|
||
'name' => 'jsonrpc-http',
|
||
'type' => Server::SERVER_HTTP,
|
||
'host' => '0.0.0.0',
|
||
'port' => 9504,
|
||
'sock_type' => SWOOLE_SOCK_TCP,
|
||
'callbacks' => [
|
||
SwooleEvent::ON_REQUEST => [\Hyperf\JsonRpc\HttpServer::class, 'onRequest'],
|
||
],
|
||
],
|
||
],
|
||
];
|
||
```
|
||
|
||
TCP Server (适配 `jsonrpc` 协议)
|
||
|
||
```php
|
||
<?php
|
||
|
||
use Hyperf\Server\Server;
|
||
use Hyperf\Server\SwooleEvent;
|
||
|
||
return [
|
||
// 这里省略了该文件的其它配置
|
||
'servers' => [
|
||
[
|
||
'name' => 'jsonrpc',
|
||
'type' => Server::SERVER_TCP,
|
||
'host' => '0.0.0.0',
|
||
'port' => 9503,
|
||
'sock_type' => SWOOLE_SOCK_TCP,
|
||
'callbacks' => [
|
||
SwooleEvent::ON_RECEIVE => [\Hyperf\JsonRpc\TcpServer::class, 'onReceive'],
|
||
],
|
||
'settings' => [
|
||
'open_eof_split' => true,
|
||
'package_eof' => "\r\n",
|
||
],
|
||
],
|
||
],
|
||
];
|
||
```
|
||
|
||
## 发布到服务中心
|
||
|
||
目前仅支持发布服务到 `consul`，后续会增加其它服务中心。
|
||
发布服务到 `consul` 在 Hyperf 也是非常容易的一件事情，通过 `composer require hyperf/consul` 加载 Consul 组件（如果已安装则可忽略该步骤），然后再在 `config/autoload/consul.php` 配置文件内配置您的 `Consul` 配置即可，示例如下：
|
||
|
||
```php
|
||
<?php
|
||
|
||
return [
|
||
'uri' => 'http://127.0.0.1:8500',
|
||
];
|
||
```
|
||
|
||
配置完成后，在启动服务时，Hyperf 会自动地将 `@RpcService` 定义了 `publishTo` 属性为 `consul` 的服务注册到服务中心去。
|
||
|
||
> 目前仅支持 `jsonrpc` 和 `jsonrpc-http` 协议发布到服务中心去，其它协议尚未实现服务注册
|
||
|
||
## 定义服务消费者
|
||
|
||
一个 `服务消费者(ServiceConsumer)` 可以理解为就是一个客户端类，但在 Hyperf 里您无需处理连接和请求相关的事情，只需要定义一个类及相关属性即可。（后续版本迭代会提供动态代理实现的客户端，使之更加简单便捷）
|
||
|
||
```php
|
||
<?php
|
||
|
||
namespace App\JsonRpc;
|
||
|
||
use Hyperf\RpcClient\AbstractServiceClient;
|
||
|
||
class CalculatorServiceConsumer extends AbstractServiceClient implements CalculatorServiceInterface
|
||
{
|
||
/**
|
||
* 定义对应服务提供者的服务名称
|
||
* @var string
|
||
*/
|
||
protected $serviceName = 'CalculatorService';
|
||
|
||
/**
|
||
* 定义对应服务提供者的服务协议
|
||
* @var string
|
||
*/
|
||
protected $protocol = 'jsonrpc-http';
|
||
|
||
public function add(int $a, int $b): int
|
||
{
|
||
return $this->__request(__FUNCTION__, compact('a', 'b'));
|
||
}
|
||
}
|
||
```
|
||
|
||
然后还需要在配置文件定义一个配置标记要从何服务中心获取节点信息，位于 `config/autoload/services.php` (如不存在可自行创建)
|
||
|
||
```php
|
||
<?php
|
||
return [
|
||
'consumers' => [
|
||
[
|
||
// 对应消费者类的 $serviceName
|
||
'name' => 'CalculatorService',
|
||
// 这个消费者要从哪个服务中心获取节点信息，如不配置则不会从服务中心获取节点信息
|
||
'registry' => [
|
||
'protocol' => 'consul',
|
||
'address' => 'http://127.0.0.1:8500',
|
||
],
|
||
// 如果没有指定上面的 registry 配置，即为直接对指定的节点进行消费，通过下面的 nodes 参数来配置服务提供者的节点信息
|
||
'nodes' => [
|
||
['host' => '127.0.0.1', 'port' => 9504],
|
||
],
|
||
]
|
||
],
|
||
];
|
||
```
|
||
|
||
|
||
这样我们便可以通过 `CalculatorService` 类来实现对服务的消费了，为了让这里的关系逻辑更加的合理，还应该在 `config/dependencies.php` 内定义 `CalculatorServiceInterface` 和 `CalculatorServiceConsumer` 的关系，示例如下：
|
||
|
||
```php
|
||
return [
|
||
'dependencies' => [
|
||
App\JsonRpc\CalculatorServiceInterface::class => App\JsonRpc\CalculatorServiceConsumer::class,
|
||
],
|
||
];
|
||
```
|
||
|
||
这样便可以通过注入 `CalculatorServiceInterface` 接口来使用客户端了。
|