Netty引導(dǎo)服務(wù)器

引導(dǎo)服務(wù)器的方法

下表顯示了 ServerBootstrap 的方法

Table 9.2 Methods of ServerBootstrap‘

如何引導(dǎo)一個(gè)服務(wù)器

ServerBootstrap 中的 childHandler(), childAttr() 和 childOption() 是常用的服務(wù)器應(yīng)用的操作。具體來(lái)說(shuō),ServerChannel實(shí)現(xiàn)負(fù)責(zé)創(chuàng)建子 Channel,它代表接受連接。因此 引導(dǎo) ServerChannel 的 ServerBootstrap ,提供這些方法來(lái)簡(jiǎn)化接收的 Channel 對(duì) ChannelConfig 應(yīng)用設(shè)置的任務(wù)。

圖9.3顯示了 ServerChannel 創(chuàng)建 ServerBootstrap 在 bind(),后者管理大量的子 Channel。

1. 當(dāng)調(diào)用 bind() 后 ServerBootstrap 將創(chuàng)建一個(gè)新的管道，這個(gè)管道將會(huì)在綁定成功后接收子管道
2. 接收新連接給每個(gè)子管道
3. 接收連接的 Channel

Figure 9.3 ServerBootstrap

記住 child* 的方法都是操作在子的 Channel，被 ServerChannel 管理。

清單9.4 ServerBootstrap 時(shí)會(huì)創(chuàng)建一個(gè) NioServerSocketChannel實(shí)例 bind() 。這個(gè) NioServerChannel 負(fù)責(zé)接受新連接和創(chuàng)建NioSocketChannel 實(shí)例。

Listing 9.4 Bootstrapping a server

NioEventLoopGroup group = new NioEventLoopGroup();
ServerBootstrap bootstrap = new ServerBootstrap(); //1
bootstrap.group(group) //2
    .channel(NioServerSocketChannel.class) //3
    .childHandler(new SimpleChannelInboundHandler<ByteBuf>() { //4
        @Override
        protected void channelRead0(ChannelHandlerContext ctx,
            ByteBuf byteBuf) throws Exception {
                System.out.println("Reveived data");
                byteBuf.clear();
            }
        }
    );
ChannelFuture future = bootstrap.bind(new InetSocketAddress(8080)); //5
future.addListener(new ChannelFutureListener() {
    @Override
    public void operationComplete(ChannelFuture channelFuture)
        throws Exception {
            if (channelFuture.isSuccess()) {
                System.out.println("Server bound");
            } else {
                System.err.println("Bound attempt failed");
                channelFuture.cause().printStackTrace();
            }
        }
    }
);

1. 創(chuàng)建要給新的 ServerBootstrap 來(lái)創(chuàng)建新的 SocketChannel 管道并綁定他們
2. 指定 EventLoopGroup 用于從注冊(cè)的 ServerChannel 中獲取EventLoop 和接收到的管道
3. 指定要使用的管道類(lèi)
4. 設(shè)置子處理器用于處理接收的管道的 I/O 和數(shù)據(jù)
5. 通過(guò)配置引導(dǎo)來(lái)綁定管道