美文网首页
【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

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

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