flink源码分析之功能组件(六)-心跳组件

2023-12-14 13:04:06

简介

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

     本文解释心跳组件，心跳组件监听组件间连接活性，超时触发重连，保证连接有效性；断连后通知并释放资源，心跳可以带荷载，作为组件间数据交换的方式

     心跳组件依赖rpc组件实现通讯，rpc的解释可参考本系列flink源码分析之功能组件(三)-rpc组件

心跳组件

    心跳组件通过定时心跳，监视组件被管理组件的存活，心跳可携带载荷信息，实现轻量级实时/准实时的信息交换

    心跳组件依赖rpc组件实现通讯服务，关于rpc组件参考相关的分析章节

    心跳组件有两个角色：sender和receiver。检测动作是Sender主动发起请求，Reciver给Sender回一个心跳，在这一个来回sender和receiver相互检测。

文章来源:https://blog.csdn.net/szlhj/article/details/134696367
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。