美文网首页
【dubbo源码】9. 服务提供方发布之netty服务端启动

【dubbo源码】9. 服务提供方发布之netty服务端启动

作者: 天还下着毛毛雨 | 来源:发表于2021-07-11 17:56 被阅读0次

    前言

    服务提供方把自己注册到注册中心后,服务调用方从注册中心获取到服务提供方的信息之后,肯定要发起调用。

    dubbo的远程调用主要是用netty nio的方式,利用tcp协议进行网络通信,那么服务提供方在启动的时候,肯定是要启动一个netty服务端的服务的,用来接受调用请求。

    1.服务提供方的invoke对象的创建

    Invoker是Dubbo中的实体域，也就是真实存在的。其他模型都向它靠拢或转换成它，它也就代表一个可执行体，可向它发起invoke调用。在服务提供方，Invoker用于调用服务提供类。在服务消费方，Invoker用于执行远程调用。

    invoke 接口

    image

    除了getInterface,只有一个用于执行具体逻辑的invoke方法

    服务提供方的invoke对象

    提供了对服务提供类实例的

    image

    通过proxyFactory对象的getInvoker返回的invoker对象

    1.ref对象

    其实就是服务暴露类的实例


    image

    是ServiceConfig的成员变量,由spring在实例化serviceBean实例的时候,依赖注入而来。

    image

    ServiceBean BeanDifinition创建过程

    image
    2.proxyFactory对象(JavassistProxyFactory)

    ProxyFactory实例,用SPI机制获取的。

    image 
    ExtensionLoader.getExtensionLoader(ProxyFactory.class).getAdaptiveExtension(

    这个dubbo api在spi源码里讲过,如果spi配置文件中配置的该接口的实现类上都没有@Adaptive注解,那么会用javaassist生成一个ProxyFactory的实现类，具体生成的是这样子的

    package com.alibaba.dubbo.rpc;

import com.alibaba.dubbo.common.extension.ExtensionLoader;

public class ProxyFactory$Adaptive implements com.alibaba.dubbo.rpc.ProxyFactory {
    // 实现的getProxy方法获取的默认的实现类的key是javassist
    public java.lang.Object getProxy(com.alibaba.dubbo.rpc.Invoker arg0) throws com.alibaba.dubbo.rpc.RpcException {
        if (arg0 == null) throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument == null");
        if (arg0.getUrl() == null)
            throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument getUrl() == null");
        com.alibaba.dubbo.common.URL url = arg0.getUrl();
        String extName = url.getParameter("proxy", "javassist");
        if (extName == null)
            throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.ProxyFactory) name from url(" + url.toString() + ") use keys([proxy])");
        com.alibaba.dubbo.rpc.ProxyFactory extension = (com.alibaba.dubbo.rpc.ProxyFactory) ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.ProxyFactory.class).getExtension(extName);
        return extension.getProxy(arg0);
    }

    public java.lang.Object getProxy(com.alibaba.dubbo.rpc.Invoker arg0, boolean arg1) throws com.alibaba.dubbo.rpc.RpcException {
        if (arg0 == null) throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument == null");
        if (arg0.getUrl() == null)
            throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument getUrl() == null");
        com.alibaba.dubbo.common.URL url = arg0.getUrl();
        String extName = url.getParameter("proxy", "javassist");
        if (extName == null)
            throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.ProxyFactory) name from url(" + url.toString() + ") use keys([proxy])");
        com.alibaba.dubbo.rpc.ProxyFactory extension = (com.alibaba.dubbo.rpc.ProxyFactory) ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.ProxyFactory.class).getExtension(extName);
        return extension.getProxy(arg0, arg1);
    }

    public com.alibaba.dubbo.rpc.Invoker getInvoker(java.lang.Object arg0, java.lang.Class arg1, com.alibaba.dubbo.common.URL arg2) throws com.alibaba.dubbo.rpc.RpcException {
        if (arg2 == null) throw new IllegalArgumentException("url == null");
        com.alibaba.dubbo.common.URL url = arg2;
        String extName = url.getParameter("proxy", "javassist");
        if (extName == null)
            throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.ProxyFactory) name from url(" + url.toString() + ") use keys([proxy])");
        com.alibaba.dubbo.rpc.ProxyFactory extension = (com.alibaba.dubbo.rpc.ProxyFactory) ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.ProxyFactory.class).getExtension(extName);
        return extension.getInvoker(arg0, arg1, arg2);
    }
}

    可以看到这个生成的类中,实现的getProxy方法获取的默认的实现类的key是javassist

    image

    所以ProxyFactory就是JavassistProxyFactory的实例

    3. JavassistProxyFactory.getInvoker创建invoke对象

    先弄一个wrapper对象,然后new出AbstractProxyInvoker(实现Invoker接口)对象,在实现doInvoke用wrapper对象去调用被代理的服务提供类的具体方法


    image

    2.又把invoke对象和serviceBean包装下

    image image

    3.protocol.export(wrapperInvoker)服务发布

    3.1 protocol对象

    image

    又是一记SPI

    image

    不用说肯定是一个生成的类

    获取到的Protocol实现类的key是registry,从url获取的

    image

    获取到的RegistryProtocol应该是这个类的实例


    image

    注意Protocol接口拓展的类有几个包装类,那么RegistryProtocol实例肯定会被这几个类的实例包装

    image

    循环中把RegistryProtocol实例传到构造函数中进行层层包装

    最终返回的是这个包装后的实例

    image

    3.2 protocol.export

    QosProtocolWrapper.export,现在url的协议是注册协议


    image

    再调到ProtocolFilterWrapper.export

    image

    再ProtocolListenerWrapper.export


    image

    最后调到RegistryProtocol.export

    image

    这里doLocalExport方法就是启动netty服务端的核心方法了

    后面的是注册服务到注册中心的逻辑

    4.RegistryProtocol.doLocalExport（invoker）启动netty服务

    4.1 获取export里的dubbo协议URL

    image

    先是获取原Regisry协议里的export参数值

    image

    是个dubbo协议,解码后

    dubbo://192.168.31.211:20880/com.lb.dubbo_api.service.UserService?anyhost=true
