破解北京pk10冠亚和值 1比0.95刷流水教程 pk10稳赚技巧方案 北京pk10怎么研究走势 北京pk赛车一天多少期 北京pk赛车历史记录 全天北京pk10赛车计划 北京pk10冠军单双技巧 北京pk两期免费计划 北京pk10冠军公式大全 pk10高手单期人工计划 北京pk10免费人工计划 pk10一天赚300好搞吗 北京pk10杀3码公式 app软件购买北京pk10 北京pk10每天开多少期 北京pk10精准一期计划 北京pk拾全天精准计划 二分pk10怎么玩 pk10怎么引诱别人玩 北京赛車pk10网站 北京pk2期计划在线网站 pk10前三跨度怎么算 赌场最怕什么样的赌法 北京pk赛车彩票官网 怎样控制自己每天赢500 北京pk10正规彩票网站 北京pk10前五1码计划 一无所有怎么白手起家 北京pk10去一尾图解

Netty超时机制及心跳程序实现

时间:2019-03-18   来源:尚学堂   阅读:122

  本文介绍了Netty超时机制的原理,以及如何在连接闲置时发送一个心跳来维持连接。

 

  Netty超时机制的介绍

  Netty的超时类型IdleState主要分为:

  ? ALL_IDLE:一段时间内没有数据接收或者发送

  ? READER_IDLE:一段时间内没有数据接收

  ? WRITER_IDLE:一段时间内没有数据发送

  在Netty的timeout包下,主要类有:

  ? IdleStateEvent:超时的事件

  ? IdleStateHandler:超时状态处理

  ? ReadTimeoutHandler:读超时状态处理

  ? WriteTimeoutHandler:写超时状态处理

  其中IdleStateHandler包含了读\写超时状态处理,比如

private static final int READ_IDEL_TIME_OUT = 4; // 读超时
private static final int WRITE_IDEL_TIME_OUT = 5;// 写超时
private static final int ALL_IDEL_TIME_OUT = 7; // 所有超时
 
new IdleStateHandler(READ_IDEL_TIME_OUT,
            WRITE_IDEL_TIME_OUT, ALL_IDEL_TIME_OUT, TimeUnit.SECONDS));

  上述例子,在IdleStateHandler中定义了读超时的时间是4秒,写超时的时间是5秒,其他所有的超时时间是7秒。

 

  应用IdleStateHandler

  ?#28909;籌dleStateHandler包括了读\写超时状态处理,那么很多时候ReadTimeoutHandler、WriteTimeoutHandler都可以不用使用。定义另一个名为HeartbeatHandlerInitializer的ChannelInitializer:

public class HeartbeatHandlerInitializer extends ChannelInitializer<Channel> {
 
    private static final int READ_IDEL_TIME_OUT = 4; // 读超时
    private static final int WRITE_IDEL_TIME_OUT = 5;// 写超时
    private static final int ALL_IDEL_TIME_OUT = 7; // 所有超时
 
    @Override
    protected void initChannel(Channel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();
        pipeline.addLast(new IdleStateHandler(READ_IDEL_TIME_OUT,
                WRITE_IDEL_TIME_OUT, ALL_IDEL_TIME_OUT, TimeUnit.SECONDS)); // 1
        pipeline.addLast(new HeartbeatServerHandler()); // 2
    }
}

  1.使用了IdleStateHandler,分别设置了读、写超时的时间

  2.定义了一个HeartbeatServerHandler处理器,用来处理超时时,发送心跳

 

  定义了一个心跳处理器

public class HeartbeatServerHandler extends ChannelInboundHandlerAdapter {
 
