天天看点

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
           

继续阅读