博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
dubbo learn
阅读量:5251 次
发布时间:2019-06-14

本文共 3971 字,大约阅读时间需要 13 分钟。

====================server=============================================

ExchangeHandlerAdapter

Exchanger

HeaderExchange
HeaderExchangeServer

org.apache.dubbo.registry.integration.RegistryProtocol#export

org.apache.dubbo.registry.integration.RegistryProtocol#doLocalExport

org.apache.dubbo.rpc.protocol.ProtocolListenerWrapper#export

org.apache.dubbo.rpc.protocol.ProtocolFilterWrapper#export

org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#export

org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#openServer

org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#createServer

org.apache.dubbo.remoting.exchange.Exchangers#bind(org.apache.dubbo.common.URL, org.apache.dubbo.remoting.exchange.ExchangeHandler)

return getExchanger(url).bind(url, handler);

org.apache.dubbo.remoting.exchange.support.header.HeaderExchanger#bind

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

HeaderExchangeHandler

DubboPtotocol

DecodeHandler

HeaderExchangeHandler
Transporter
NettyTransporter
-> NettyServer

============================================org.apache.dubbo.remoting.transport.dispatcher.ChannelHandlers#wrap

new MultiMessageHandler(new HeartbeatHandler(ExtensionLoader.getExtensionLoader(Dispatcher.class)

.getAdaptiveExtension().dispatch(handler, url)));

AllChannelHandler ==== ExtensionLoader.getExtensionLoader(Dispatcher.class)

.getAdaptiveExtension().dispatch(handler, url)
DecodeHandler
HeartbeatHandler
AllChannelHandler

MultiMessageHandler

HeartbeatHandler
NettyServer
MultiMessageHandler
org.apache.dubbo.remoting.transport.AbstractServer#doOpen
org.apache.dubbo.remoting.transport.netty4.NettyServer#doOpen
====================client=============================================
ReferenceCountExchangeClient
org.apache.dubbo.config.ReferenceConfig#get
org.apache.dubbo.config.ReferenceConfig#init
org.apache.dubbo.config.ReferenceConfig#createProxy
org.apache.dubbo.rpc.protocol.ProtocolListenerWrapper#refer
org.apache.dubbo.rpc.protocol.ProtocolFilterWrapper#refer
org.apache.dubbo.registry.integration.RegistryProtocol#refer
org.apache.dubbo.registry.integration.RegistryProtocol#doRefer
org.apache.dubbo.registry.zookeeper.ZookeeperRegistry#doSubscribe
org.apache.dubbo.registry.support.AbstractRegistry#notify(org.apache.dubbo.common.URL, org.apache.dubbo.registry.NotifyListener, java.util.List<org.apache.dubbo.common.URL>)
org.apache.dubbo.registry.integration.RegistryDirectory#notify
org.apache.dubbo.registry.integration.RegistryDirectory#refreshOverrideAndInvoker
org.apache.dubbo.registry.integration.RegistryDirectory#refreshInvoker
org.apache.dubbo.registry.integration.RegistryDirectory#toInvokers
org.apache.dubbo.rpc.protocol.ProtocolFilterWrapper#refer
org.apache.dubbo.rpc.protocol.ProtocolFilterWrapper#buildInvokerChain
org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#refer
org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#getClients
org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#getSharedClient
org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#buildReferenceCountExchangeClientList
org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#buildReferenceCountExchangeClient
org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#initClient
心跳,断线重连
org.apache.dubbo.remoting.exchange.support.header.HeaderExchangeClient#HeaderExchangeClient
org.apache.dubbo.rpc.cluster.support.FailoverClusterInvoker#doInvoke
org.apache.dubbo.rpc.protocol.InvokerWrapper#invoke
org.apache.dubbo.rpc.listener.ListenerInvokerWrapper#invoke
org.apache.dubbo.rpc.protocol.AbstractInvoker#invoke
org.apache.dubbo.rpc.protocol.dubbo.DubboInvoker#doInvoke
org.apache.dubbo.rpc.protocol.dubbo.ReferenceCountExchangeClient#request(java.lang.Object, int)
org.apache.dubbo.remoting.exchange.support.header.HeaderExchangeClient#request(java.lang.Object, int)
org.apache.dubbo.remoting.exchange.support.header.HeaderExchangeChannel#request(java.lang.Object, int)

转载于:https://www.cnblogs.com/parkdifferent/p/10952573.html

你可能感兴趣的文章
Go 语言的基本数据类型
查看>>
数据库建立索引加快查询
查看>>
[codevs 2235]机票打折
查看>>
微信智能开放平台
查看>>
C# ArcgisEngine开发中,对一个图层进行过滤,只显示符合条件的要素
查看>>
ArcGIS Engine 中的绘制与编辑
查看>>
Oracle--通配符、Escape转义字符、模糊查询语句
查看>>
子网划分讲解及练习(一)
查看>>
Python 装饰器
查看>>
c# 文件笔记
查看>>
Vue 自定义指令
查看>>
帆软 控件内容 清除
查看>>
第一页 - 工具的使用(webstorm)
查看>>
.net static 变量
查看>>
The Number of set-hdu-3006
查看>>
[设计模式]适配器模式与外观模式
查看>>
自定义分页控件,修改自AspNetForums.Controls.Pager
查看>>
ssh 免签登录 亲测可以
查看>>
Linux 进程资源用量监控和按用户设置进程限制
查看>>
IE浏览器整页截屏程序(二)
查看>>