Flink RPC
主要抽象类
RpcEndpoint: 具体服务的尸体抽象,线程安全类
RpcGateway: 用于远程调用的代理接口,提供对应RpcEndpoint
的地址方法
RpcService: RpcEndpoint
的运行时环境,并提供异步任务或周期性任务调度
RpcServer: RpcEndpoint
自身的代理对象
FencedRpcEndpoint & FencedRpcGateway: 在调用RPC
方法时需提供token
信息
本博客所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自 Asura7969 Blog!