在spark 源码分析之五 -- Spark内置RPC机制剖析之一创建NettyRpcEnv中,剖析了NettyRpcEnv的创建过程。
Dispatcher、NettyStreamManager、TransportContext、TransportClientFactory、TransportServer、Outbox、Inbox等等基础的知识都已经在前面剖析过了。
可以参照如下文章做进一步了解。
p.p1 { margin: 0.0px 0.0px 0.0px 0.0px; font: 12.0px "Helvetica Neue" }
span.s1 { text-decoration: underline }
span.s2 { font: 12.0px ".PingFang SC"; text-decoration: underline }
spark 源码分析之五 -- Spark内置RPC机制剖析之一创建NettyRpcEnv
spark 源码分析之六 -- Spark内置RPC机制剖析之二Dispatcher和Inbox、Outbox剖析
spark 源码分析之七 -- Spark内置RPC机制剖析之三RpcEndPoint和RpcEndPointRef剖析
spark 源码分析之八 -- Spark内置RPC机制剖析之四TransportContext和TransportClientFactory剖析
spark 源码分析之九 -- Spark内置RPC机制剖析之五StreamManager和RpcHandler
spark 源码分析之十 -- Spark内置RPC机制剖析之六TransportResponseHandler、TransportRequestHandler和TransportChannelHandler剖析
spark 源码分析之十一 -- Spark内置RPC机制剖析之七TransportClient和TransportServer剖析
spark rpc 整体架构图如下(自己画的