当前位置: 首页 > article >正文

什么是长连接?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秒连接超时

http://www.kler.cn/a/508990.html

相关文章:

  • 代码随想录算法训练营第三十五天-动态规划-01背包(二维)
  • js基础---var与let的区别以及const的使用
  • MyBatisPlus学习笔记
  • Python毕业设计选题:基于python的酒店推荐系统_django+hadoop
  • 仿射密码实验——Python实现(完整解析版)
  • Windows图形界面(GUI)-QT-C/C++ - QT 窗口属性
  • Docker详解与部署微服务实战
  • Ansible深度解析:如何精准区分并选用command与shell模块
  • Ruby语言的数据库交互
  • Redis 设计与实现:深入理解高性能缓存数据库
  • 【逆境中绽放:万字回顾2024我在挑战中突破自我】
  • 数据结构——堆(介绍,堆的基本操作、堆排序)
  • 【MySQL】简单解析一条SQL更新语句的执行过程
  • Zookeeper 配置文件:核心参数优化与实操指南
  • csp22前2题
  • JWT(数据结构、认证流程、加密、解密过程)、对称加密和非对称加密
  • C++从入门到实战(一)C++入门基础
  • WPS数据分析000001
  • SparkSQL函数
  • ComfyUI 矩阵测试指南:用三种方法,速优项目效果
  • 适配器模式详解:解决接口不兼容问题的灵活设计模式
  • 如何修改React 项目版本
  • 21天学通C++——11多态(引入多态的目的)
  • 用户中心项目教程(二)---umi3的使用出现的错误
  • 通过idea创建的springmvc工程需要的配置
  • vue3常用的组件的通信方式