dubbo学习之本地存根实践

川长思鸟来 2022-12-04 09:29 188阅读 0赞

### 目录 ###

*  绪论
 *  实践
 *   *  dubbo-demo-interface
     *  dubbo-demo-xml-provider
     *  dubbo-demo-xml-consumer
     *  启动

# 绪论 #

今天主要学习并实践dubbo的本地存根stub机制。首先了解一下官网文档对本地存根的介绍：

远程服务后，客户端通常只剩下接口，而实现全在服务器端，但提供方有些时候想在客户端也执行部分逻辑。
    比如：做 ThreadLocal 缓存，提前验证参数，调用失败后伪造容错数据等等。
    核心思想：API 中带上 Stub，客户端生成 Proxy 实例，**会把 Proxy 通过构造函数传给 Stub** ，然后把 Stub 暴露给用户，Stub 可以决定要不要去调 Proxy。

Stub会使用代理模式将原有的远程调用service进行包装，让使用者可以在远程服务调用前后做一些通用处理，非常适合做缓存容错，或者日志处理，异常包装等。故**本地存根机制类似与AOP机制中的around advice（环绕增强）**；  
则本地存根执行顺序：  
1.服务消费者发起调用；  
2.如果服务消费者端存在本地存根 Stub 的话，会先执行本地存根；  
3.本地存根 Stub 持有远程服务的 Proxy 对象，Stub 在执行的时候，会先执行自己的逻辑`(before)`，然后通过`Proxy 发起远程调用`，最后在返回过程之前也会执行自己的逻辑`(after-returning)`  
4.如果远程服务的 Proxy 对象在执行过程中抛出了 exception，会执行服务消费端的`本地伪装 Mock 的逻辑 (after-throwing)`【后面再议】，返回容错数据，从而达到服务降级的目的。  
如图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center]

# 实践 #

虽然dubbo官网简单给了本地存根的示例，但不是能够足以解决新手实战问题，其他博客千篇一律，没有几乎什么改进的地方，溪源学习的时候也是在花费了两个下班的时间搞定的实践，实属坎坷～  
**写在前面**

dubbo官网给出两种设置本地存根的示例

*  `stub`的属性值设置为实现类的全限定名；
 *  `stub`的属性值，则默认设置为**true**；  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 1]

溪源主要给大家说下第二种方式：**踩坑点**；  
**如果默认将`stub`属性设置为true，则必须保证本地存根实现类以`Stub`命名结尾，例如`UserServiceStub`.**  
那为什么要这么设置呢？？？？给大家贴一下源码`ServiceConfig#checkAndUpdateSubConfigs()`类中。  
如果实现类不以Stub结束,那反射查找本地存根实现类便找不到，又谈何实现本地存根的逻辑呢～  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 2]  
踩坑点相信大家已经清楚，下面开始进入实战环节。

再看下dubbo官网本地存根，细品细品：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 3]

## dubbo-demo-interface ##

*  **目录结构如下**：  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 4]
 *  **UserService**  
    简单定义一个方法

/** * @author wx * @date 2020/9/6 11:39 下午 * 测试本地存根服务接口 */
    public interface UserService { 
        /** * 根据用户名，返回用户名字 * @param userId 用户ID * @return 用户名 */
        String getUserName(String userId);
    }

*  **UserServiceStub**

/** * @author wx * @date 2020/9/6 11:09 下午 * 服务消费者实现接口，并实现本地存根逻辑 */
    public class UserServiceStub implements UserService { 
        private static final String USER_ID  = "1503891";
    
        private final UserService userService;
    
        /** * 通过构造方法将服务接口代理对象（接口实现类对象）传入stub * @param userService */
        public UserServiceStub(UserService userService) { 
            this.userService = userService;
        }
    
        @Override
        public String getUserName(String userId) { 
            System.out.println("开始执行服务消费端本地存根逻辑");
            if (StringUtils.isBlank(userId)) { 
                return "userId is null";
            }
            if (!USER_ID.equals(userId)) { 
                return "user not exits";
            }
            String userName = userService.getUserName(userId);
            System.out.println("结束执行服务消费端本地存根逻辑");
            return userName;
        }
    }

## dubbo-demo-xml-provider ##

*  **目录结构**  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 5]
 *  **stub-provider.xml**  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 6]
 *  **UserProviderStubServiceImpl**

/** * @author wx * @date 2020/9/6 11:09 下午 * 服务消费者实现接口，并实现本地存根逻辑 */
    @Service
    public class UserProviderStubServiceImpl implements UserService { 
        private static final String USER_ID  = "1503891";
    
        @Override
        public String getUserName(String userId) { 
            return USER_ID.equals(userId) ? "溪～源" : "";
        }
    }

*  **ProviderApplication**

/** * 服务端Stub测试 * @throws IOException */
        private static void stubTest() throws IOException { 
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/stub-provider.xml");
            context.start();
            System.in.read();
        }

## dubbo-demo-xml-consumer ##

*  **stub-consumer.xml**  
    消费者端并没有新增实现类，但溪源为了**代码的整洁与后期维护、梳理**，选择了新建`stub-consumer.xml`配置文件和单元测试的模式实践.  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 7]
 *  **ConsumerApplication**

private static void stubTest() { 
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/stub-consumer.xml");
            UserService stubService = context.getBean(UserService.class);
            String userName = stubService.getUserName("1503891");
            System.out.println(userName);
    
        }

## 启动 ##

分别启动provider，consumer如图：

*  测试1  
    将userId传为空  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 8]
 *  测试2  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 9]

到此为止，本地存根实践应用结束，大家对源码如何实现原理，可以借助此demo开始debug吧～

溪源初次接触dubbo本地存根机制，如文中存在错误之处，希望大家及时指正！

源码传送门：[https://github.com/stream-source/dubbo/tree/master/dubbo-demo][https_github.com_stream-source_dubbo_tree_master_dubbo-demo]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/37429c1a7e974f47a2c90d2b60edafb2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221123/b91b590337154a37b9cbd1a88ddf97dc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221123/4a5d1b5a6ca94cdc8b297e359909aaf3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221123/d605dc634eb24a0db4c3989ae92c071a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221123/6b69827c7e4d4fae8591e14b94325dac.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221123/dc22c96dea3847f8bad63c6e3aceca6c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20221123/03b202c84b1a4aeb8be36fb106729295.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20221123/d8519446d7ec4550923616c0413c4b9d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 8]: /images/20221123/985a7a9ebbcc4d4a8225c5356a7e7c63.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1YW5fbHU_size_16_color_FFFFFF_t_70_pic_center 9]: /images/20221123/55af4d74f9b04eab94de91abf283138e.png
[https_github.com_stream-source_dubbo_tree_master_dubbo-demo]: https://github.com/stream-source/dubbo/tree/master/dubbo-demo