• NIO簡單介
  NIO 非阻塞IO模型，基于緩沖區(Buffer)讀寫數據，讀寫后的數據通過通道(Channel)進行傳輸，采用選擇器(Selector)管理多個通道從而實現高并發。
  核心組件：1. Buffer 為一個內存數組作為數據容器，代替傳統的InputStream和OutputStream；2. Channel 雙向數據傳輸；3. Selector 監聽多通道區別于傳統的單線程管理多連接
• 傳統的IO模型
  阻塞、非阻塞、多路復用、信號驅動、異步IO
• 簡單的NIO服務器接收客戶端TCP請求

 public void start(int port) throws IOException {//創建一個選擇器管理通道Selector selector = Selector.open();//創建通道并注冊到選擇器（可創建多個通道）createChannel(selector, port);while (true) {//阻塞，等到有事件發生時繼續執行selector.select();//處理事件Iterator<SelectionKey> keys = selector.selectedKeys().iterator();while (keys.hasNext()) {SelectionKey key = keys.next();keys.remove();//新連接到達if (key.isAcceptable()) {ServerSocketChannel socketChannel = (ServerSocketChannel) key.channel();SocketChannel channel = socketChannel.accept();channel.configureBlocking(false);//注冊新的讀取事件channel.register(selector, SelectionKey.OP_READ);continue;}//可讀取數據if (key.isReadable()) {SocketChannel channel = (SocketChannel) key.channel();//定義讀取數據的緩沖區ByteBuffer buffer = ByteBuffer.allocate(1024);//讀取數據到緩沖int bytes = channel.read(buffer);//客戶端關閉連接if (bytes == -1) {channel.close();continue;}//切換為讀取模式buffer.flip();String message = new String(buffer.array(), 0, bytes);System.out.println("接收到消息");//回顯消息給客戶端channel.write(ByteBuffer.wrap(message.getBytes()));}}}}

private void createChannel(Selector selector, int port) throws IOException {//創建通道并綁定端口ServerSocketChannel socketChannel = ServerSocketChannel.open();socketChannel.bind(new InetSocketAddress(port));//設置為非阻塞socketChannel.configureBlocking(false);//將通道注冊到選擇器socketChannel.register(selector, SelectionKey.OP_ACCEPT);}

• Netty基于NIO的異步事件驅動的網絡應用框架
  特性：異步和事件驅動、高性能（高效的線程模型和緩沖區機制）、易使用和靈活可擴展
  涉及到 channel 、callback(事件發生時的回調)、Future和Promise（異步計算）、EventLoop(事件循環)、Pipeline和ChannelHandler管道和處理器、bootstrap引導類

 public static void start(int port) {// 創建兩個EventLoopGroup事件循環組，一個用于接收客戶端連接，一個用于處理客戶端數據EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();try {start(bossGroup, workerGroup, port);} catch (Exception e) {log.warn("Netty服務【{}】發生異常", port, e);} finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}

private static void start(EventLoopGroup bossGroup, EventLoopGroup workerGroup, int port) throws InterruptedException {//創建服務器啟動對象ServerBootstrap serverBootstrap = new ServerBootstrap();//parentGroup：這個事件組用于接收客戶端的連接請求。它會創建一個ServerChannel，用于監聽并接收客戶端的連接。一旦有連接請求到達，parentGroup就會將連接分配給childGroup中的一個EventLoop來處理。//childGroup：這個事件組用于處理接收到的連接的數據。它會創建一個或多個Channel，用于與客戶端進行通信。每個Channel都有一個關聯的EventLoop，用于處理該Channel的I/O操作。childGroup會負責管理這些Channel和EventLoop，包括事件循環、線程分配、I/O操作等。//通過使用兩個不同的事件組，可以實現多線程處理客戶端連接和數據的模型。parentGroup負責接收連接請求并將其分配給childGroup處理，childGroup負責處理具體的連接和數據操作，從而提高服務器的并發性能。serverBootstrap.group(bossGroup, workerGroup)//.option(ChannelOption)可設置其它各種參數//服務器通道實現采用NioServerSocketChannel.channel(NioServerSocketChannel.class)//針對服務端的所有連接（不論已連接或是創建連接）.handler(new LoggingHandler())//針對已接收到的連接的處理器配置.childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel socketChannel) {//添加自定義解碼器，如繼承ByteToMessageCodec用于處理各種業務邏輯，解碼器按添加的先后順尋執行//ByteToMessageCodec主要用于解碼字節數據，將其轉換為消息對象，常用于解決粘包和拆包問題//ChannelInboundHandlerAdapter主要用于處理各種事件，如接收到數據、連接建立、異常處理等，同時為響應請求數據可以用用channel的writeAndFlush將數據寫入并刷新網路socketChannel.pipeline().addLast(new IotDataDecoder(), new IotBusinessDecoder());}});//以下兩行代碼用于確保服務器在綁定端口后一直保持運行狀態，直到接收到關閉信號//綁定服務器端口并啟動服務 sync()使當前線程阻塞直到綁定服務器,綁定多個端口直接重復以下兩行代碼ChannelFuture channelFuture = serverBootstrap.bind(port).sync();//等待服務器關閉channelFuture.channel().closeFuture().sync();}

• 通過NIO將數據流寫入到本地文件

 private void write(InputStream stream, String targetPath) throws IOException {//創建通道FileChannel outChannel = FileChannel.open(Paths.get(targetPath), StandardOpenOption.CREATE, StandardOpenOption.WRITE);ReadableByteChannel inChannel = Channels.newChannel(stream);//創建緩沖區ByteBuffer buffer = ByteBuffer.allocate(2048);//寫入和讀取while (inChannel.read(buffer) != -1) {//調整緩沖區的位置以便讀取，將位置調整到0buffer.flip();outChannel.write(buffer);//將緩沖區未讀取的位置移動到起始位置buffer.compact();}buffer.flip();//判斷是否有剩余內容while (buffer.hasRemaining()) {outChannel.write(buffer);}}