Netty 在一個(gè)引導(dǎo)中添加多個(gè) ChannelHandler

Netty 的一個(gè)優(yōu)勢是可以在 ChannelPipeline 中堆疊很多ChannelHandler 并且可以最大程度的重用代碼。如何添加多個(gè)ChannelHandler 呢？Netty 提供 ChannelInitializer 抽象類用來初始化 ChannelPipeline 中的 ChannelHandler。ChannelInitializer是一個(gè)特殊的 ChannelHandler，通道被注冊到 EventLoop 后就會調(diào)用ChannelInitializer，并允許將 ChannelHandler 添加到CHannelPipeline；完成初始化通道后，這個(gè)特殊的 ChannelHandler 初始化器會從 ChannelPipeline 中自動刪除。

聽起來很復(fù)雜，其實(shí)很簡單，看下面代碼：

Listing 9.6 Bootstrap and using ChannelInitializer

ServerBootstrap bootstrap = new ServerBootstrap();//1
bootstrap.group(new NioEventLoopGroup(), new NioEventLoopGroup())  //2
    .channel(NioServerSocketChannel.class)  //3
    .childHandler(new ChannelInitializerImpl()); //4
ChannelFuture future = bootstrap.bind(new InetSocketAddress(8080));  //5
future.sync();


final class ChannelInitializerImpl extends ChannelInitializer<Channel> {  //6
    @Override
    protected void initChannel(Channel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline(); //7
        pipeline.addLast(new HttpClientCodec());
        pipeline.addLast(new HttpObjectAggregator(Integer.MAX_VALUE));

    }
}

1. 創(chuàng)建一個(gè)新的 ServerBootstrap 來創(chuàng)建和綁定新的 Channel
2. 指定 EventLoopGroups 從 ServerChannel 和接收到的管道來注冊并獲取 EventLoops
3. 指定 Channel 類來使用
4. 設(shè)置處理器用于處理接收到的管道的 I/O 和數(shù)據(jù)
5. 通過配置的引導(dǎo)來綁定管道
6. ChannelInitializer 負(fù)責(zé)設(shè)置 ChannelPipeline
7. 實(shí)現(xiàn) initChannel() 來添加需要的處理器到 ChannelPipeline。一旦完成了這方法 ChannelInitializer 將會從 ChannelPipeline 刪除自身。

通過 ChannelInitializer, Netty 允許你添加你程序所需的多個(gè) ChannelHandler 到 ChannelPipeline