想了解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