从0到1实现rpc之异常码和异常超时

27 Mar 2024   |  

1. 定义RpcException

RpcException继承RuntimeException，定义特定错误码，专用于远程过程调用过程中产生的异常。

• X: 技术类异常
• Y: 业务类异常
• Z: 未知异常

在使用时，使用rpc专用的异常错误码，方便定位排查。

1. 超时异常重试

在发生网络超时的时候，可以进行重试，保证业务请求不因为网络原因而中断。

在代理类中，通过传入指定参数retry控制重试次数，使用while()循环进行重试，只对网络超时进行重试，其他异常直接抛出去。

1. 测试

在测试方法中通过睡眠模拟网络超时。特别的，只有8081请求端口访问时才超时，其他不会。

开始三个服务提供者，端口分别是8081,8082,8083

从服务消费者发起请求，睡眠时间是2秒，okhttp的连接超时时间设置为1秒，重试次数为1次。观察日志。

当请求到8081 时，发生网络超时，自动进行了一次重试，第二次重试，在负载均衡时采用的是轮询，所以重试选择了8083，请求成功了。

源码：

https://github.com/midnight2104/midnight-rpc/tree/lesson8

从0到1实现rpc之更新pom依赖方式

24 Mar 2024   |  

1. 当前工程目录进行编译时 mvn clean install，会报错。原因是 rpc-core和rpc-demo-api不是一个spring boot项目，没有启动类。

默认在根pom文件中引入了spring的parent，导致子模块都是web项目，所以需要更新pom文件。

1. 在根目录的pom文件移除parent。

1. 指定版本号

没有了统一的版本号，需要各模块自己指定。

1. 导入依赖管理

在consumer和provider两个模块使用依赖管理，导入spring的各个依赖。没有了paren引入的依赖，就需要通过这种方式引入依赖管理。

1. 再次编译

使用命令mvn clean install -Dmaven.test.skip=true 再次编译，先忽略测试案例。

从0到1实现rpc之支持mockfilter和cachefilter

23 Mar 2024   |  

一、在过滤器中定义好了前置过滤和后置过滤接口。

二、支持MockFilter

Mock过滤器应用场景是：当发现微服务间调用异常时，开启MockFilter可以对服务请求进行mock，排查是哪个微服务发生了问题。

前置过滤接口的实现逻辑是：

1. 从RpcRequest中获取服务接口类型；
2. 找到当前调用方法；
3. 获取方法返回值类型；
4. 对返回值类型进行mock

没有实现后置逻辑。

MockUtils的实现逻辑：对基本类型进行mock，对String类型进行mock，对一般类进行mock，还没有实现数组、集合、Map等复杂数据类型。

二、支持CacheFilter

CacheFilter的应用场景是：对调用过的请求进行缓存，不再发起远程调用，起缓存作用。

在前置过滤器中获取缓存，在后置过滤器中存放缓存结果。

三、在Consumer的应用

1. 在配置类ConsumerConfig中声明bean。

1. 在启动类ConsumerBootstrap中放到Context中，传递给代理对象。

1. 在代理对象中分别调用前置处理逻辑和后置处理逻辑。

四、测试

1. 缓存过滤器CacheFilter

调用findById()方法，第一次生成对象后，多次调用，返回的时间戳是一样的，证明缓存过滤器起作用了。

1. mock过滤器MockFilter

查看启动类中的测试方法，返回的都是mock值，就成功了。

还有什么问题？

1. Filter可以用责任链设计模式；
2. 可以使用其他缓存框架，支持过期时间；
3. 缓存没有考虑写操作。

源码：

https://github.com/midnight2104/midnight-rpc/tree/lesson7