本篇內(nèi)容主要講解“怎么理解Netty中的NIO阻塞通信”，感興趣的朋友不妨來(lái)看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來(lái)帶大家學(xué)習(xí)“怎么理解Netty中的NIO阻塞通信”吧!

成都創(chuàng)新互聯(lián)服務(wù)項(xiàng)目包括龍江網(wǎng)站建設(shè)、龍江網(wǎng)站制作、龍江網(wǎng)頁(yè)制作以及龍江網(wǎng)絡(luò)營(yíng)銷策劃等。多年來(lái)，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，龍江網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到龍江省份的部分城市，未來(lái)相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

NIO 完成網(wǎng)絡(luò)通信的三個(gè)核心：Channel、Buffer、Selector

1、通道（Channel）：負(fù)責(zé)連接

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

2、緩沖區(qū)（Buffer）：負(fù)責(zé)數(shù)據(jù)的存取

3、 選擇器（Selector）：是 SelectableChannel 的多路復(fù)用器。用于監(jiān)控 SelectableChannel 的 IO 狀況

1、阻塞網(wǎng)絡(luò)通信copy數(shù)據(jù)

//客戶端
@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. 分配指定大小的緩沖區(qū)
   ByteBuffer buf = ByteBuffer.allocate(1024);
   
   //3. 讀取本地文件，并發(fā)送到服務(wù)端
   while(inChannel.read(buf) != -1){
      buf.flip();
      sChannel.write(buf);
      buf.clear();
   }
   
   //4. 關(guān)閉通道
   inChannel.close();
   sChannel.close();
}

//服務(wù)端
@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. 分配指定大小的緩沖區(qū)
   ByteBuffer buf = ByteBuffer.allocate(1024);
   
   //5. 接收客戶端的數(shù)據(jù)，并保存到本地
   while(sChannel.read(buf) != -1){
      buf.flip();
      outChannel.write(buf);
      buf.clear();
   }
   
   //6. 關(guān)閉通道
   sChannel.close();
   outChannel.close();
   ssChannel.close();
}

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

2、阻塞簡(jiǎn)單版client發(fā)送server數(shù)據(jù)

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

   ByteBuffer buf = ByteBuffer.allocate(1024);

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

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

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

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

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

到此，相信大家對(duì)“怎么理解Netty中的NIO阻塞通信”有了更深的了解，不妨來(lái)實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！