怎么理解Netty中的NIO阻塞通信

本篇內容主要講解“怎么理解Netty中的NIO阻塞通信”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“怎么理解Netty中的NIO阻塞通信”吧!

成都創新互聯服務項目包括龍江網站建設、龍江網站制作、龍江網頁制作以及龍江網絡營銷策劃等。多年來，我們專注于互聯網行業，利用自身積累的技術優勢、行業經驗、深度合作伙伴關系等，向廣大中小型企業、政府機構等提供互聯網行業的解決方案，龍江網站推廣取得了明顯的社會效益與經濟效益。目前，我們服務的客戶以成都為中心已經輻射到龍江省份的部分城市，未來相信會繼續擴大服務區域并繼續獲得客戶的支持與信任！

NIO 完成網絡通信的三個核心：Channel、Buffer、Selector

1、通道（Channel）：負責連接

SocketChannel、ServerSocketChannel、DatagramChannel、Pipe.SinkChannel、Pipe.SourceChannel

2、緩沖區（Buffer）：負責數據的存取

3、 選擇器（Selector）：是 SelectableChannel 的多路復用器。用于監控 SelectableChannel 的 IO 狀況

1、阻塞網絡通信copy數據

//客戶端
@Test
public void client() throws IOException{
   //1. 獲取通道
   SocketChannel sChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 8085));
   
   FileChannel inChannel = FileChannel.open(Paths.get("/Users/tentsuuhou/Desktop/777.txt"), StandardOpenOption.READ);
   
   //2. 分配指定大小的緩沖區
   ByteBuffer buf = ByteBuffer.allocate(1024);
   
   //3. 讀取本地文件，并發送到服務端
   while(inChannel.read(buf) != -1){
      buf.flip();
      sChannel.write(buf);
      buf.clear();
   }
   
   //4. 關閉通道
   inChannel.close();
   sChannel.close();
}

//服務端
@Test
public void server() throws IOException{
   //1. 獲取通道
   ServerSocketChannel ssChannel = ServerSocketChannel.open();
   
   FileChannel outChannel = FileChannel.open(Paths.get("/Users/tentsuuhou/Desktop/666.txt"), StandardOpenOption.WRITE, StandardOpenOption.CREATE);
   
   //2. 綁定連接
   ssChannel.bind(new InetSocketAddress(8085));
   
   //3. 獲取客戶端連接的通道
   SocketChannel sChannel = ssChannel.accept();
   
   //4. 分配指定大小的緩沖區
   ByteBuffer buf = ByteBuffer.allocate(1024);
   
   //5. 接收客戶端的數據，并保存到本地
   while(sChannel.read(buf) != -1){
      buf.flip();
      outChannel.write(buf);
      buf.clear();
   }
   
   //6. 關閉通道
   sChannel.close();
   outChannel.close();
   ssChannel.close();
}

先開啟server端，在開啟client端，這樣就ok了

2、阻塞簡單版client發送server數據

//客戶端
@Test
public void client() throws IOException{
   SocketChannel sChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 8080));

   ByteBuffer buf = ByteBuffer.allocate(1024);

   sChannel.shutdownOutput();
   
   //接收服務端的反饋
   int len = 0;
   while((len = sChannel.read(buf)) != -1){
      buf.flip();
      System.out.println(new String(buf.array(), 0, len));
      buf.clear();
   }
   
   sChannel.close();
}

//服務端
@Test
public void server() throws IOException{
   ServerSocketChannel ssChannel = ServerSocketChannel.open();

   ssChannel.bind(new InetSocketAddress(8080));
   
   SocketChannel sChannel = ssChannel.accept();
   
   ByteBuffer buf = ByteBuffer.allocate(1024);

   
   //發送反饋給客戶端
   buf.put("服務端接收數據成功".getBytes());
   buf.flip();
   sChannel.write(buf);
   
   sChannel.close();
   ssChannel.close();
}

client中，sChannel.shutdownOutput(); 如果沒有這個，處于阻塞狀態，server不知道，只有shutdownOutput()才能提醒server端，這樣就能把client的數據傳到server中。

怎么理解Netty中的NIO阻塞通信