【Netty】Netty 核心组件 ( ServerBootstrap | Bootstrap )

public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup)

public B channel(Class<? extends C> channelClass)

public <T> B option(ChannelOption<T> option, T value)

public <T> ServerBootstrap childOption(ChannelOption<T> childOption, T value)

public B handler(ChannelHandler handler)

public ChannelFuture bind(int inetPort)

// 1. BossGroup 线程池 : 负责客户端的连接
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
// 2. WorkerGroup 线程池 : 负责客户端连接的数据读写
EventLoopGroup workerGroup = new NioEventLoopGroup();
// 3. 服务器启动对象, 需要为该对象配置各种参数
ServerBootstrap bootstrap = new ServerBootstrap();
bootstrap.group(bossGroup, workerGroup) // 设置 主从 线程组 , 分别对应 主 Reactor 和 从 Reactor
        .channel(NioServerSocketChannel.class)  // 设置 NIO 网络套接字通道类型
        .option(ChannelOption.SO_BACKLOG, 128)  // 设置线程队列维护的连接个数
        .childOption(ChannelOption.SO_KEEPALIVE, true)  // 设置连接状态行为, 保持连接状态
        .childHandler(  // 为 WorkerGroup 线程池对应的 NioEventLoop 设置对应的事件 处理器 Handler
                new ChannelInitializer<SocketChannel>() {// 创建通道初始化对象
                    @Override
                    protected void initChannel(SocketChannel ch) throws Exception {
                        // 该方法在服务器与客户端连接建立成功后会回调
                        // 为 管道 Pipeline 设置处理器 Hanedler
                        ch.pipeline().addLast(new ServerHandler());
                    }
                }
        );
 // 4. 绑定本地端口 
 ChannelFuture channelFuture = null;
 try {
     // 绑定本地端口, 进行同步操作 , 并返回 ChannelFuture
     channelFuture = bootstrap.bind(8888).sync();
 } catch (InterruptedException e) {
     e.printStackTrace();
 } finally {
     // 出现异常后, 优雅的关闭
     bossGroup.shutdownGracefully();
     workerGroup.shutdownGracefully();
}

public ChannelFuture connect(String inetHost, int inetPort)

// 客户端只需要一个 时间循环组 , 即 NioEventLoopGroup 线程池
EventLoopGroup eventLoopGroup = new NioEventLoopGroup();
// 客户端启动对象
Bootstrap bootstrap = new Bootstrap();
// 设置相关参数
bootstrap.group(eventLoopGroup)     // 设置客户端的线程池
        .channel(NioSocketChannel.class)    // 设置客户端网络套接字通道类型
        .handler(   // 设置客户端的线程池对应的 NioEventLoop 设置对应的事件处理器 Handler
                new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) throws Exception {
                        ch.pipeline().addLast(new ClientHandler());
                    }
                }
        );
try {
    // 开始连接服务器, 并进行同步操作
    // ChannelFuture 类分析 , Netty 异步模型
    // sync 作用是该方法不会再次阻塞
    ChannelFuture channelFuture = bootstrap.connect("127.0.0.1", 8888).sync();
    System.out.println("客户端连接服务器成功 ...");
    // 关闭通道, 开始监听
    channelFuture.channel().closeFuture().sync();
} catch (InterruptedException e) {
    e.printStackTrace();
}finally {
    // 优雅的关闭
    eventLoopGroup.shutdownGracefully();
}