    // Return a unreleasable view on the given ByteBuf
    // which will just ignore release and retain calls.
    private static final ByteBuf HEARTBEAT_SEQUENCE = Unpooled
            .unreleasableBuffer(Unpooled.copiedBuffer("Heartbeat",
                    CharsetUtil.UTF_8));  // 1
 
    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt)
            throws Exception {
 
        if (evt instanceof IdleStateEvent) {  // 2
            IdleStateEvent event = (IdleStateEvent) evt;  
            String type = "";
            if (event.state() == IdleState.READER_IDLE) {
                type = "read idle";
            } else if (event.state() == IdleState.WRITER_IDLE) {
                type = "write idle";
            } else if (event.state() == IdleState.ALL_IDLE) {
                type = "all idle";
            }
 
            ctx.writeAndFlush(HEARTBEAT_SEQUENCE.duplicate()).addListener(
                    ChannelFutureListener.CLOSE_ON_FAILURE);  // 3
 
            System.out.println( ctx.channel().remoteAddress()+"超时类型:" + type);
        } else {
            super.userEventTriggered(ctx, evt);
        }
    }
}

  1.定义了心跳时,要发送的内容

  2.判断是否是IdleStateEvent事件,是则处理

  3.将心跳内容发送给客户端

 

  服务器

  服务器代码比较简单,启动后侦听8082端口

public final class HeartbeatServer {
 
    static final int PORT = 8082;
 
    public static void main(String[] args) throws Exception {
 
        // Configure the server.
        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .option(ChannelOption.SO_BACKLOG, 100)
             .handler(new LoggingHandler(LogLevel.INFO))
             .childHandler(new HeartbeatHandlerInitializer());
 
            // Start the server.
            ChannelFuture f = b.bind(PORT).sync();
 
            // Wait until the server socket is closed.
            f.channel().closeFuture().sync();
        } finally {
            // Shut down all event loops to terminate all threads.
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}

 

  客户端测试

  客户端用操作系统自带的Telnet程序即可:

telnet 127.0.0.1 8082

 

  效果

 

  源码

  见https://github.com/waylau/netty-4-user-guide-demos中heartbeat包

 

  参考

  ? Netty4.x?#27809;?#25351;南https://github.com/waylau/netty-4-user-guide

  ? Netty实战(精髓)https://github.com/waylau/essential-netty-in-action

相关资讯

  • ?#26412;?#26657;区
  • 山西校区
  • 郑州校区
  • 武汉校区
  • 四川校区
  • 长沙校区
  • 深圳校区
  • 上海校区
  • 广州校区
  • 保定招生办

?#26412;?#28023;淀区校区(总部):?#26412;?#24066;海淀区西三旗街道建材城西?#20998;?#33150;建华商务大厦东侧二层尚学堂
?#26412;?#20140;?#38386;?#21306;:?#26412;?#20134;庄经济开发区科创十四街6号院1号楼 赛蒂国际工业园
咨询电话:400-009-1906 / 010-56233821
面授课程: JavaEE培训大数据就业班培训大数据云计算周末班培训零基础大数据连读班培训大数据云计算高手班培训人工智能周末班培训人工智能+Python全栈培训H5+PHP全栈工程师培训

山西学区地址:山西省晋中市榆次区大学城大学生活广场万科商业A1座702

郑州学区地址?#27721;幽系?#23376;商务产业园6号楼4层407
咨询电话:0371-55177956

武汉学区地址?#27721;?#21271;省武汉?#34218;?#22799;区江夏大道26号 宏信悦谷创业园4楼
咨询电话:027-87989193

四川学区地址:成都市高新区锦晖西一街99号布鲁明顿大厦2栋1003室
咨询电话:028-65176856 / 13880900114

网址:http://www.cssxt.com/
咨询电话:0731-83072091

深圳校区地址:深圳市宝安区航城街道航城大道航城创新创业园A4栋210(固戍地铁站C出口)
咨询电话:0755-23061965 / 18898413781

上海尚学堂?#23665;?#26657;区地址:上海市?#23665;?#21306;荣乐东路2369弄45号绿地伯顿大厦2层
咨询电话:021-67690939

广州校区地址:广州市天河区元岗横路31号慧通产业广场B区B1栋6楼尚学堂(地铁3号线或6号线到“天河客运站”D出口,右拐直走约800米)
咨询电话:020-2989 6995

保定招生办公室

地址?#27721;?#21271;省保定市竞秀区朝阳南大街777号鸿悦国际1101室

电话:15132423123

Copyright 2006-2019 ?#26412;?#23578;学堂科技有限公司  京ICP备13018289号-19  京公网安备11010802015183  
?#25945;?#32852;系:18610174079 ?#35780;?#24072;  
pk10单双最好方法