天天看點

spark學習-73-源代碼:Endpoint模型介紹(5)-Netty通訊小例子

spark學習-73-源代碼:Endpoint模型介紹(5)-Netty通訊小例子

想了解Rpc的通訊,先看看Netty的通訊小例子,有助于了解Spark的Rpc通訊原理

先看一個整體圖

靜态圖:

spark學習-73-源代碼:Endpoint模型介紹(5)-Netty通訊小例子

動态圖gif動畫:

spark學習-73-源代碼:Endpoint模型介紹(5)-Netty通訊小例子

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
           

繼續閱讀