Netty入门(九)空闲连接以及超时

时间:2023-03-09 21:01:58
Netty入门(九)空闲连接以及超时

  检测空闲连接和超时是为了及时释放资源。常见的方法是发送消息来测试一个不活跃的连接,通常称为“心跳”。

  Netty 提供了几个 ChannelHandler 来实现此目的,如下:

  Netty入门(九)空闲连接以及超时

  下面是 IdleStateHandler 的一个简单使用:

 /**
* 空闲连接
* 当超过60s没有数据收到时,就发送心跳到远端
* 如果没有回应,关闭连接
*/
public class IdleStateHandlerInitializer extends ChannelInitializer<Channel> { @Override
protected void initChannel(Channel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
// 若60s没有收到消息,调用userEventTriggered方法
pipeline.addLast(new IdleStateHandler(0, 0, 60, TimeUnit.SECONDS));
pipeline.addLast(new HeartBeatHandle());
} public static final class HeartBeatHandle extends ChannelInboundHandlerAdapter {
private static final ByteBuf HEARTBEAT_SEQUENCE = Unpooled.unreleasableBuffer(
Unpooled.copiedBuffer("HEARTBEAT", CharsetUtil.UTF_8)); @Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
if(evt instanceof IdleStateEvent) {
// 发送心跳到远端
ctx.writeAndFlush(HEARTBEAT_SEQUENCE.duplicate())
.addListener(ChannelFutureListener.CLOSE_ON_FAILURE); // 关闭连接
} else {
// 传递给下一个处理程序
super.userEventTriggered(ctx, evt);
}
}
} }