写一个 echo 服务器

• 一个服务器 handler：这个组件实现了服务器的业务逻辑，决定了连接创建后和接收到信息后该如何处理
• Bootstrapping： 这个是配置服务器的启动代码。最少需要设置服务器绑定的端口，用来监听连接请求。

• channelRead() - 每个信息入站都会调用
• channelReadComplete() - 通知处理器最后的 channelread() 是当前批处理中的最后一条消息时调用
• exceptionCaught()- 读操作时捕获到异常时调用

Listing 2.2 EchoServerHandler
@Sharable                                        //1
public class EchoServerHandler extends
        ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx,
        Object msg) {
        ByteBuf in = (ByteBuf) msg;
        System.out.println("Server received: " + in.toString(CharsetUtil.UTF_8));        //2
        ctx.write(in);                            //3
    }
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        ctx.writeAndFlush(Unpooled.EMPTY_BUFFER)//4
        .addListener(ChannelFutureListener.CLOSE);
    }
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx,
        Throwable cause) {
        cause.printStackTrace();                //5
        ctx.close();                            //6
    }
}

1. @Sharable 标识这类的实例之间可以在 channel 里面共享
2. 日志消息输出到控制台
3. 将所接收的消息返回给发送者。注意，这还没有冲刷数据
4. 冲刷所有待审消息到远程节点。关闭通道后，操作完成
5. 打印异常堆栈跟踪
6. 关闭通道

• ChannelHandler 是给不同类型的事件调用
• 应用程序实现或扩展 ChannelHandler 挂接到事件生命周期和 提供自定义应用逻辑。

• 监听和接收进来的连接请求
• 配置 Channel 来通知一个关于入站消息的 EchoServerHandler 实例

Listing 2.3 EchoServer
public class EchoServer {
    private final int port;
    public EchoServer(int port) {
        this.port = port;
    }
        public static void main(String[] args) throws Exception {
        if (args.length != 1) {
            System.err.println(
                    "Usage: " + EchoServer.class.getSimpleName() +
                    " <port>");
            return;
        }
        int port = Integer.parseInt(args[0]);        //1
        new EchoServer(port).start();                //2
    }
    public void start() throws Exception {
        NioEventLoopGroup group = new NioEventLoopGroup(); //3
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(group)                                //4
             .channel(NioServerSocketChannel.class)        //5
             .localAddress(new InetSocketAddress(port))    //6
             .childHandler(new ChannelInitializer<SocketChannel>() { //7
                 @Override
                 public void initChannel(SocketChannel ch) 
                     throws Exception {
                     ch.pipeline().addLast(
                             new EchoServerHandler());
                 }
             });
            ChannelFuture f = b.bind().sync();            //8
            System.out.println(EchoServer.class.getName() + " started and listen on " + f.channel().localAddress());
            f.channel().closeFuture().sync();            //9
        } finally {
            group.shutdownGracefully().sync();            //10
        }
    }
}

1. 设置端口值（抛出一个 NumberFormatException 如果该端口参数的格式不正确）
2. 呼叫服务器的 start() 方法
3. 创建 EventLoopGroup
4. 创建 ServerBootstrap
5. 指定使用 NIO 的传输 Channel
6. 设置 socket 地址使用所选的端口
7. 添加 EchoServerHandler 到 Channel 的 ChannelPipeline
8. 绑定的服务器;sync 等待服务器关闭
9. 关闭 channel 和 块，直到它被关闭
10. 关机的 EventLoopGroup，释放所有资源。

• EchoServerHandler 实现了的业务逻辑
• 在 main() 方法，引导了服务器

• 创建 ServerBootstrap 实例来引导服务器并随后绑定
• 创建并分配一个 NioEventLoopGroup 实例来处理事件的处理，如接受新的连接和读/写数据。
• 指定本地 InetSocketAddress 给服务器绑定
• 通过 EchoServerHandler 实例给每一个新的 Channel 初始化
• 最后调用 ServerBootstrap.bind() 绑定服务器