Netty三大核心组件之Channel

左手的ㄟ右手 2023-06-18 09:58 17阅读 0赞

所有的 NIO 操作始于通道，通道是数据来源或数据写入的目的地，主要地，我们将关心 java.nio 包中实现的以下几个 Channel：

![format_png][]

FileChannel：文件通道，用于文件的读和写。

DatagramChannel：用于UDP连接的接收和发送

SocketChannel：TCP客户端

ServerSocketChannel:TCP服务端，监听某个端口进来的请求。

Channel 经常翻译为通道，类似 IO 中的流，用于读取和写入。它与前面介绍的 Buffer 打交道，读操作的时候将 Channel 中的数据填充到 Buffer 中，而写操作时将 Buffer 中的数据写入到 Channel 中。

![format_png 1][]

![format_png 2][]

### SocketChannel ###

打开一个TCP链接：

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>SocketChannel socketChannel = SocketChannel&lt;br&gt;　　.open(</code><code>new</code> <code>InetSocketAddress(</code><code>"127.0.0.1"</code><code>, </code><code>80</code><code>));</code> </td> 
 </tr> 
 </tbody> 
</table>

当然了，上面的这行代码等价于下面的两行：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 </td> 
 <td> <code>// 打开一个通道</code> <code>SocketChannel socketChannel = SocketChannel.open();</code> <code>// 发起连接</code> <code>socketChannel.connect(</code><code>new</code> <code>InetSocketAddress(</code><code>"127.0.0.1"</code><code>, </code><code>80</code><code>));</code> </td> 
 </tr> 
 </tbody> 
</table>

SocketChannel 的读写和 FileChannel 没什么区别，就是操作缓冲区。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>// 读取数据</code> <code>socketChannel.read(buffer);</code> &nbsp; <code>// 写入数据到网络连接中</code> <code>while</code><code>(buffer.hasRemaining()) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>socketChannel.write(buffer);&nbsp;&nbsp; </code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

### ServerSocketChannel ###

ServerSocketChannel 用于监听机器端口，管理从这个端口进来的 TCP 连接。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>// 实例化</code> <code>ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();</code> <code>// 监听 8080 端口</code> <code>serverSocketChannel.socket().bind(</code><code>new</code> <code>InetSocketAddress(</code><code>8080</code><code>));</code> &nbsp; <code>while</code> <code>(</code><code>true</code><code>) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 一旦有一个 TCP 连接进来，就对应创建一个 SocketChannel 进行处理</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>SocketChannel socketChannel = serverSocketChannel.accept();</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

这里我们看到了SocketChannel的第二个实例化方式。

到这里，我们应该能理解SocketChannel了，它不仅仅是TCP客户端，它代表的是一个网络通道，可读可写。

ServerSocketChannel不和Buffer打交道了，因为它并不实际处理数据，一旦接到请求，就会实例化一个SocketChannel，之后再这个简介通道上传递的数据它就不管了，它会继续监听端口等待下一个连接。

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9pbWcyMDE4LmNuYmxvZ3MuY29tL2Jsb2cvODExMzM2LzIwMTgxMS84MTEzMzYtMjAxODExMDcyMjQ2MTA3ODgtMTU4MDg3MDM4Mi5wbmc?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9pbWcyMDE4LmNuYmxvZ3MuY29tL2Jsb2cvODExMzM2LzIwMTgxMS84MTEzMzYtMjAxODExMDcyMjUzMTgzNTEtMzI0MzQ4NjMucG5n?x-oss-process=image/format,png
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9pbWcyMDE4LmNuYmxvZ3MuY29tL2Jsb2cvODExMzM2LzIwMTgxMS84MTEzMzYtMjAxODExMDcyMjUzNTE0OTEtNTI3NzA3ODg5LnBuZw?x-oss-process=image/format,png