dubbo请求调用过程分析-阿里云开发者社区

开发者社区> javahongxi> 正文

dubbo请求调用过程分析

简介:
+关注继续查看

服务消费方发起请求

 

当服务的消费方引用了某远程服务,服务的应用方在spring的配置实例如下:

 

<dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService" />

 

demoService实例其实是代理工厂生产的代理对象(大家可以参考代理那部分生成的伪代码),在代码中调用demoService.sayHello(“world!”)时,

 

1.      将方法名方法参数传入InvokerInvocationHandler的invoke方

 

对于Object中的方法toString, hashCode, equals直接调用invoker的对应方法,

 

这里对于Object的方法需要被远程调用吗?调用了是不是报错比默认处理更好呢??

 

远程调用层是以Invocation, Result为中心, 这里根据要调用的方法以及传入的参数构建RpcInvocation对象,作为Invoker的入参

 

2.      MockClusterInvoker根据参数提供了三种调用策略

 

不需要mock, 直接调用FailoverClusterInvoker

 

强制mock,调用mock

 

先调FailoverClusterInvoker,调用失败在mock、

 

3.      FailoverClusterInvoker默认调用策略

 

通过目录服务查找到所有订阅的服务提供者的Invoker对象

 

路由服务根据策略来过滤选择调用的Invokers

 

通过负载均衡策略LoadBalance来选择一个Invoker

 

4.      执行选择的Invoker.inoker(invocation)

 

经过监听器链,默认没有

 

经过过滤器链,内置实现了很多

 

执行到远程调用的DubboInvoker

 

5.      DubboInvoker

 

根据url 也就是根据服务提供者的长连接,这里封装成交互层对象ExchangeClient供这里调用

 

判断远程调用类型同步,异步还是oneway模式

 

ExchangeClient发起远程调用,底层remoting不在这里描述了

 

获取调用结果:

 

        Oneway返回空RpcResult

 

        异步,直接返回空RpcResult, ResponseFuture回调

 

        同步, ResponseFuture模式同步转异步,等待响应返回

 

 

 

 

 

服务提供方接收调用请求

 

同样我们也是rpc调用层DubboProtocol层开始分析,对于通信层remoting的数据接收反序列等等过程不做分析。

 

DubboProtocol的requestHandler是ExchangeHandler的实现,是remoting层接收数据后的回调。

 

requestHandler.replay方法接收请求消息,这里只处理远程调用消息Invocation。

 

1.      通过Invocation获取服务名和端口组成serviceKey=com.alibaba.dubbo.demo.DemoService:20880, 从DubboProtocol的exproterMap中获取暴露服务的DubboExporter, 在从dubboExporter 获取invoker返回

 

2.      经过过滤器链

 

3.      经过监听器链

 

4.      到达执行真正调用的invoker, 这个invoker由代理工厂ProxyFactory.getInvoker(demoService, DemoService.class, registryUrl)创建,具体请看代理那部分介绍。

 

调用demoService实例方法,将结果封装成RpcResult返回

 

5.      交换层构建Response,通过Remoting层编码传输将结果响应给调用方

 

 

 

 

 

服务消费方发起远程调用的底层通信

 

 

服务提供方接收请求并响应的底层通信

 

一:provider提供方

 



 

ClassPathXmlApplicationContext <init>(构造方法)

 

-> ClassPathXmlApplicationContext refresh()

 

-> ClassPathXmlApplicationContext finishRefresh()

 

-> AbstractApplicationContext publishEvent()

 

-> ServiceBean onApplicationEvent()

 

-> ServiceConfig doExport()

 

#构造dubbo对象 application provider module protocol registry service reference consume等

 

 

 

-> ServiceConfig doExportUrls #导出URL,获取注册中心RegistryConfig

 

#注册中心:registry://10.199.101.228:2181/com.alibaba.dubbo.registry.RegistryService?application=demo&backup=10.199.101.227:2181,10.199.101.229:2181&dubbo=2.4.9&pid=8045&registry=zookeeper&timestamp=1491546077803

 

 

 

-> ServiceConfig doExportUrlsFor1Protocol()

 

#需要暴露 dubbo://10.199.66.242:20880/com.unj.dubbotest.provider.DemoService?anyhost=true&application=dubbo_demo_provider&dubbo=2.4.9&interface=com.unj.dubbotest.provider.DemoService&methods=sayHello,getUsers&pid=8045&revision=0.0.1&side=provider&timestamp=1491546674441&version=0.0.1

 

 

 

-> ServiceConfig exportLocal()

 

-> Exporter<?> exporter = protocol.export(proxyFactory.getInvoker(ref, (Class) interfaceClass, local));

 

#暴露Invoker<XxxService>调用服务代理类

 

 

 

-> proxyFactory.getInvoker(ref, (Class) interfaceClass, local)

 

#返回 AbstractProxyInvoker代理ProxyInvoker<XxxService>

 

public abstract class AbstractProxyInvoker<T> implements Invoker<T> {

 

private final T proxy; //代理目标实例 XxxServiceImpl

 

private final Class<T> type;

 

private final URL url;

 

}

 

-> InvokerInvocationHandler.invoke()

 

#invoker.invoke(new RpcInvocation(method, args)).recreate();

 

 

 

-> DubboProtocol export(Invoker<T> invoker)

 

# 返回暴露Exporter<T>

 

