Netty学习之编写Netty程序

使用Netty框架编写Netty程序一般需要十个步骤

1：声明线程池

// 创建bossGroup用于处理Accept事件（一般声明一个线程）
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
// 创建workerGroup用于处理读写事件
EventLoopGroup workerGroup = new NioEventLoopGroup();

2：创建服务端引导类（用来集成所有配置）

// 一种是服务端引导类（ClientBootstrap ），一种是客户端引导类（ServerBootstrap ）
ServerBootstrap serverBootstrap = new ServerBootstrap();

3：设置线程池（用于说明Netty以什么样的线程模式运行）

serverBootstrap.group(bossGroup, workerGroup);

4：设置ServerSocketChannel类型（设置Netty以什么样的IO模型运行）

serverBootstrap.channel(NioServerSocketChannel.class);

5：设置参数（可选）

serverBootstrap.option(ChannelOption.SO_BACKLOG, 100);

6：设置Handler（可选）

serverBootstrap.handler(new LoggingHandler(LogLevel.INFO));

7：编写并设置子Handler（Netty 中的 Handler 分成两种，一种叫做 Inbound，一种叫做 Outbound）

serverBootstrap.childHandler(new ChannelInitializer() {
            @Override
            public void initChannel(SocketChannel ch) throws Exception {
                ChannelPipeline p = ch.pipeline();
                // 可以添加多个子Handler
                p.addLast(new LoggingHandler(LogLevel.INFO));
                // p.addLast(new EchoServerHandler());
            }
        });

8：绑定端口

try {
            f = serverBootstrap.bind(PORT).sync();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

9：等待服务端端口关闭

try {
            f.channel().closeFuture().sync();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

10：关闭线程池

bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();