fix:处理心跳响应失败后:停止发送心跳消息,并启动重新上线
This commit is contained in:
parent
67fa0bc1ba
commit
74708b505e
@ -16,21 +16,22 @@ class UdpHeartBeatHandler extends ScpMessageBaseHandle
|
|||||||
|
|
||||||
@override
|
@override
|
||||||
void handleResp(ScpMessage scpMessage) {
|
void handleResp(ScpMessage scpMessage) {
|
||||||
// TODO: 收到心跳消息回复
|
|
||||||
final HeartbeatResponse heartbeatResponse = scpMessage.Payload;
|
final HeartbeatResponse heartbeatResponse = scpMessage.Payload;
|
||||||
final statusCode = heartbeatResponse.statusCode;
|
final statusCode = heartbeatResponse.statusCode;
|
||||||
if (statusCode != null &&
|
if (statusCode != null &&
|
||||||
statusCode != PayloadTypeConstant.heartHeatSuccessResponse) {
|
statusCode != PayloadTypeConstant.heartHeatSuccessResponse) {
|
||||||
// 停止发送心跳
|
// 心跳回复失败,停止发送心跳
|
||||||
startChartManage.stopHeartbeat();
|
startChartManage.stopHeartbeat();
|
||||||
// 心跳响应失败,重新上线
|
// 心跳响应失败,重新上线
|
||||||
startChartManage.isOnlineStartChartServer = false;
|
startChartManage.isOnlineStartChartServer = false;
|
||||||
startChartManage.reStartOnlineStartChartServer();
|
startChartManage.reStartOnlineStartChartServer();
|
||||||
|
} else {
|
||||||
|
// 修改间隔为返回的心跳间隔
|
||||||
|
startChartManage.heartbeatIntervalTime =
|
||||||
|
heartbeatResponse.nextPingTime ?? 1;
|
||||||
|
// 修改完间隔之后重新启动发送心跳
|
||||||
|
startChartManage.reStartHeartBeat();
|
||||||
}
|
}
|
||||||
startChartManage.heartbeatIntervalTime =
|
|
||||||
heartbeatResponse.nextPingTime ?? 1;
|
|
||||||
// 修改完间隔之后重新启动发送心跳
|
|
||||||
startChartManage.reStartHeartBeat();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user