public class DubboExporter<T> extends AbstractExporter<T> {

 

private final String key; //com.unj.dubbotest.provider.DemoService:0.0.1:20880

 

private final Map<String, Exporter<?>> exporterMap;

 

public DubboExporter(Invoker<T> invoker, String key, Map<String, Exporter<?>> exporterMap){

 

super(invoker);

 

this.key = key;

 

this.exporterMap = exporterMap;

 

}

 

 

 

-> DubboProtocol openServer(url)

 

#url dubbo://10.199.66.242:20880/com.unj.dubbotest.provider.DemoService?anyhost=true&application=dubbo_demo&dubbo=2.4.9&interface=com.unj.dubbotest.provider.DemoService&methods=sayHello,getUsers&pid=8045&revision=0.0.1&side=provider&timestamp=1491546674441&version=0.0.

 

#serverMap.put(key, createServer(url)); key:10.199.66.242:20880 value:ExchangeServer

 

 

 

-> DubboProtocol createServer(URL url)

 

#返回HeaderExchangeServer,添加参数列表 如心跳,心跳时间

 

-> Exchangers.bind(url, requestHandler);

 

#返回HeaderExchangeServer,getTransporter()获取的实例来源于配置,默认返回一个NettyTransporter

 

-> HeaderExchangeServer.bind(URL url, ExchangeHandler handler);

 

 

 

-> HeaderExchangeServer(Transporters.bind(url, new DecodeHandler(new HeaderExchangeHandler(handler))));

 

#HeaderExchangeServer包装实例NettyServer

 

 

 

-> NettyTransporter.bind(URL url, ChannelHandler listener)

 

#return new NettyServer(url, listener)

 

 

 

-> NettyServer.doOpen();

 

#打开socket监听端口准备接收消息

 

#ServerBootstrap bind(getBindAddress())绑定地址端口

 

#RpcInvocation 具体类名、方法名、调用参数

 

#DubboInvoker – 执行具体的远程调用,包含初始化信息如client

 

#Protocol – 服务地址的发布和订阅

 

#Exporter – 暴露服务的引用,或取消暴露

 

 

 

二:consume(消费方):

 

->ReferenceConfig.init

 

#consume端启动初始化

 

->DubboProtocol.refer

 

#根据参数url,接口等构建Invoker

 

->JavassistProxyFactory.getProxy(Invoker<T> invoker, Class<?>[] interfaces)

 

#构建代理对象Proxy.getProxy(interfaces).newInstance(new InvokerInvocationHandler(invoker));

 

 

 

->DemoService.say(String hello);#真正调用时候

 

->InvokerInvocationHandler.invoke(Object proxy, Method method, Object[] args)

 

#invoker.invoke(new RpcInvocation(method, args)).recreate();RpcInvocation包装参数方法名

 

->DubboInvoker.doInovke(final Invocation invocation)

 

#统一代理调用

 

->ExchangeClient.send(invocation, isSent);

 

->HeaderExchangeChannel.request(Object request, int timeout)

 

->NettyChannel.send(Object message, boolean sent)

 

 

 

三:dubbo 底层通讯:NettyClient <-- 异步NIO传输 socket监听-> NettyServer

 

 

 

四:consume --> provider 调用过程:

 

-> NettyServer->NettyHandler.messageReceived #接收消息处理器

 

-> MultiMessageHandler->HeartbeatHandler->AllChannelHandler->DecodeHandler->HeaderExchangeHandler->DubboProtocol$requestHandler

 

#NettyServer启动时候绑定MultiMessageHandler

 

#DubboProtocol.getServers() 检索serverMap获取Exporter<?>

 

#DubboProtocol.getServers() 检索serverMap获取ExchangeServer

 

-> ExchangeHandlerAdapter.reply

 

#真正获取Invoker,将传入message 转换 invocation

 

-> invoker.invoke(invocation)

 

-> JavassistProxyFactory$AbstractProxyInvoker.doInvoke

 

#服务端Invoker代理 AbstractProxyInvoker调用目标引用service

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Dubbo服务消费者调用过程
上图是服务消费的主过程: 首先通过ReferenceConfig类的private void init()方法会先检查初始化所有的配置信息后,调用private T createProxy(Map map)创建代理,消费者最终得到的是服务的代理, 在createProxy接着调用Protocol接口实现的 Invoker refer(Class type, URL url)方法生成Invoker实例(如上图中的红色部分),这是服务消费的关键。
955 0
分析、调试内存泄漏的应用程序
项目组的一个window service (7×24)出现 OutOfMemory异常,一直找不到原因。尝试过各种方法。 1、去掉方法和类中 static ,以便资源释放; 2、将无线等待的“死”循环while(true){...} 更改为 心跳触发; 3、将核心类实现 IDisposiable 接口,以便更好释放资源; 等等,其他很多优化的操作,均不见效。
679 0
阿里云服务器怎么设置密码?怎么停机?怎么重启服务器?
如果在创建实例时没有设置密码,或者密码丢失,您可以在控制台上重新设置实例的登录密码。本文仅描述如何在 ECS 管理控制台上修改实例登录密码。
8028 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
9792 0
源码分析Dubbo服务消费端启动流程
通过前面文章详解,我们知道Dubbo服务消费者标签dubbo:reference最终会在Spring容器中创建一个对应的ReferenceBean实例,而ReferenceBean实现了Spring生命周期接口:InitializingBean,接下来应该看一下其afterPropertiesSet方法的实现。
1466 0
Dubbo 源码分析 - 集群容错之 Directory
1. 简介 前面文章分析了服务的导出与引用过程,从本篇文章开始,我将开始分析 Dubbo 集群容错方面的源码。这部分源码包含四个部分,分别是服务目录 Directory、服务路由 Router、集群 Cluster 和负载均衡 LoadBalance。
1018 0
+关注
javahongxi
京东技术 www.toutiao.im
33
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载