Dubbo 源码解析 —— 简单原理、与spring融合

前言

结束了集群容错服务发布原理这两个小专题之后,有朋友问我服务引用什么时候开始,本篇为服务引用的启蒙篇.之前是一直和大家一起看源码,鉴于Talk is cheap.Show me your code,所以本篇将和大家一起写写代码.

插播面试题

  • dubbo的原理是怎么样的?请简单谈谈
  • 有没有考虑过自己实现一个类似dubbo的RPC框架,如果有,请问你会如果着手实现?(面试高频题,区分度高)
  • 你说你用过mybatis,那你知道Mapper接口的原理吗?(如果回答得不错,并且提到动态代理这个关键词会继续往下问,那这个动态代理又是如何通过依赖注入到Mapper接口的呢?)

直入主题

简单原理

谈到dubbo的原理,我们就必须首先要知道,dubbo的基本概念,通俗的说,就是dubbo是干嘛的

dubbo是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案

在此之前,就必须要讲讲以下几个简单又容易混淆的概念

  • 集群

同一个业务,部署在多个服务器上

  • 分布式

一个业务分拆多个子业务,部署在不同的服务器上

  • RPC

RPC(Remote Procedure Call Protocol)---远程过程调用

我们捕捉到几个重要的关键词,分布式,透明化,RPC.

既然各服务是部署在不同的服务器上,那服务间的调用就是要通过网络通信,简单的用图描述如下:

之前在dubbo源码解析-本地暴露的时候就有很多朋友留言问到,这个本地暴露有什么用.首先,dubbo作为一个被广泛运用的框架,点滴的性能提升,那么受益者都是很大一个数量.这也就是为什么JDK的源码,都喜欢用位运算.比如图中的UserServiceRoleService服务是在同一模块内的,他们直接的通信通过JVM性能肯定要比通过网络通信要好得多.这就是为什么dubbo在设计上,既有远程暴露,又有本地暴露的原因.

既然涉及到了网络通信,那么服务消费者调用服务之前,都要写各种网络请求,编解码之类的相关代码,明显是很不友好的.dubbo所说的透明,就是指,让调用者对网络请求,编解码之类的细节透明,让我们像调用本地服务一样调用远程服务,甚至感觉不到自己在调用远程服务.

说了这么多,那到底怎么做?要实现这个需求,我们很容易想到一个关键词,那就是动态代理

public interface MenuService {
    void sayHello();
}
public class MenuServiceImpl implements MenuService{
    @Override
    public void sayHello() {
    }
}
public class ProxyFactory implements InvocationHandler {
    private Class interfaceClass;
    public ProxyFactory(Class interfaceClass) {
        this.interfaceClass = interfaceClass;
    }
    //返回代理对象,此处用泛型为了调用时不用强转,用Object需要强转
    public  T getProxyObject(){
        return (T) Proxy.newProxyInstance(this.getClass().getClassLoader(),//类加载器
                new Class[]{interfaceClass},//为哪些接口做代理(拦截哪些方法)
                this);//(把这些方法拦截到哪处理)
    }
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        System.out.println(method);
        System.out.println("进行编码");
        System.out.println("发送网络请求");
        System.out.println("将网络请求结果进行解码并返回");
        return null;
    }
}
public void test() throws Exception {
    ProxyFactory proxyFactor = new ProxyFactory(MenuService.class);
    MenuService menuService = proxyFactor.getProxyObject();
    menuService.sayHello();
    //输出结果如下:
    //public abstract void com.toby.rpc.MenuService.sayHello()
    //进行编码
    //发送网络请求
    //将网络请求结果进行解码并返回
}

看到这里可能有朋友要吐槽了,我都看了你几个月的源码解析了,上面说的那些我早就懂了,那我还关注肥朝干嘛.我要的是整出一个类似dubbo的框架,性能上差点没关系,至少外观使用上要差不多,比如我们平时使用dubbo都是先在配置文件配置这么个东西

然后用在用@Autowired依赖注入来使用的,说白了,逼格要有!

与spring融合

我们假如要写一个简单的RPC,就取名叫tobyRPC(肥朝英文名为toby),其实我个人是比较喜欢截图,但是部分朋友和我反复强调贴代码,那这里我就贴代码吧

1.设计配置属性和JavaBean

public class ReferenceBean extends ReferenceConfig implements FactoryBean {
    @Override
    public Object getObject() throws Exception {
        return get();
    }
    @Override
    public Class<?> getObjectType() {
        return getInterfaceClass();
    }
    @Override
    public boolean isSingleton() {
        return true;
    }
}
public class ReferenceConfig {
    private Class<?> interfaceClass;
    // 接口代理类引用
    private transient volatile T ref;
    public synchronized T get() {
        if (ref == null) {
            init();
        }
        return ref;
    }
    private void init() {
        ref = new ProxyFactory(interfaceClass).getProxyObject();
    }
    public Class<?> getInterfaceClass() {
        return interfaceClass;
    }
    public void setInterfaceClass(Class<?> interfaceClass) {
        this.interfaceClass = interfaceClass;
    }
}

2.编写XSD文件

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
                        <![CDATA[ The service interface class name. ]]></xsd:documentation>
                            </tool:annotation>
                        </xsd:appinfo>
                    </xsd:annotation>
                </xsd:attribute>
            </xsd:extension>
        </xsd:complexContent>
    </xsd:complexType>
            <![CDATA[ Reference service config ]]></xsd:documentation>
        </xsd:annotation>
    </xsd:element>
