连接假死和心跳监测

作者: zhl 分类: Netty 发布时间: 2024-03-05 13:53

【出现原因】

  • 当网络设备出现故障,但应用程序没有感知到,仍然占用着资源
  • 网络不稳定,出现丢包
  • 应用程序线程阻塞,无法进行数据读写

【存在的问题】

  • 假死的连接占用的资源不能自动释放
  • 向假死的连接发送数据,得到的反馈是发送超时

服务器端定时向客户端发送数据,如果客户端没有发送数据,就可以判定为连接假死。

添加 Netty 中的 IdleStateHandler(int readerIdleTimeSeconds, int writerIdleTimeSeconds,int allIdleTimeSeconds))可以监测读或写事件。

添加ChannelDuplexHandler`中的`userEventTriggered方法触发特殊事件,以此进行监测

// 5s 内如果没有收到 channel 的数据(没有读操作时),会触发一个 IdleState#READER_IDLE 事件
ch.pipeline().addLast(new IdleStateHandler(5,0,0));
// 空闲检测 需要对读写事件监测 =》 双向检测
// ChannelDuplexHandler 可以同时作为入站和出站处理器
ch.pipeline().addLast(new ChannelDuplexHandler(){
    // 用来触发特殊事件
    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        IdleStateEvent event = (IdleStateEvent) evt;
        // 触发了读空闲事件
        if (event.state() == IdleState.READER_IDLE) {
            log.debug("已经 5s 未读到数据");
            ctx.channel().close();
        }
    }
});

为了避免服务器的误判,在客户端中需要定时向服务器发送数据。

例如: 客户端连接正常,用户只是停顿了一会儿,但是服务器没有接收到客户端的数据,认为是连接假死。

客户端向服务器发送数据的时间间隔,小于服务器定义的空闲检测的时间间隔,就能防止服务器的误判。

// 3s 内如果没有向服务器写数据(没有写操作时),会触发一个 IdleState#WRITER_IDLE 事件
ch.pipeline().addLast(new IdleStateHandler(0,3,0));
ch.pipeline().addLast(new ChannelDuplexHandler(){
    // 用来触发特殊事件
    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        IdleStateEvent event = (IdleStateEvent) evt;
        // 触发了写空闲事件
        if (event.state() == IdleState.WRITER_IDLE) {
            log.debug("3s 没有写数据,发送一个心跳包");
            ctx.writeAndFlush(new PingMessage());
        }
    }
});

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注