前提知识
Akka是一套可扩展、弹性和快速的系统，为此Flink基于Akka实现了一套内部的RPC通信框架；为此先对Akka进行了解
Akka
Akka是使用Scala语言编写的库，基于Actor模型提供一个用于构建可扩展、弹性、快速响应的系统；并被应用到Flink中，基于Akka实现了集群组件之间的RPC通信框架
Actor模型
Actor模型是一个通用的并发编程模型，该模型独立维护隔离状态，基于消息传递实现异步通信，大致可以理解为三部分：
- 邮箱：每个
actor持有一个邮箱（mailbox），本质上是一个队列，用于存储消息。 - 行为：每个
actor可以发送消息至任何actor。 - 状态：每个
actor可以通过处理消息来更新内部状态，对于外部而言，actor的状态是隔离的状态，避免了并发环境下的锁和内存原子性问题
Akka系统组成
Akka系统核心包括两个组件：ActorSystem和Actor（使用demo可以参考这里）
- 只能通过
ActorSystem.actorOf和ActorContext.actorOf创建Actor，不允许直接创建Actor - 只能通过
ActorRef发送消息与Actor通信
Flink的RPC框架
Flink的RPC框架基于Akka实现，其中Flink集群中实现RPC通信节点功能主要有：Dispacher，ResourceManager，TaskManager，TaskManager；这些节点分别继承了RpcEndPoint抽象类，并在实现类中初始化各自RpcServer（类似于Actor）来提供本地和远程代码请求；RpcServer的创建和启动都是由RpcService（主要实现AkkaRpcService，封装ActorSystem）来完成，此外一个RpcService可以创建多个RpcServer；详细的调用链路图如下所示
RpcEndPoint
RpcEndPoint代表RPC组件的端点，需要实现RPC通信的都需要实现RpcEndPoint，主要成员变量如下
-
rpcServer用于完成本地和远程调用能力 -
rpcService是的rpcService引用，rpcService可用于启动/关闭当前rpcServer（rpcServer中封装了ActorRef） -
mainThreadExecutor封装了MainThreadExecutable接口（RpcServer接口继承了MainThreadExecutable），用于实现本地调用 -
endpointId用于唯一标识当前的RpcEndPoint
AkkaRpcService
AkkaRpcService负责创建启动Flink集群中RpcEndPoint组件的RpcServer，且AkkaRPCService在集群创建时就会启动完毕；UML类图如下所示
属性：
actorSystem是引用Akka的ActorSystem，可以用于启动、停止actor（启动、停止rpcServer）actors用于存储创建的RpcEndPoint的实现类（类中会封装actor）
方法：
startServer()用于启动RpcServer，启动完成后这能对外提供服务connect()用于连接远端RpcEndpoint，并返回调用方RpcGateway接口的代理类，获得调用外部的能力
RpcServer
RpcServer是一个接口类，该类实现类有AkkaInvocationHandler和FencedAkkaInvocationHandler；AkkaInvocationHandler中封装有ActorRef，并通过动态代理技术（InvocationHandler）实现远程和本地方法调用
RpcServer中RpcGateWay、MainThreadExecutable和StartStoppable接口的方法，都会通过代理实现；方法中会查看调用方法实现类，来判断本地调用还是通过RefActor发送远程RPC调用
小结
Flink中每个需要使用RPC的组件都会实现RpcEndpoint，每个RpcEndpoin中都会包含两个属性RpcService和RpcServer；其中RpcService封装了AkkaSystem，RpcServer封装了ActorRef，最终通过动态代理技术实现方法的调用
参考资料：
书籍：Flink设计与实现
博客：https://cloud.tencent.com/developer/news/698662
