想理解Rpc的通讯,先看看Netty的通讯小例子,有助于理解Spark的Rpc通讯原理
先看一个整体图
静态图:
动态图gif动画:
Spark2.2以后统一了通讯方式,全部是netty方式,根据源码的思路用scala写了一个Demo级别的netty通信
package com.spark.netty
import io.netty.bootstrap.ServerBootstrap
import io.netty.channel.ChannelInitializer
import io.netty.channel.nio.NioEventLoopGroup
import io.netty.channel.socket.SocketChannel
import io.netty.channel.socket.nio.N