猜测心跳包机制的核心逻辑
一、心跳包的作用
定时发送一个数据包，等待对方回复。
如果对方在规定时间内回复，说明连接正常；否则出现异常或者收不到回复，说明工作不正常。
二、主要逻辑
(一)定义心跳包的格式
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();
}
}
三、其他情况
1、如果只是监听状态的TCP连接中断，而服务进程还在正常运行，那么此时把服务移除会错误处理。
2、解决思路
再次重连测试，只有超过1次重连后，依然无法连接，就说明服务器出现死机，可以通知运维处理或者从服务列表里移除。