lujunfa/dubbo-debug

dubbo源码解读

Apache Dubbo (incubating) Project

Dubbo源码思路梳理

• Dubbo SPI

  入口：ExtensionLoader.getExtension(String name)

• Adaptive

  入口：ExtensionLoader.getAdaptiveExtension()

• 服务导出export

  入口：ServiceConfig.export()

• 服务引入getProxy

  入口：ReferenceBean.get()

• 服务调用InvokerInvocationHandler.invoke

  入口：InvokerInvocationHandler.invoke(Object proxy, Method method, Object[] args)

• 服务降级MockClusterInvoker

  入口：MockClusterInvoker.invoker(Invocation invocation)

• Provider接收消息并响应结果

  入口：NettyServerHandler.channelRead(ChannelHandlerContext ctx, Object msg)

• Consumer接收Provider响应结果

  入口：NettyClientHandler.channelRead(ChannelHandlerContext ctx, Object msg)

• Dubbo调用异步变同步

  入口：DubboInvoker.doInvoke(final Invocation invocation)

• Dubbo协议编解码

  入口：NettyCodecAdapter.InternalEncoder/NettyCodecAdapter.InternalDecoder

Dubbo架构图

Dubbo调用链

1、proxy:服务引用（代理对象，调用InvokerInvocationHandler）

2、filter:服务降级 MockClusterInvoker

3、Cluster Invoker:服务容错 FailoverCluster

4、Directory: 服务目录 RegistryDirectory

5、LoadBalance: 负载均衡 RandomLoadbalance

6、Filter: 扩展点：监听、过滤、统计、异常、超时....

7、Protocol Invoker: 服务引用 DubboInvoker

8、Client: 网络通信 NettyClient

9、Codec: 编解码

10、Serizlization : 序列化

11、ThreadPool: 请求接收处理线程池 ExecutorService

12、Server:网络通信 NettyServer

13、Exporter: 维护服务端的远程接口Invoker DubboExporter

14、Filter: 扩展点：监听、过滤、统计、异常、超时

15、Invoker: 服务包装 AbstractProxyInvoker

16、Implement： 服务方法