简介

     本系列是flink源码分析的第二个系列，上一个《flink源码分析之集群与资源》分析集群与资源，本系列分析功能组件，kubeclient，rpc，心跳，高可用，slotpool，rest，metrics，future。

     本文解释rpc组件，rpc组件用于个核心组件，包括作业管理器，资源管理器和任务管理器之间的通讯。

rpc组件

core包定义rpc基类/抽象类，flink rpc组件是使用akka框架实现，akka框架是基于actor模型的并发框架，本文不深入解释akka和rpc的akka实现的原理

rpc-core

rpc-core定义rpc组件的基类/抽象类

1）RpcEndpoint中提供了集群RPC组件的基本实现，所有需要实现RPC服务的组件都会继承RpcEndpoint抽象类。RpcEndpoint中包含了endpointId，用于唯一标记当前的RPC节点。RpcEndpoint借助RpcService启动内部RpcServer，之后通过RpcServer完成本地和远程线程执行。

2）FencedRpc