Swoft 2.x Rpc调用

蔚落 2022-08-28 12:43 17阅读 0赞

## Swoft框架的初始化 ##

Swoft初始化有六个步骤:

1.  ENV环境文件初始化
2.  注解信息扫描收集
3.  配置初始化
4.  注册类到bean容器
5.  收集事件监听器
6.  启动console控制台，启动相应的服务

[官方文档][Link 1]

而Rpc作为Swoft提供的基础模块之一，其初始化流程也与框架的初始化一致

## Rpc服务调用 ##

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16][]

Rpc的本质也是一个请求的发送和处理，所以会有发送请求的Client和接收请求的Server，这两者在Swoft中都需要进行Bean容器的注册

## Rpc 服务初始化 ##

Rpc Client是发起Rpc请求的客户端，在Swoft中其底层实现是Swoole的协程客户端，即 Swoole\\Coroutine\\Client， 且Swoft对客户端进行了连接池的实现，每次进行Rpc请求的调用时，无需不断初始化Client，只需要在Rpc Client的连接池中获取Client即可

在Swoft中是以服务的形式来声明不同的功能模块，具体在 /app/bean.php中 声明配置

官方提供了一个user的rpc 服务:

### Rpc Client服务配置 ###

![20210924105236420.png][]

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

### Rpc 服务注入 ###

在 /app/Http/Controller/RpcController 中声明并注入配置文件中配置好的Rpc服务

![2021092410540265.png][]

Client启动时，通过控制器当中的接口注解，去访问Rpc服务，所以框架启动时通过代理类解析接口注解，并加载对象到附加容器中，在调用时可以从容器中获取并调用

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

【注意】 更底层的服务注入和Rpc服务初始化要看 Bean容器初始化及 Rpc 的框架底层源码

具体位置在 /vendor/swoft/bean 及 /vendor/swoft/rpc-client /vendor/swoft/rpc-server

### 服务编写 ###

服务的具体业务内容编写在 app/Rpc 中，这个在官方文档中有详细介绍

大体流程就是需要先 声明服务接口，然后再实现这个服务接口

[官方文档详细介绍][Link 2]

【注意】 当然上述是基于swoft框架的Rpc服务，若调用的是其他系统的rpc，则需要根据事先规定好的rpc协议进行通信

## Rpc服务启动 ##

swoft的Rpc服务有单独启动和集成其他服务（http/Websocket）两种方式，无论哪种方式，都需要在 bean.php 中配置Rpc

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

如图， Rpc服务成功启动

![20210924105728953.png][]

**1.Rpc请求过来后，进行dispatch， 触发dispatch**  
![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 4][]

**2.在服务分发类中调用 serviceHandle 处理请求**

**![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_19_color_FFFFFF_t_70_g_se_x_16][]**

**3.加载对应中间件处理请求**

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 5][]

**4.进行路由匹配，通过获取发送的打包数据，决定调用的接口方法及版本**

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 6][]

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 7][]

至此一个完整的Rpc请求完成，但是Swoft2.0中并没有提供远程Rpc的服务发现组件，需要手动进行集成和封装

**swoole官方文档**

协程客户端 https://wiki.swoole.com/\#/coroutine\_client/init  
连接池 https://wiki.swoole.com/\#/coroutine/conn\_pool  
多端口监听 https://wiki.swoole.com/\#/server/port

**swoft2.0 文档**

rpc-server https://www.bookstack.cn/read/swoft-doc-v2.x/rpc-server-index.md  
rpc-client https://www.bookstack.cn/read/swoft-doc-v2.x/rpc-client-index.md

[Link 1]: https://github.com/swoft-cloud/swoft-doc/blob/2.x/zh-CN/SUMMARY.md
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/8b89bad251f243008d9052be98e9b4bf.png
[20210924105236420.png]: /images/20220828/514a156bb52c469d9e6ba62143190b91.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/1b8bb196b6d6475b900c90ea8502fece.png
[2021092410540265.png]: /images/20220828/fe0d9121300249138293df0b2503a290.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/2aa7862780af44539a370045f24f5261.png
[Link 2]: https://www.bookstack.cn/read/swoft-doc-v2.x/rpc-server-statement.md
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220828/8590d64ce8a74990b7b64db3f86f0ae7.png
[20210924105728953.png]: /images/20220828/c51882f152574e68b99e5930e3e66062.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 4]: /images/20220828/4058f298817a43c590cd4cb330498b63.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_19_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/8611ce1110bf4547885de63b20f9d832.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 5]: /images/20220828/500ca1395e8a4b26a8ab583efc02433a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 6]: /images/20220828/a2600efda5ad4f7381ae5b4d414f3855.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oi05Zu96L-b_size_20_color_FFFFFF_t_70_g_se_x_16 7]: /images/20220828/17a51245296e41fdba358b244ac5b7f9.png