抛弃服务器

2021-02-02 14:04:30 阅读：170 来源： 互联网

标签：Exception void throws 抛弃 new 服务器 public Channel

世上最简单的协议不是'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

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

抛弃服务器