&application=dubbo-p
&bean.name=ServiceBean:com.lb.dubbo_api.service.UserService
&bind.ip=192.168.31.211&bind.port=20880
&dubbo=2.0.2&generic=false&interface=com.lb.dubbo_api.service.UserService
&methods=getUser&pid=58137&side=provider&timestamp=1625993018676

    创建Url对象,返回

    在外面有根据新创建的dubbo协议url和invoker对象创建一个静态代理对象,进行静态代理

    image

    4.2 RegistryProtocol.protocol.export()

    image
    4.2.1 RegistryProtocol.protocol对象(DubboProtocol)

    RegistryProtocol对象里还有个protocol对象
    在创建RegistryProtocol的依赖注入的时候,从SPI工厂获取并注入到该属性上的


    image

    又是一个动态生成的Protocol实现类

    image image

    由于方法传入的Invoke静态代理对象的URL是刚刚创建的dubbo协议,所以这里最终调到的会是DubboProtocol实例的export方法

    同样会被三个包装类包装

    image
    4.2.2 DubboProtocol.export

    一样的先走包装类的export方法,

    QosProtocolWrapper.export,现在url的协议不是注册协议了，而是dubbo协议
    image
    再调到ProtocolFilterWrapper.export
    image

    ==这里会创建invoker对象的过滤器链。==

    image

    根据provider分组和url的key：service.filter从spi工厂中获取Filter的拓展实例

    image

    这八个

    image

    把Invoker对象接到链表的尾端，并返回的是链表的头结点,以实现在调用invoke对象的方法时,进行层层过滤

    image
    再ProtocolListenerWrapper.export
    image

    这里会用SPI工厂获取ExporterListener的拓展类实例,用于对服务发布进行时间通知，默认没有,可以自己在本地文件中配置.进行拓展

    在ListenerExporterWrapper<T>的构造函数里会调用发布事件监听类的listener方法

    image
    最后调到DubboProtocol.export
    image

    5.启动netty服务 openServer(url)

    这里创建服务 createServer(url)会返回一个ExchangeServer对象,并做了缓存,key为ip加端口号,说明在同一个主机中,配置的tcp端口相同的多个服务发布，都只启动一次netty服务端！

    key : 192.168.31.211:20880
value : ExchangeServer
    image

    5.1 createServer(url)

    Exchangers.bind(url, requestHandler)

    requestHandler是一个内部对象

    image
    getExchanger(url).bind(url, handler);
    image
    new HeaderExchangeServer(Transporters.bind(url, new DecodeHandler(new HeaderExchangeHandler(handler))))
    image
    Transporters.bind
    image

    getTransporter()又是用SPI获取Transporter的拓展实例

    image

    最终获取到的是这个

    image
    在构造方法中创建netty服务
    image

    AbstractServer的构造方法
    获取codec编解码方式,超时时间,绑定的ip,端口
    ,然后调用子类的doOpen();

    image

    接下来就是用netty api开启服务端的代码了

    image

    至此,netty服务端已经创建,可以用来接受通信请求了

    相关文章

      网友评论

          本文标题：【dubbo源码】9. 服务提供方发布之netty服务端启动

          本文链接：https://www.haomeiwen.com/subject/iqokpltx.html

          延伸阅读

          深度阅读

          • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

          栏目导航

          热点阅读

          关于我们|服务条款|联系我们|【dubbo源码】9. 服务提供方发布之netty服务端启动|投稿指南|网站地图|RSS订阅|排版工具|手机版

          提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

          Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

          备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

          本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

          所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！