当前位置：首页 > news >正文

# Java NIO（一）FileChannel

news 来源：原创 2024/5/19 1:45:48

Java NIO

1.BIO与NIO的区别

BIO为阻塞IO，NIO为非阻塞IO。

BIO	NIO
JAVA1.4之前	Java 1.4之后
面向流：以byte为单位处理数据	面向块：以块为单位处理数据
同步阻塞	同步非阻塞
无	选择器（Selector）

1.1NIO的核心组成部分

Channels
Channel是双向的，既能做读操作也能做写操作，常见Channel如下：

Channel类	功能
FileChannel	文件数据读写
DtagramChannel	UDP数据读写
ServerScoketChannel和SocketChannel	TCP数据读写

Buffers
缓冲区
Selectors
选择器，用于监听多个通道的事件，可实现单个线程就可以监听多个客户端通道。

2.Channel

Channel封装了对数据源的操作，可以操作多种数据源，但是不必关心数据源的具体物理结构。Channel用于在字节缓冲区和另一侧的实体之间有效地传输数据。

Channel所有数据都是通过Buffer对象进行处理，通道要么读数据到缓冲区，要么从缓冲区写入到通道。

public interface Channle extend Closeable {public boolean isOpen();public void close() throws IOException;
}

2.1 FileChannel

FileChannel常用方法如下;

方法名	作用
public int read(ByteBuffer dst)	从通道读取数据并放到缓冲区中
public int write(ByteBuffer src)	把缓冲区的数据写到通道中
public long transferFrom(ReadableByteChannel src, long position, long count)	从目标通道中复制数据到当前通道
public long transferTo(long position, long count, WritableByteChannel target)	把数据从当前通道复制给目标通道

无法直接打开一个FileChannel，常见的方法是通过inPutStream和outPutStream或RandomAccessFile获取一个FileChannel实例。
示例代码
文件写入示例

package com.hero.nio.file;
import org.junit.Test;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
//通过NIO实现文件IO
public class TestNIO {
@Test //往本地文件中写数据
public void test1() throws Exception{//1. 创建输出流FileOutputStream fos=new FileOutputStream("basic.txt");//2. 从流中得到一个通道FileChannel fc=fos.getChannel();//3. 提供一个缓冲区ByteBuffer buffer=ByteBuffer.allocate(1024);//4. 往缓冲区中存入数据String str="HelloJava";buffer.put(str.getBytes());//5. 翻转缓冲区buffer.flip();while(buffer.hasRemaining（)) {//6. 把缓冲区写到通道中fc.write(buffer);}//7. 关闭fos.close();}
}

文件复制示例

public void test4() throws Exception {//1. 创建两个流FileInputStream fis = new FileInputStream("basic2.txt");FileOutputStream fos = new FileOutputStream("basic3.txt");//2. 得到两个通道FileChannel sourceFC = fis.getChannel();FileChannel destFC = fos.getChannel();//3. 复制destFC.transferFrom(sourceFC, 0, sourceFC.size());//4. 关闭fis.close();fos.close();
}