netty中有比较完善的心跳机制，（在基础server版本基础上【netty基础--基本收发】）添加少量代码即可实现对心跳的监测和处理。
1 server端channel中加入心跳处理机制
// IdleStateHandler参数顺序readerIdleTimeSeconds, writerIdleTimeSeconds, allIdleTimeSeconds
ch.pipeline().addLast("heartbeat",new IdleStateHandler(5, 0, 0, TimeUnit.SECONDS));
下方有IdleStateHandler的数据结构。
2 在channelhandler中重写用户触发事件
@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt)
throws Exception {
if (evt instanceof IdleStateEvent) {
IdleStateEvent event = (IdleStateEvent) evt;
String type = "";
if (event.state() == IdleState.READER_IDLE) {
type = "read idle";
} /*else if (event.state() == IdleState.WRITER_IDLE) {
type = "write idle";
} else if (event.state() == IdleState.ALL_IDLE) {
type = "all idle";
}*/
// ctx.writeAndFlush(HEARTBEAT_SEQUENCE.duplicate()).addListener(
// ChannelFutureListener.CLOSE_ON_FAILURE);
System.out.println( ctx.channel().remoteAddress()+"超时类型：" + type);
ctx.channel().close();
} else {
super.userEventTriggered(ctx, evt);
}
}
修改了以上两个部分之后，运行server程序，使用packet sender建立两个客户端，一个以4秒间隔重发，另一个以6秒间隔重发。
可以看到6秒间隔重发的客户端发送一次之后就触发了服务器的timeout，客户端被断开连接。
4秒间隔的客户端可以保持连接。
3 IdleStateHandler数据结构
public IdleStateHandler(
Timer timer,
int readerIdleTimeSeconds,
int writerIdleTimeSeconds,
int allIdleTimeSeconds) {
this(timer, readerIdleTimeSeconds, writerIdleTimeSeconds, allIdleTimeSeconds, TimeUnit.SECONDS);
}
4 ctx.close ctx.channel.close差异
ctx.channel.close会从channel的tail开始关闭所有的channel。
ctx.close在存在多个channel时，会关闭当前channel及之前的channel
5 参考