文章目錄

• 一、 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)

2 . 設置通道類 : 設置服務器端的通道類型 , 一般設置 NioServerSocketChannel.class 值 ;

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

3 . 添加 BossGroup 線程池配置 : 設置服務器端的配置 , ChannelOption option 參數是設置的操作類型 , T value 參數設置參數值 ; 如 bootstrap.option(ChannelOption.SO_BACKLOG, 128) 就是設置線程隊列維護的連接個數 ;

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

4 . 添加 WorkerGroup 線程池配置 : 設置服務器端的配置 , ChannelOption option 參數是設置的操作類型 , T value 參數設置參數值 ; 如 bootstrap.childOption(ChannelOption.SO_KEEPALIVE, true) 就是設置客戶端連接的狀態行為為保持連接狀態 ;

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

5 . 添加 BossGroup 線程池處理器 Handler : 給 BossGroup 線程池 ( NioEventLoopGroup 類型 ) 設置的處理器 , 該處理器需要用戶自定義 , 繼承 ChannelInboundHandlerAdapter 類 ;

public B handler(ChannelHandler handler)

6 . 添加 WorkerGroup 線程池處理器 ChildHandler : 給 WorkerGroup 線程池 ( NioEventLoopGroup 類型 ) 設置處理器 , 該處理器需要用戶自定義 , 繼承 ChannelInboundHandlerAdapter 類 ;

public ServerBootstrap childHandler(ChannelHandler childHandler)

7 . 綁定端口 : 服務器端的 ServerBootstrap 對象 , 調用 bind 方法 , 綁定本地的端口號 , 然后監聽該端口的客戶端連接請求 ;

public ChannelFuture bind(int inetPort)

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 設置對應的事件 處理器 Handlernew ChannelInitializer<SocketChannel>() {// 創建通道初始化對象@Overrideprotected void initChannel(SocketChannel ch) throws Exception {// 該方法在服務器與客戶端連接建立成功后會回調// 為 管道 Pipeline 設置處理器 Hanedlerch.pipeline().addLast(new ServerHandler());}});// 4. 綁定本地端口 ChannelFuture channelFuture = null;try {// 綁定本地端口, 進行同步操作 , 并返回 ChannelFuturechannelFuture = bootstrap.bind(8888).sync();} catch (InterruptedException e) {e.printStackTrace();} finally {// 出現異常后, 優雅的關閉bossGroup.shutdownGracefully();workerGroup.shutdownGracefully(); }

三、 客戶端 Bootstrap 引導組件

---

Bootstrap 常用方法 :

1 . 關聯線程池 : 關聯客戶端的 NioEventLoopGroup 線程池 , 客戶端只有一個線程池 , 只需要與服務器進行數據讀寫交互 , EventLoopGroup group 參數就是 NioEventLoopGroup 線程池 , 負責與客戶端進行數據交互 ;

public B group(EventLoopGroup group)

2 . 設置通道類 : 設置客戶端的通道類型 , 一般設置 NioSocketChannel.class 值 ;

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

3 . 設置 NioEventLoopGroup 線程池處理器 Handler : 為客戶端的 NioEventLoopGroup 線程池 設置處理器 , 該處理器需要用戶自定義 , 繼承 ChannelInboundHandlerAdapter 類 ;

public B handler(ChannelHandler handler)

4 . 連接服務器 : 連接 String inetHost 地址的 int inetPort 端口 , 建立連接用于讀寫數據 ;

public ChannelFuture connect(String inetHost, int inetPort)

5 . 客戶端 Bootstrap 代碼示例 :

// 客戶端只需要一個 時間循環組 , 即 NioEventLoopGroup 線程池 EventLoopGroup eventLoopGroup = new NioEventLoopGroup(); // 客戶端啟動對象 Bootstrap bootstrap = new Bootstrap(); // 設置相關參數 bootstrap.group(eventLoopGroup) // 設置客戶端的線程池.channel(NioSocketChannel.class) // 設置客戶端網絡套接字通道類型.handler( // 設置客戶端的線程池對應的 NioEventLoop 設置對應的事件處理器 Handlernew ChannelInitializer<SocketChannel>() {@Overrideprotected 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(); }

總結

以上是生活随笔為你收集整理的【Netty】Netty 核心组件 ( ServerBootstrap | Bootstrap )的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。