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

举报
韩曙亮 发表于 2022/01/10 23:22:43 2022/01/10
【摘要】 文章目录 一、 ServerBootstrap / Bootstrap 引导组件二、 服务器端 ServerBootstrap 引导组件三、 客户端 Bootstrap 引导组件 ...





一、 ServerBootstrap / Bootstrap 引导组件



ServerBootstrap / Bootstrap 引导组件 :


① 服务器 / 客户端 配置 : ServerBootstrap / Bootstrap 组件的作用是配置 Netty 服务器 / 客户端的各种配置 ;

② 关联各种组件 : 该 ServerBootstrap / Bootstrap 组件将线程池 ( NioEventLoopGroup ) , 套接字通道 ( NioServerSocketChannel / SocketChannel ) , 处理者 ( Handler ) , 通道初始化器 ( ChannelInitializer ) 关联在一起 ;

③ ServerBootstrap : 服务器端程序的引导组件 ;

④ Bootstrap : 客户端程序的引导组件 ;





二、 服务器端 ServerBootstrap 引导组件



ServerBootstrap 常用方法 : 该组件类是服务器端使用的引导组件 ;


1 . 关联线程池 : 关联服务器端的 BossGroup 和 WorkerGroup 线程池 ( NioEventLoopGroup 类型 ) , parentGroup 参数是 BossGroup 负责建立客户端连接 , childGroup 参数是 WorkerGroup 负责与客户端进行数据交互 ;

public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup)

  
 
  • 1

2 . 设置通道类 : 设置服务器端的通道类型 , 一般设置 NioServerSocketChannel.class 值 ;

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

  
 
  • 1

3 . 添加 BossGroup 线程池配置 : 设置服务器端的配置 , ChannelOption option 参数是设置的操作类型 , T value 参数设置参数值 ; 如 bootstrap.option(ChannelOption.SO_BACKLOG, 128) 就是设置线程队列维护的连接个数 ;

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

  
 
  • 1

4 . 添加 WorkerGroup 线程池配置 : 设置服务器端的配置 , ChannelOption option 参数是设置的操作类型 , T value 参数设置参数值 ; 如 bootstrap.childOption(ChannelOption.SO_KEEPALIVE, true) 就是设置客户端连接的状态行为为保持连接状态 ;

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

  
 
  • 1

5 . 添加 BossGroup 线程池处理器 Handler : 给 BossGroup 线程池 ( NioEventLoopGroup 类型 ) 设置的处理器 , 该处理器需要用户自定义 , 继承 ChannelInboundHandlerAdapter 类 ;

public B handler(ChannelHandler handler)

  
 
  • 1

6 . 添加 WorkerGroup 线程池处理器 ChildHandler : 给 WorkerGroup 线程池 ( NioEventLoopGroup 类型 ) 设置处理器 , 该处理器需要用户自定义 , 继承 ChannelInboundHandlerAdapter 类 ;

public ServerBootstrap childHandler(ChannelHandler childHandler)

  
 
  • 1

7 . 绑定端口 : 服务器端的 ServerBootstrap 对象 , 调用 bind 方法 , 绑定本地的端口号 , 然后监听该端口的客户端连接请求 ;

public ChannelFuture bind(int inetPort)

  
 
  • 1

8 . 服务器端常用的 ServerBootstrap 设置代码 :

// 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();
}

  
 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34




三、 客户端 Bootstrap 引导组件



Bootstrap 常用方法 :


1 . 关联线程池 : 关联客户端的 NioEventLoopGroup 线程池 , 客户端只有一个线程池 , 只需要与服务器进行数据读写交互 , EventLoopGroup group 参数就是 NioEventLoopGroup 线程池 , 负责与客户端进行数据交互 ;

public B group(EventLoopGroup group)

  
 
  • 1

2 . 设置通道类 : 设置客户端的通道类型 , 一般设置 NioSocketChannel.class 值 ;

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

  
 
  • 1

3 . 设置 NioEventLoopGroup 线程池处理器 Handler : 为客户端的 NioEventLoopGroup 线程池 设置处理器 , 该处理器需要用户自定义 , 继承 ChannelInboundHandlerAdapter 类 ;

public B handler(ChannelHandler handler)

  
 
  • 1

4 . 连接服务器 : 连接 String inetHost 地址的 int inetPort 端口 , 建立连接用于读写数据 ;

public ChannelFuture connect(String inetHost, int inetPort)

  
 
  • 1

5 . 客户端 Bootstrap 代码示例 :

// 客户端只需要一个 时间循环组 , 即 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();
}

  
 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29

文章来源: hanshuliang.blog.csdn.net,作者:韩曙亮,版权归原作者所有,如需转载,请联系作者。

原文链接:hanshuliang.blog.csdn.net/article/details/106578689

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。