【NIO】Channel（通道）

灰太狼 2022-05-31 08:56 278阅读 0赞

# 前言 #

Github：[https://github.com/yihonglei/jdk-source-code-reading][https_github.com_yihonglei_jdk-source-code-reading]（java-nio）

# 一 Channel 概述 #

**通道 Channel 由 java.nio.channels 包定义。Channel 表示 IO 源与目标打开的连接。**

Java NIO 的通道类似流，Channel 本身不能直接访问数据，Channel 只能与 Buffer 进行交互。

既可以从通道中读取数据，又可以写数据到通道，通道可以异步地读写。

通道中的数据总是要先读到一个 Buffer，或者总是要从一个 Buffer 中写入。

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

![Center][]

# 二 Channel 实现 #

**如下是 Java NIO 中最重要的通道的实现。**

**FileChannel**

从文件中读写数据。

**DatagramChannel**

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

**SocketChannel**

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

**ServerSocketChannel**

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

# 三 Channel 实例 #

通过 Java NIO 复制文件实例。

package com.jpeony.nio.channel;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.nio.ByteBuffer;
    import java.nio.channels.FileChannel;
    
    /**
     * 基于NIO完成文件复制
     *
     * @author yihonglei
     */
    public class ChannelCopyFileTest {
        public static void main(String[] args) {
            // 源文件
            File fromFile = new File("/Users/yihonglei/tmp/hello.txt");
            // 目标文件
            File toFile = new File("/Users/yihonglei/tmp/hello-copy.txt");
            try (
                    // 根据源文件创建文件输入流
                    FileInputStream fis = new FileInputStream(fromFile);
                    // 根据目标文件创建文件输入流，如果文件不存在，自动创建
                    FileOutputStream fos = new FileOutputStream(toFile);
    
                    //1、获取通道
                    FileChannel inChannel = fis.getChannel();
                    FileChannel outChannel = fos.getChannel();
            ) {
                // 2、分配指定大小缓冲区
                ByteBuffer buffer = ByteBuffer.allocate(48);
    
                // 3、将通道的数据读取到缓冲区
                while (inChannel.read(buffer) != -1) {
                    // 切换模式
                    buffer.flip();
    
                    //4、从缓冲区写入到通道
                    outChannel.write(buffer);
    
                    //5、清空缓冲区
                    buffer.clear();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

`注意 buf.flip() 的调用，首先读取数据到 Buffer，然后反转 Buffer，接着再从 Buffer 中读取数据。`

[https_github.com_yihonglei_jdk-source-code-reading]: https://github.com/yihonglei/jdk-source-code-reading
[Center]: /images/20220531/35d34234660f494f9cc95165fcb6dffd.png