服务消费方发起请求

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

<dubbo:referenceid="demoService"interface="com.alibaba.dubbo.demo.DemoServ ice" />

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，客户端DubboInvoker

dubbo 请求调用过程分析相关推荐

dubbo请求调用过程分析
服务消费方发起请求当服务的消费方引用了某远程服务,服务的应用方在spring的配置实例如下: <dubbo:reference id="demoService" inter ...
限时购校验小工具dubbo异步调用实现限
本文来自网易云社区作者:张伟背景限时购是网易考拉目前比较常用的促销形式,但是前期创建一个限时购活动时需要各个BU按照指定的Excel格式进行选品提报,为了保证提报数据准确,运营需要人肉校验很多信 ...
Soul 网关源码阅读（四）Dubbo请求概览
Soul 网关源码阅读(四)Dubbo请求概览简介本次启动一个dubbo服务示例,初步探索Soul网关源码的Dubbo请求处理流程示例运行环境配置在Soul源码clone下来 ...
Dubbo服务调用过程流程图
Dubbo服务调用过程主要有两个阶段 1.服务消费方发起调用请求,并处理结果 2.服务提供方接收请求,并返回处理结果第一阶段消费者客户端发起rpc请求这个阶段会将请求数据发送到服务提供者,并且在 ...
面试杀手锏之Dubbo服务调用过程
点赞再看,养成习惯,微信搜一搜[三太子敖丙]关注这个喜欢写情怀的程序员. 本文 GitHub https://github.com/JavaFamily 已收录,有一线大厂面试完整考点.资料以及我的系 ...
dubbo的调用原理及泛化调用
简单介绍 dubbo是阿里开源出来的一个rpc框架,主要是用于微服务分布式项目的远程调用,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现,下面是调用的原理图: ...
Dubbo技术知识总结之六——Dubbo服务调用链路
接上篇<Dubbo技术知识总结之五--Dubbo远程调用> 六. Dubbo 服务调用链路参考地址:<Dubbo中服务消费者和服务提供者之间的请求和响应过程> 6.1 初始化 ...
dubbo+zipkin调用链监控
dubbo+zipkin调用链监控原文地址:http://www.cnblogs.com/ASPNET2008/p/6709900.html 分布式环境下,对于线上出现问题往往比单体应用要复杂的多, ...
Dubbo 泛化调用
dubbo 泛化调用含义使用含义官方说的文邹邹的,不太懂.按我的理解,就是可以通过指定某个接口的全限定名和方法名,调用远程有提供该方法的服务. 通过上篇文章Dubbo入门,我们可以知道作为服务 ...

dubbo 请求调用过程分析

服务消费方发起请求

服务提供方接收调用请求

dubbo 请求调用过程分析相关推荐

最新文章

热门文章