</xsd:schema>

3.编写NamespaceHandlerBeanDefinitionParser完成解析工作

public class TobyRPCBeanDefinitionParser extends AbstractSingleBeanDefinitionParser {
    protected Class getBeanClass(Element element) {
        return ReferenceBean.class;
    }
    protected void doParse(Element element, BeanDefinitionBuilder bean) {
        String interfaceClass = element.getAttribute("interface");
        if (StringUtils.hasText(interfaceClass)) {
            bean.addPropertyValue("interfaceClass", interfaceClass);
        }
    }
}
public class TobyRPCNamespaceHandler extends NamespaceHandlerSupport {
    public void init() {
        registerBeanDefinitionParser("reference", new TobyRPCBeanDefinitionParser());
    }
}

4.编写spring.handlersspring.schemas串联起所有部件

spring.handlers

http\://toby.com/schema/tobyRPC=com.toby.config.TobyRPCNamespaceHandler

spring.schemas

http\://toby.com/schema/tobyRPC.xsd=META-INF/tobyRPC.xsd

5.创建配置文件

<?xml version="1.0" encoding="UTF-8"?>

demo结构截图如下:

万事俱备,那我们跑个单元测试看看

运行结果如我们所料.但是具体要怎么编码,怎么发送请求,又如何解码好像也没说啊.没说?没说就对了.在完结服务引用这个小专题后,还会重点和大家看一下dubbo中的编解码,spi,javassist等重点内容源码,等粗略把整个框架的思想都掌握后,再手把手临摹一个五脏俱全(包含设计模式,dubbo架构设计)的简易dubbo框架.总之一句话,关注肥朝即可.

敲黑板划重点

为什么面试都喜欢问原理,难道都是为了装逼?当然不是,明白了原理,很多东西都是一通百通的.我们来看mybatis的这道面试题.首先Mapper接口的原理,可以参考我之前的别怕看源码,一张图搞定Mybatis的Mapper原理 ,其实说白了,就是给Mapper接口注入一个代理对象,然后动态代理对象调用方法会被拦截到invoke中,然后在这个invoke方法中,做了一些不可描述的事情(老司机可以尽情YY).而这一切的前提,都是要无声无息的把动态代理对象注入进去.其实注入进去的原理和dubbo也是一样的,我们简单看两个图

雄关万道真如铁,而今迈步从头越

因为一些原因,经营了一年多的简书,可能要逐步停更(流下两行热泪),大部分文章在后面会迁入掘金.今后的每周一篇也会在掘金首发

回首向来萧瑟处,也无风雨也无晴

变的只是发布平台,不变的是还是那个无比热爱技术的肥朝,每周一篇dubbo源码解析承诺依然不变(熟悉的配方,熟悉的味道).鉴于本人才疏学浅,不对的地方还望斧正,也欢迎大家继续关注我的掘金,互相交流进步.简书掘金同名,依旧为肥朝

原文发布于微信公众号 - 芋道源码(YunaiV)

原文发表时间:2018-03-23

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏架构之路

追源索骥:透过源码看懂Flink核心框架的执行流程

写在最前:因为这篇博客太长,所以我把它转成了带书签的pdf格式,看起来更方便一点。想要的童鞋可以到我的公众号“老白讲互联网”后台留言flink即可获取。

3.4K50
来自专栏极客慕白的成长之路

信息安全实验室招新试题和完全解析

写个网页应该是很简单的,不管是静态网页还是带特效的网页。但是有几个问题,需要说明一下。

12830
来自专栏美团技术团队

Android热更新方案Robust

美团•大众点评是中国最大的O2O交易平台,目前已拥有近6亿用户,合作各类商户达432万,订单峰值突破1150万单。美团App是平台主要的入口之一,O2O交易场景...

43290
来自专栏java一日一条

编写可靠 Shell 脚本的 8 个建议

这八个建议,来源于键者几年来编写 shell 脚本的一些经验和教训。事实上开始写的时候还不止这几条,后来思索再三,去掉几条无关痛痒的,最后剩下八条。毫不夸张地说...

12220
来自专栏雨过天晴

原 荐 C# FTP 坑了我两天的一个坑

1.4K70
来自专栏趣谈编程

synchronized与Lock 擂台之战

面试官:说说synchronized和Lock(或ReentrantLock)的区别 Java 1.5之后,对共享变量访问的协调机制除了之前的synchron...

202100
来自专栏小狼的世界

Go学习入门

Go语言的历史要从贝尔实验室开始说起,我们知道贝尔实验室计算科学研究中心的肯•汤普逊 Ken Thompson 和丹尼斯 • 里奇 Dennis Ritchie...

37920
来自专栏互扯程序

Java 9 逆天的十大新特性

KS Knowledge Sharing 知识分享 现在是资源共享的时代,同样也是知识分享的时代,如果你觉得本文能学到知识,请把知识与别人分享。 在介绍...

27460
来自专栏PhpZendo

没错,这就是面向对象编程(设计模式)需要遵循的 6 个基本原则

在讨论面向对象编程和模式(具体一点来说,设计模式)的时候,我们需要一些标准来对设计的好还进行判断,或者说应该遵循怎样的原则和指导方针。

10620
来自专栏Golang语言社区

Go语言实战: 编写可维护Go语言代码建议

大家好, 我在接下来的两个会议中的目标是向大家提供有关编写Go代码最佳实践的建议。

23830

扫码关注云+社区

领取腾讯云代金券