Java NIO系列教程（二） Channel

男娘i 2022-01-26 12:01 253阅读 0赞

[原文链接][Link 1] **作者：**Jakob Jenkov **译者：**airu **校对：**丁一

Java NIO的通道类似流，但又有些不同：

*  既可以从通道中读取数据，又可以写数据到通道。但流的读写通常是单向的。
 *  通道可以异步地读写。
 *  通道中的数据总是要先读到一个Buffer，或者总是要从一个Buffer中写入。

正如上面所说，从通道读取数据到缓冲区，从缓冲区写入数据到通道。如下图所示：

![overview-channels-buffers.png][]

### Channel的实现 ###

这些是Java NIO中最重要的通道的实现：

*  FileChannel
 *  DatagramChannel
 *  SocketChannel
 *  ServerSocketChannel

FileChannel 从文件中读写数据。

DatagramChannel 能通过UDP读写网络中的数据。

SocketChannel 能通过TCP读写网络中的数据。

ServerSocketChannel可以监听新进来的TCP连接，像Web服务器那样。对每一个新进来的连接都会创建一个SocketChannel。

### 基本的 Channel 示例 ###

下面是一个使用FileChannel读取数据到Buffer中的示例：

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td> <code>RandomAccessFile aFile = </code><code>new</code> <code>RandomAccessFile(</code><code>"data/nio-data.txt"</code><code>, </code><code>"rw"</code><code>);</code> </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>02</code></td> 
   <td><code>FileChannel inChannel = aFile.getChannel();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>04</code></td> 
   <td> <code>ByteBuffer buf = ByteBuffer.allocate(</code><code>48</code><code>);</code> </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>06</code></td> 
   <td> <code>int</code> <code>bytesRead = inChannel.read(buf);</code> </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td> <code>while</code> <code>(bytesRead != -</code><code>1</code><code>) { </code> </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>09</code></td> 
   <td> <code>System.out.println(</code><code>"Read "</code> <code>+ bytesRead);</code> </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>12</code></td> 
   <td> <code>while</code><code>(buf.hasRemaining()){ </code> </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>13</code></td> 
   <td> <code>System.out.print((</code><code>char</code><code>) buf.get());</code> </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>16</code></td> 
   <td><code>buf.clear();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>17</code></td> 
   <td><code>bytesRead = inChannel.read(buf);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>19</code></td> 
   <td><code>aFile.close();</code></td> 
  </tr> 
 </tbody> 
</table>

注意 buf.flip() 的调用，首先读取数据到Buffer，然后反转Buffer,接着再从Buffer中读取数据。下一节会深入讲解Buffer的更多细节。

[Link 1]: http://tutorials.jenkov.com/java-nio/channels.html
[overview-channels-buffers.png]: /images/20220126/14a66ec63d56446eaa208eb66edd770f.png