Dubbo配置参数详解-mock

2020-01-07  本文已影响0人  codeimport

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也有两种使用方式

  1. 在相同接口的包中创建一个名为InterfaceName+Mock的类,该类必须实现该Interface,设置@Reference(mock = "true")
  2. 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这个参数,太容易跟Spring的Mock混淆了;

上一篇下一篇

猜你喜欢

热点阅读