netty心跳

package com.heart;import io.netty.bootstrap.ServerBootstrap;import io.netty.channel.Channel;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelInitializer;import io.netty.channel.ChannelOption;import io.netty.channel.EventLoopGroup;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.nio.NioServerSocketChannel;import io.netty.handler.codec.string.StringDecoder;import io.netty.handler.codec.string.StringEncoder;import io.netty.handler.timeout.IdleStateHandler;/** * netty5服务端 */public class Server {    public static void main(String[] args) {        //服务类        ServerBootstrap bootstrap = new ServerBootstrap();        //boss和worker        EventLoopGroup boss = new NioEventLoopGroup();        EventLoopGroup worker = new NioEventLoopGroup();        try {            //设置线程池            bootstrap.group(boss, worker);            //设置socket工厂、            bootstrap.channel(NioServerSocketChannel.class);            //设置管道工厂            bootstrap.childHandler(new ChannelInitializer
       
        () {                @Override                protected void initChannel(Channel ch) throws Exception {                    ch.pipeline().addLast(new IdleStateHandler(5, 5, 10));                    ch.pipeline().addLast(new StringDecoder());                    ch.pipeline().addLast(new StringEncoder());                    ch.pipeline().addLast(new ServerHandler());                }            });            //netty3中对应设置如下            //bootstrap.setOption("backlog", 1024);            //bootstrap.setOption("tcpNoDelay", true);            //bootstrap.setOption("keepAlive", true);            //设置参数，TCP参数            bootstrap.option(ChannelOption.SO_BACKLOG, 2048);//serverSocketchannel的设置，链接缓冲池的大小            bootstrap.childOption(ChannelOption.SO_KEEPALIVE, true);//socketchannel的设置,维持链接的活跃，清除死链接            bootstrap.childOption(ChannelOption.TCP_NODELAY, true);//socketchannel的设置,关闭延迟发送            //绑定端口            ChannelFuture future = bootstrap.bind(10101);            System.out.println("start");            //等待服务端关闭            future.channel().closeFuture().sync();        } catch (Exception e) {            e.printStackTrace();        } finally {            //释放资源            boss.shutdownGracefully();            worker.shutdownGracefully();        }    }}
       

package com.heart;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelFutureListener;import io.netty.channel.ChannelHandlerContext;import io.netty.channel.SimpleChannelInboundHandler;import io.netty.handler.timeout.IdleState;import io.netty.handler.timeout.IdleStateEvent;/** * 服务端消息处理 * * */public class ServerHandler extends SimpleChannelInboundHandler
       
         {    @Override    protected void messageReceived(ChannelHandlerContext ctx, String msg) throws Exception {        System.out.println(msg);        ctx.channel().writeAndFlush("hi");        ctx.writeAndFlush("hi");    }    @Override    public void userEventTriggered(final ChannelHandlerContext ctx, Object evt) throws Exception {        if (evt instanceof IdleStateEvent) {            IdleStateEvent event = (IdleStateEvent) evt;            if (event.state() == IdleState.ALL_IDLE) {                //清除超时会话                ChannelFuture writeAndFlush = ctx.writeAndFlush("you will close");                writeAndFlush.addListener(new ChannelFutureListener() {                    @Override                    public void operationComplete(ChannelFuture future) throws Exception {                        ctx.channel().close();                    }                });            }        } else {            super.userEventTriggered(ctx, evt);        }    }    /**     * 新客户端接入     */    @Override    public void channelActive(ChannelHandlerContext ctx) throws Exception {        System.out.println("channelActive");    }    /**     * 客户端断开     */    @Override    public void channelInactive(ChannelHandlerContext ctx) throws Exception {        System.out.println("channelInactive");    }    /**     * 异常     */    @Override    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {        cause.printStackTrace();    }}