猜测心跳包机制的核心逻辑-拓冰建站

一、心跳包的作用

定时发送一个数据包，等待对方回复。

如果对方在规定时间内回复，说明连接正常；否则出现异常或者收不到回复，说明工作不正常。

二、主要逻辑

(一)定义心跳包的格式

1、发送

1字节类型(值为10)
2字节标识码(值为0xAABB)

2、回复

1字节类型(值为1)
2字节代号(默认为0xFF)

(二)定时发送心跳包

// 记录超时次数
int k = 0；
try{
oo:
while(true){
k = 0;
// 输出心跳包给对方
out.write(Util.getHeart());
// 在3次超时内读取
while(k < 3){
try{
// 设置超时时间为2秒
sock.setSoTimeout(2000);
// 读取回复
Data d = in.read();
// 如果是正确回复，跳出
if(ok(d)){
break;
} else {
// 跳出外层循环
break oo;
}
} catch(SocketException e){
// 超时，次数加一
k++;
}
}
// 如果等于3次，跳出循环
if(k == 3){
break;
}
// 休眠10秒
Thread.sleep(10000);
}
} catch(SocketException e){
}
// 打印提醒连接中断
System.out.print("失去连接");
// 其他处理，移除服务，通知运维

(三)收到心跳包，回复

while(true){
// 读取一个数据包
Data d = in.get();
// 如果类型是10，说明为心跳包
if(d.type() == 10){
// 对心跳包回复
out.write(1);
out.write(00);
out.write(0xFF);
out.flush();
}
}