netty心跳检测实现

95 阅读 0 评论 63 点赞

我是靠谱客的博主贪玩飞机，这篇文章主要介绍netty心跳检测实现，现在分享给大家，希望可以做个参考。

初学netty想要写一点代码增加一些熟练度和对一些接口的认识，在前面一篇文章实现了通过事先发送长度的方法来传输自定义的message对象，这次在之前的代码上加入一些代码实现心跳检测
服务器这边首先要在管道加入idlestatehandler
之后在myhandler里加入一些代码

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
class myhandler extends SimpleChannelInboundHandler<message>{
    /** 空闲次数 */
    private int idle_count = 1;
    /** 发送次数 */
    private int count = 1;
    @Override
    public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
        System.err.println("one new channel in bound");
    }

    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        if (evt instanceof IdleStateEvent) {
            IdleStateEvent event = (IdleStateEvent) evt;
            if (IdleState.READER_IDLE.equals(event.state())){
                if (idle_count>2){
                    System.out.println("超过两次等待超时，关闭连接");
                    ctx.channel().close();
                }
                System.out.println("已经等待超过5秒没有用户信息");
                idle_count++;
            }
        } else {
            super.userEventTriggered(ctx, evt);
        }
    }
    。。。。。。