Dubbo源码之服务调用
2019-12-05 本文已影响0人
spilledyear
在应用启用的时候, 会为消费方创建一个代理对象,即 引用Bean
,该 引用Bean
内部只持有一个InvokerInvocationHandler
对象,而该 InvokerInvocationHandler
对象最终指向MockClusterInvoker
对象
当我们通过 @Reference 注解注入一个Bean并调用该Bean方法时,实际上是执行MockClusterInvoker#invoke
方法
MockClusterInvoker
MockClusterInvoker
在RegistryProtocol#doRefer
中创建
Invoker invoker = cluster.join(directory);
Cluster$Adaptive#join =>
MockClusterWrapper#join =>
return MockClusterInvoker(directory, FailoverCluster#join => new FailoverClusterInvoker)
调用链
消费方代理类 ->
InvokerInvocationHandler#invoke ->
MockClusterInvoker#invoke ->
AbstractClusterInvoker#invoke【获取LoadBalance】 ->
FailoverClusterInvoker#doInvoke【处理重试次数】 ->
ProtocolFilterWrapper#invoke【处理Filter链路】 ->
AbstractInvoker#invoke【设置Attachments参数】 ->
DubboInvoker#doInvoke【Exchange交接层】 ->
ReferenceCountExchangeClient#request ->
HeaderExchangeClient#request ->
HeaderExchangeChannel#request【return CompletableFuture】 ->
AbstractPeer#send ->
AbstractClient#send ->
NettyChannel#send ->
Channel#writeAndFlush【发消息给服务端】