一、概述

Worker 通过发送心跳实现的汇报运行状态

二、源码

当 worker 向 Master 注册成功后会接收到 Master 回复的 RegisteredWorker 消息,Worker 使用 handleRegisterResponse 方法处理 RegisteredWorker 消息时,将会向 forworaMessageScheduler 提交以 HEARTBEAT_MILLIS 作为间隔向 Worker 自身发送 SendHeartbeat 消息的定时任务。Worker 的 receive 方法实现了对 SendHeartbeat 消息的处理

如果 connected 为 true,则调用 $sendToMaster$ 方法,向 Master 发送 Heartbeat 消息(此消息将携带Worker 的 ID 和 Worker 的 RpcEndpointRef)

三、总结