Dubbo源码之服务调用

在应用启用的时候, 会为消费方创建一个代理对象,即 引用Bean ,该 引用Bean 内部只持有一个InvokerInvocationHandler对象,而该 InvokerInvocationHandler对象最终指向MockClusterInvoker对象

当我们通过 @Reference 注解注入一个Bean并调用该Bean方法时,实际上是执行MockClusterInvoker#invoke方法

MockClusterInvoker

MockClusterInvokerRegistryProtocol#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【发消息给服务端】
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容