抛弃服务器

世上最简单的协议不是'Hello, World!' 而是 DISCARD(抛弃服务)。

public class DiscardServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        //抛弃数据
        ByteBuf in = (ByteBuf) msg;
        try {
            while (in.isReadable()) { // (1)

                // 打印消息内容
                System.out.print((char) in.readByte());
                System.out.flush();
            }
        } finally {

            // 释放消息
            ReferenceCountUtil.release(msg); // (2)
        }
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
       // 出现异常关闭连接
        cause.printStackTrace();
        ctx.close();
    }
}



public class DiscardServer {
    private static final int port = 8080;

    public void run() throws Exception {
        /**
         * 1.NioEventLoopGroup 是用来处理I/O操作的多线程事件循环器，
         * Netty 提供了许多不同的 EventLoopGroup 的实现用来处理不同的传输。
         * 在这个例子中我们实现了一个服务端的应用，因此会有2个 NioEventLoopGroup 会被使用。
         * 第一个经常被叫做‘boss’，用来接收进来的连接。第二个经常被叫做‘worker’，用来处理已经被接收的连接，一旦‘boss’接收到连接，
         * 就会把连接信息注册到‘worker’上。如何知道多少个线程已经被使用，如何映射到已经创建的 Channel上都需要依赖于 EventLoopGroup 的实现，
         * 并且可以通过构造函数来配置他们的关系。
         */
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workGroup = new NioEventLoopGroup();
        /**
         * ServerBootstrap 是一个启动 NIO 服务的辅助启动类。
         * 你可以在这个服务中直接使用 Channel，
         * 但是这会是一个复杂的处理过程，在很多情况下你并不需要这样做。
         */
        try {
            ServerBootstrap sb = new ServerBootstrap();
             sb.group(bossGroup, workGroup)
                    .channel(NioServerSocketChannel.class)
                    /**
                     * 这里的事件处理类经常会被用来处理一个最近的已经接收的 Channel。ChannelInitializer 是一个特殊的处理类，
                     * 他的目的是帮助使用者配置一个新的 Channel。也许你想通过增加一些处理类比如DiscardServerHandler
                     * 来配置一个新的 Channel 或者其对应的ChannelPipeline 来实现你的网络程序。当你的程序变的复杂时，
                     * 可能你会增加更多的处理类到 pipline 上，然后提取这些匿名类到最顶层的类上
                     */
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel socketChannel) throws Exception {
                            socketChannel.pipeline().addLast(new DiscardServerHandler());
                        }
                        /**
                         * 你可以设置这里指定的 Channel 实现的配置参数。我们正在写一个TCP/IP 的服务端，
                         * 因此我们被允许设置 socket 的参数选项比如tcpNoDelay 和 keepAlive。
                         * 请参考 ChannelOption 和详细的 ChannelConfig 实现的接口文档以此可以对ChannelOption 的有一个大概的认识。
                         * option() 是提供给NioServerSocketChannel 用来接收进来的连接。
                         * childOption() 是提供给由父管道 ServerChannel 接收到的连接，在这个例子中也是 NioServerSocketChannel。
                         */
                    }).option(ChannelOption.SO_BACKLOG, 128)          // (5)
                    .childOption(ChannelOption.SO_KEEPALIVE, true); // (6)

            ChannelFuture f = sb.bind(port).sync();
            System.out.println("DiscardServer已启动，端口：" + port);
            // 在这个例子中，这不会发生，但你可以优雅地关闭你的服务器。
            f.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workGroup.shutdownGracefully();

        }
    }

    public static void main(String[] args) throws Exception {
        new DiscardServer().run();
    }
}

标签：Exception,void,throws,抛弃,new,服务器,public,Channel
来源： https://www.cnblogs.com/webzom/p/14361616.html