Dubbo配置參數(shù)詳解-mock
Dubbo是一個(gè)由阿里開源的服務(wù)治理框架，筆者的公司重度使用Dubbo。Dubbo開源這么多年，配置項(xiàng)已經(jīng)非常豐富，了解各個(gè)配置項(xiàng)的作用也變得非常重要，本系列將從源代碼的角度分析Dubbo目前的最新版本（2.7.4）各個(gè)常用的配置項(xiàng)的具體含義以及是怎么起作用的。
畫外音：目前Dubbo在開源中國(guó)舉辦的2019年度最受歡迎中國(guó)開源軟件中排名第3名，支持Dubbo的朋友可以去投票哇。2019年度最受歡迎中國(guó)開源軟件
mock是啥？
mock：百度百科：mock測(cè)試就是在測(cè)試過程中，對(duì)于某些不容易構(gòu)造或者不容易獲取的對(duì)象，用一個(gè)虛擬的對(duì)象來創(chuàng)建以便測(cè)試的測(cè)試方法。
dubbo中的不是用來測(cè)試的，是用來降級(jí)使用的。
mock有啥用？
dubbo中的mock用于服務(wù)降級(jí)，比如某驗(yàn)權(quán)服務(wù)，當(dāng)服務(wù)提供方全部掛掉后，客戶端不拋出異常，而是通過 Mock 數(shù)據(jù)返回授權(quán)失敗。
mock怎么使用？
同stub，mock也有兩種使用方式
- 在相同接口的包中創(chuàng)建一個(gè)名為InterfaceName+Mock的類，該類必須實(shí)現(xiàn)該Interface，設(shè)置@Reference(mock = "true")
- Consumer端自定義Mock類，名字隨意，設(shè)置全限定名@Reference(mock = "com....MyMock")
package com.example.dubboprovider.service;
/**
* @description: 當(dāng)調(diào)用provider返回RpcException時(shí)，會(huì)使用Mock數(shù)據(jù)代替provider，相當(dāng)與降級(jí)
* 該類必須跟HelloDubboService在同一個(gè)包中
* @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 "調(diào)用遠(yuǎn)端hello出錯(cuò)了";
}
@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: 當(dāng)調(diào)用provider返回RpcException時(shí)，會(huì)使用Mock數(shù)據(jù)代替provider，相當(dāng)與降級(jí)
* 該類名字隨意，包隨意
* @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源碼分析？
當(dāng)Consumer端調(diào)用Provider時(shí)，都會(huì)調(diào)用MockClusterInvoker，在這里判斷調(diào)用是否拋出RpcException，如果有則執(zhí)行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側(cè)拋出RpcException時(shí)才會(huì)執(zhí)行Mock，如果是Provider側(cè)拋出RpcException，Provider會(huì)將異常封裝在Result，這時(shí)Consumer端就無法捕獲該異常，就不會(huì)調(diào)用Mock。
筆者認(rèn)為這是不正確的，Provider側(cè)拋出的RpcException應(yīng)該也要調(diào)用Mock。
筆者已經(jīng)跟官方提交了Pr，修復(fù)了該問題：
fix when provider throw RpcException consumer do not invoke mock
總結(jié)
- Mock提供的是降級(jí)的功能；
- 只有拋出RpcException才會(huì)執(zhí)行Mock，業(yè)務(wù)異常是不會(huì)執(zhí)行Mock的；
畫外音：我也不知道為什么要用Mock這個(gè)參數(shù)，太容易跟Spring的Mock混淆了；
