dubbo服务调用流程图
2022-03-14 23:27:38 2 举报dubbo服务调用流程图
作者其他创作
大纲/内容
DelegateProviderMetaDataInvoker
DubboExporter
HeaderExchangeHandler
服务消费者
RegistryDirectory
ExchangeHandlerAdapter
服务实现类
发送请求(invokation)
MonitorFilter
NettyClientHandler
执行DefaultFuture
TimeoutFilter
AbstractProxyInvoker
AllChannelHandler
AbstractClient
MultiMessageHandler
ChannelEventRunnabele
服务三invoke
AbstractPeer
ExecutorServer
发送响应(AllResponse)
LoadBalance
ContextFilter
handleResponse
received
handleRequest
DubboInvoker
GenericFilter
HeartBeatHandler
RouterChain
CompletionStage执行完成后
ListenerInvokerWrapper
默认使用fixed线程池，启动了200个线程
启动了重连和心跳的定时任务 startReconnectTask(url); startHeartBeatTask(url);
HeaderExchangeChannel
服务二invoke
NioSocketChannel
received-Object msg
服务四invoke
receive-request
MultiMessage消息处理
DecodeHandler
FailoverClusterInvoker
received-Object msg
ProtocalFilterWrapper$callbackRegistrationInvoker
MockClusterInvoker
EchoFilter
将连接请求和数据请求交给线程池
CallbackRegistrationInvoker
AsyncToSyncInvoker
ExceptionFilter
NettyChannel
NettyServer extend AbstractPeer
FutureFilter
服务接口的代理对象
AbstractInvoker
recieved-Response
NettyServerHander
ClassLoaderFilter
HeaderExchangeClient
received -Object msg
NettyClient extend AbstractPeer
TraceFiletr
开启了超时检测的定时任务TimeoutCheckTask
返回结果
ReferenceCountExchangeClient
服务一invoke
处理心跳
服务提供者
ConsumerContextFilter
InvokerWrapper
接收到的数据转换为RpcInvocate或者RpcResult
ChannelEventRunnable
默认使用cached线程池
0 条评论
下一页
