什么是长连接?Netty如何设置进行长连接?
什么是长连接:
客户端和服务器在完成一次请求-响应后,不会立即断开连接,而是保持连接状态以便多次数据交互,减少频繁建立和断开连接的开销。
而TCP协议建立之后本身没有说会断开的,属于是长连接,除非是其中一方主动断开
而长连接一般意味着连接是复用的,每次发送完请求不关闭下次请求继续使用。而如果并发下只有一个连接可用,所有请求就都得加锁排队等待,因此连接池就出现了,连接池里保留一定数量的连接不关闭,有请求的时候就取出可用连接。
而TCP协议并没有限制一个连接可以保持多久,理论上只要不关闭连接,连接就一直存在。但事实上由于NAT等网络设备的存在,一个连接即使没有主动关闭,它也不会一直存活。
NAT是进行网络地址转化的,会对p包的源ip、源端口、目的ip和目的端口进行替换。而假设现在有A和B要进行长连接,实际上并不与B直接建立连接,而是与NAT A建立长连接,而NAT A又与NAT B、NAT B与B建立长连接。如果NAT设备任由下面的机器保持连接不关闭,那它很容易就耗尽所能支持的连接数,因此NAT设备会定时关闭一定时间内没有数据包的连接,并且它不会通知网络的双方,发送方不知道连接已关闭,会继续通过该连接发送数据而接收方也不知道连接已关闭,还会持续监听该连接,这样发送方收不到接收方的响应就会阻塞接口导致超时。
而要解决这个问题就是在NAT的一定时间内发送数据包来保证NAT不关闭,这个就是心跳检测机制,实际上TCP协议中就包含了一个keepalive机制:如果keepalive开关被打开,在一段时间(保活时间:tcp_keepalive_time) 内此连接不活跃,开启保活功能的一端会向对端发送一个保活探测报文。只要我们保证这个tcp_keepalive_time小于NAT的超时时间,这个探测报文的存在就能保证NAT设备不会关闭我们的连接(HTTP 1.1以后默认开启而HTTP 1.0设计上默认是不支持长连接的)
如何设置长连接
1.在 Bootstrap中设置
TCP Keepalive:
bootstrap.option(ChannelOption.SO_KEEPALIVE, true); // 启用 TCP Keepalive
2. 设置空闲检测
Netty 提供了 IdleStateHandler
,用于检测连接的空闲状态(读空闲、写空闲、读写空闲)。通过空闲检测,可以在连接空闲时发送心跳包以保持连接。
代码示例
在 ChannelPipeline
中添加 IdleStateHandler
:
pipeline.addLast(new IdleStateHandler(60, 30, 0, TimeUnit.SECONDS)); // 60秒读空闲,30秒写空闲
3. 实现心跳机制
而如果使用TCP协议层的Keeplive机制,但是该机制默认的心跳时间是2小时,依赖操作系统实现不够灵活;所以可以继承IdleStateHandler或者ChannelInboundHandlerAdapter实现自定义心跳包检测
代码示例
自定义心跳处理器:
public class HeartbeatHandler extends ChannelInboundHandlerAdapter {
private static final ByteBuf HEARTBEAT_PACKET = Unpooled.wrappedBuffer(new byte[]{0x01}); // 心跳包内容
@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
if (evt instanceof IdleStateEvent) {
IdleStateEvent event = (IdleStateEvent) evt;
if (event.state() == IdleState.WRITER_IDLE) {
// 写空闲时发送心跳包
ctx.writeAndFlush(HEARTBEAT_PACKET.duplicate());
log.info("发送心跳包");
} else if (event.state() == IdleState.READER_IDLE) {
// 读空闲时关闭连接
log.warn("读空闲超时,关闭连接");
ctx.close();
}
} else {
super.userEventTriggered(ctx, evt);
}
}
}
4. 设置连接超时
为了防止连接长时间无响应,可以设置连接超时时间。
代码示例
在 Bootstrap
中设置连接超时:
bootstrap.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000); // 5秒连接超时