Dubbo配置参数详解-mock
Dubbo是一个由阿里开源的服务治理框架,笔者的公司重度使用Dubbo。Dubbo开源这么多年,配置项已经非常丰富,了解各个配置项的作用也变得非常重要,本系列将从源代码的角度分析Dubbo目前的最新版本(2.7.4)各个常用的配置项的具体含义以及是怎么起作用的。
画外音:目前Dubbo在开源中国举办的2019年度最受欢迎中国开源软件中排名第3名,支持Dubbo的朋友可以去投票哇。2019年度最受欢迎中国开源软件
mock是啥?
mock:百度百科:mock测试就是在测试过程中,对于某些不容易构造或者不容易获取的对象,用一个虚拟的对象来创建以便测试的测试方法。
dubbo中的不是用来测试的,是用来降级使用的。
mock有啥用?
dubbo中的mock用于服务降级,比如某验权服务,当服务提供方全部挂掉后,客户端不抛出异常,而是通过 Mock 数据返回授权失败。
mock怎么使用?
同stub,mock也有两种使用方式
- 在相同接口的包中创建一个名为InterfaceName+Mock的类,该类必须实现该Interface,设置@Reference(mock = "true")
- Consumer端自定义Mock类,名字随意,设置全限定名@Reference(mock = "com....MyMock")
package com.example.dubboprovider.service;
/**
* @description: 当调用provider返回RpcException时,会使用Mock数据代替provider,相当与降级
* 该类必须跟HelloDubboService在同一个包中
* @author: chengang6
* @create: 2019/5/22 17:16
**/
public class HelloDubboServiceMock implements HelloDubboService {
@Override
public String say() {
return "mock-say";
}
@Override
public String hello() {
return "调用远端hello出错了";
}
@Override
public String post(String key) {
return "mock-post";
}
}
@Reference(mock = "true")
private HelloDubboService helloDubboService;
package com.example.dubboconsumer.mock;
import com.example.dubboprovider.service.HelloDubboService;
/**
* @description: 当调用provider返回RpcException时,会使用Mock数据代替provider,相当与降级
* 该类名字随意,包随意
* @author: chengang6
* @create: 2019/5/22 17:16
**/
public class MyMock implements HelloDubboService {
@Override
public String say() {
return "mock-say";
}
@Override
public String hello() {
return "mock-hello";
}
@Override
public String post(String key) {
return "mock-post";
}
}
@Reference(mock = "com.example.dubboconsumer.stub.MyMock")
private HelloDubboService helloDubboService;
mock源码分析?
当Consumer端调用Provider时,都会调用MockClusterInvoker,在这里判断调用是否抛出RpcException,如果有则执行Mock
public Result invoke(Invocation invocation) throws RpcException {
Result result = null;
String value = this.directory.getUrl().getMethodParameter(invocation.getMethodName(), "mock", Boolean.FALSE.toString()).trim();
if (value.length() != 0 && !value.equalsIgnoreCase("false")) {
if (value.startsWith("force")) {
if (logger.isWarnEnabled()) {
logger.warn("force-mock: " + invocation.getMethodName() + " force-mock enabled , url : " + this.directory.getUrl());
}
result = this.doMockInvoke(invocation, (RpcException)null);
} else {
try {
result = this.invoker.invoke(invocation);
} catch (RpcException var5) {
if (var5.isBiz()) {
throw var5;
}
if (logger.isWarnEnabled()) {
logger.warn("fail-mock: " + invocation.getMethodName() + " fail-mock enabled , url : " + this.directory.getUrl(), var5);
}
result = this.doMockInvoke(invocation, var5);
}
}
} else {
result = this.invoker.invoke(invocation);
}
return result;
}
问题
只有Consumer侧抛出RpcException时才会执行Mock,如果是Provider侧抛出RpcException,Provider会将异常封装在Result,这时Consumer端就无法捕获该异常,就不会调用Mock。
笔者认为这是不正确的,Provider侧抛出的RpcException应该也要调用Mock。
笔者已经跟官方提交了Pr,修复了该问题:
fix when provider throw RpcException consumer do not invoke mock
总结
- Mock提供的是降级的功能;
- 只有抛出RpcException才会执行Mock,业务异常是不会执行Mock的;
画外音:我也不知道为什么要用Mock这个参数,太容易跟Spring的Mock混淆了;