DUBBO 源码分析(3): server 端消息处理过程

AbstractProxyInvoker

received();

ChannelEventRunnable

[ProtocolFilterWrapper + ???Filter] *

AbstractPeer

invoke();

ProtocolFilterWrapper

HeartbeatHandler

doInvoke();

DubboProtocol

???method()

channelRead();

1. 分析IO 线程和业务代码线程解耦.(Dispatcher: AllDispatcher)2. 剖析 netty server 的 pipeline 构成; invoker 的调用链路.

Dubbo线程组(Business)

MultiMessageHandler

NettyServerHandler

HeaderExchangeHandler

filter

EchoFilter

run()

Netty Worker Group线程组(IO)

???ServiceImpl

NettyServer

DUBBO 源码分析(3): server 端消息处理过程

execute

reply();

DecodeHandler

InvokerWrapper

AllChannelHandler