• Bootstrap引导
  • Bootstrap类
    • 引导客户端和无连接协议
    • 引导服务端

Bootstrap引导

在了解ChanelPipeline，EventLoop等组件之后，我们需要将这些组件组织起来，使其成为一个可运行的应用程序。 这里就需要引导这些组件了。

Bootstrap类

引导类的层次结构包括一个抽象的父类和两个具体的引导子类：

ServerBootstrap总是需要一个ServerSocketChannel来处理客户端的连接通信，而 Bootstrap则只需要一个普通的Channel用于与服务端的通信。

下面是AbstractBootstrap的主要方法：

引导客户端和无连接协议

Bootstrap负责Netty应用程序的客户端引导，作为客户端，我们需要使用到connect API来连接到远程 服务端，其过程如下：

客户端引导的编程模型如下：

//创建EventLoopGroup
EventLoopGroup group = new NioEventLoopGroup();
//创建客户端引导
Bootstrap bootstrap = new Bootstrap();
//配置各种属性，如Channel，ChannelHandler等 
bootstrap.group(group) 
    .channel(NioSocketChannel.class)
    .handler(new SimpleChannelInboundHandler<ByteBuf>() { 
        @Override
        protected void channeRead0(
            ChannelHandlerContext channelHandlerContext,
            ByteBuf byteBuf) throws Exception {
                System.out.println("Received data");
                byteBuf.clear();
            }
        });
//连接到远程主机
ChannelFuture future = bootstrap.connect(
    new InetSocketAddress("www.manning.com", 80)); 
//设置连接成功后的回调
future.addListener(new ChannelFutureListener() {
    @Override
    public void operationComplete(ChannelFuture channelFuture)
        throws Exception {
            if (channelFuture.isSuccess()) {
                System.out.println("Connection established");
            } else {
                System.err.println("Connection attempt failed");
                channelFuture.cause().printStackTrace();
            }
        }
    });

引导服务端

ServerBootstrap负责Netty应用程序的服务端引导，作为服务端，我们需要使用bind API来 与本地地址绑定，从而接收客户端连接，其过程如下：

服务端引导的编程模型如下:

//创建EventLoopGroup
NioEventLoopGroup group = new NioEventLoopGroup();
//创建服务端引导
ServerBootstrap bootstrap = new ServerBootstrap();
//配置各种属性，如Channel，ChannelHandler等 
bootstrap.group(group)
    .channel(NioServerSocketChannel.class) 
    .childHandler(new SimpleChannelInboundHandler<ByteBuf>() {
        @Override
        protected void channelRead0(ChannelHandlerContext ctx,
            ByteBuf byteBuf) throws Exception {
                System.out.println("Reveived data");
                byteBuf.clear();
            }
        }
    );
//绑定本地地址
ChannelFuture future = bootstrap.bind(new InetSocketAddress(8080));
//设置绑定成功后的回调
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();
            }
        }
    }
);