FileChannel指南

Stella981
• 阅读 599

推荐关注公众号:锅外的大佬

每日推送国外技术好文,帮助每位开发者更优秀地成长

FileChannel指南

原文链接:https://www.baeldung.com/java-filechannel

作者:baeldung

译者:Leesen

1.概述

在这篇速学教程中,我们将研究Java NIO库中提供的FileChannel类,讨论如何使用FileChannelByteBuffer读写数据,探讨使用FileChannel以及其他文件操作特性的优点。

2.FileChannel的优点

FileChannel的优点包括:

  • 在文件特定位置进行读写操作
  • 将文件一部分直接加载到内存,这样效率更高
  • 以更快的速度将文件数据从一个通道传输到另一个通道
  • 锁定文件的某一部分来限制其他线程访问
  • 为了避免数据丢失,强制立即将更新写入文件并存储

3.FileChannel读操作

当我们读取一个大文件时,FileChannel标准I/O执行得更快。需要注意,虽然FileChannelJava NIO的一部分,但是FileChannel操作是阻塞的,并且没有非阻塞模式。

3.1.使用FileChannel读取文件

先了解如何使用FileChannel读取一个文件,该文件包含:

 Hello world

下面测试读取文件,并检查是否ok:

@Test
public void givenFile_whenReadWithFileChannelUsingRandomAccessFile_thenCorrect() throws IOException { try (RandomAccessFile reader = new RandomAccessFile("src/test/resources/test_read.in", "r"); FileChannel channel = reader.getChannel(); ByteArrayOutputStream out = new ByteArrayOutputStream()) { int bufferSize = 1024; if (bufferSize > channel.size()) { bufferSize = (int) channel.size(); } ByteBuffer buff = ByteBuffer.allocate(bufferSize); while (channel.read(buff) > 0) { out.write(buff.array(), 0, buff.position()); buff.clear(); } String fileContent = new String(out.toByteArray(), StandardCharsets.UTF_8); assertEquals("Hello world", fileContent); } } 

这里使用FileChannelRandomAccessFileByteBuffer从文件中读取字节。还应该注意,多个并发线程可以安全地使用FileChannel。但是,每次只允许一个线程执行涉及更新通道位置(channel position)或更改其文件大小的操作。这会阻止其他试图执行类似操作的线程,直到前一个操作完成。
但是,显式提供通道位置的操作可以并发运行且不会被阻塞。

3.2.打开FileChannel

为了使用FileChannel读取文件,我们必须打开它(Open FileChannel)。看看如何使用RandomAccessFile打开FileChannel:

RandomAccessFile reader = new RandomAccessFile(file, "r");
FileChannel channel = reader.getChannel();

模式“r”表示通道仅为“只读“,注意,关闭RandomAccessFile也将关闭与之关联的通道。
接下来,使用FileInputStream打开一个FileChannel来读取文件:

FileInputStream fin= new FileInputStream(file);
FileChannel channel = fin.getChannel();

同样的,关闭FileInputStream也会关闭与之相关的通道。

3.3.从FileChannel中读取数据

为了读取数据,我们可以使用只读模式。接下来看看如何读取字节序列,我们将使用ByteBuffer来保存数据:

ByteBuffer buff = ByteBuffer.allocate(1024);
int noOfBytesRead = channel.read(buff);
String fileContent = new String(buff.array(), StandardCharsets.UTF_8);

assertEquals("Hello world", fileContent);

然后,我们将看到如何从文件某个位置开始读取一个字节序列:

ByteBuffer buff = ByteBuffer.allocate(1024);
int noOfBytesRead = channel.read(buff, 5);
String fileContent = new String(buff.array(), StandardCharsets.UTF_8);
assertEquals("world", fileContent); 

我们应该注意:需要使用字符集(Charset)将字节数组解码为字符串
我们指定原始编码字节的字符集。没有它,我们可能会以断章取义的文字结束。特别是像UTF-8UTF-16这样的多字节编码可能无法解码文件的任意部分,因为一些多字节字符可能是不完整的。

4.FileChannel写操作

4.1.使用FileChannel写入文件

我们来探究下如何使用FileChannel写:

@Test
public void whenWriteWithFileChannelUsingRandomAccessFile_thenCorrect() throws IOException { String file = "src/test/resources/test_write_using_filechannel.txt"; try (RandomAccessFile writer = new RandomAccessFile(file, "rw"); FileChannel channel = writer.getChannel()){ ByteBuffer buff = ByteBuffer.wrap("Hello world".getBytes(StandardCharsets.UTF_8)); channel.write(buff); // verify RandomAccessFile reader = new RandomAccessFile(file, "r"); assertEquals("Hello world", reader.readLine()); reader.close(); } } 

4.2.打开FileChannel

要使用FileChannel写入文件,必须先打开它。使用RandomAccessFile打开一个FileChannel:

RandomAccessFile writer = new RandomAccessFile(file, "rw");
FileChannel channel = writer.getChannel();

模式“rw”表示通道为“读写”。
使用FileOutputStream打开FileChannel:

FileOutputStream fout = new FileOutputStream(file);
FileChannel channel = fout.getChannel();

4.3.FileChannel写入数据

使用FileChannel写数据,可以使用其中的某个写方法。
我们来看下如何写一个字节序列,使用ByteBuffer来存储数据:

ByteBuffer buff = ByteBuffer.wrap("Hello world".getBytes(StandardCharsets.UTF_8));
channel.write(buff);

接下来,我们将看到如何从文件某个位置开始写一个字节序列:

ByteBuffer buff = ByteBuffer.wrap("Hello world".getBytes(StandardCharsets.UTF_8));
channel.write(buff, 5);

5.当前位置

FileChannel允许我们获得和改变读或写的位置(position)。获得当前的位置:

long originalPosition = channel.position();

设置位置:

channel.position(5);
assertEquals(originalPosition + 5, channel.position());

6.获取文件大小

使用FileChannel.size方法获取文件大小(以字节为单位):

@Test
public void whenGetFileSize_thenCorrect() throws IOException { RandomAccessFile reader = new RandomAccessFile("src/test/resources/test_read.in", "r"); FileChannel channel = reader.getChannel(); // the original file size is 11 bytes. assertEquals(11, channel.size()); channel.close(); reader.close(); } 

7.截断文件

使用FileChannel.truncate方法将文件截断为给定的大小(以字节为单位):

@Test
public void whenTruncateFile_thenCorrect() throws IOException { String input = "this is a test input"; FileOutputStream fout = new FileOutputStream("src/test/resources/test_truncate.txt"); FileChannel channel = fout.getChannel(); ByteBuffer buff = ByteBuffer.wrap(input.getBytes()); channel.write(buff); buff.flip(); channel = channel.truncate(5); assertEquals(5, channel.size()); fout.close(); channel.close(); } 

8.强制更新

由于性能原因,操作系统可能缓存文件更改,如果系统崩溃,数据可能会丢失。要强制文件内容和元数据不断写入磁盘,我们可以使用force方法:

channel.force(true);

仅当文件存储在本地设备上时,才能保证该方法有效。

9.将文件部分加载到内存

使用FileChannel.map方法将文件的部分加载到内存中。使用FileChannel.MapMode.READ_ONLY以只读模式打开文件:

@Test
public void givenFile_whenReadAFileSectionIntoMemoryWithFileChannel_thenCorrect() throws IOException { try (RandomAccessFile reader = new RandomAccessFile("src/test/resources/test_read.in", "r"); FileChannel channel = reader.getChannel(); ByteArrayOutputStream out = new ByteArrayOutputStream()) { MappedByteBuffer buff = channel.map(FileChannel.MapMode.READ_ONLY, 6, 5); if(buff.hasRemaining()) { byte[] data = new byte[buff.remaining()]; buff.get(data); assertEquals("world", new String(data, StandardCharsets.UTF_8)); } } } 

类似地,可以使用FileChannel.MapMode.READ_WRITE以读写模式打开文件。还可以使用FileChannel.MapMode.PRIVATE模式,该模式下,更改不应用于原始文件。

10.锁定文件部分

来看下如何锁定文件某一部分,使用FileChannel.tryLock方法阻止对文件某一部分进行高并发访问。

@Test
public void givenFile_whenWriteAFileUsingLockAFileSectionWithFileChannel_thenCorrect() throws IOException { try (RandomAccessFile reader = new RandomAccessFile("src/test/resources/test_read.in", "rw"); FileChannel channel = reader.getChannel(); FileLock fileLock = channel.tryLock(6, 5, Boolean.FALSE )){ //do other operations... assertNotNull(fileLock); } } 

tryLock方法尝试获取文件部分(file section)上的锁。如果请求的文件部分已被另一个线程阻塞,它将抛出一个OverlappingFileLockException异常。此方法还接受Boolean参数来请求共享锁或独占锁。
我们应该注意到,有些操作系统可能不允许共享锁,默认情况下是独占锁。

11.FileChannel关闭

最后,当使用FileChannel时,必须关闭它。在示例中,我们使用了try-with-resources
如果有必要,我们可以直接使用FileChannel.close方法:

channel.close();

12.总结

在本教程中,我们了解了如何使用FileChannel读取和写入文件。此外,我们还研究了如何读取和更改文件大小及其当前读/写位置,并研究了如何在并发应用程序或数据关键应用程序中使用FileChannel
与往常一样,示例的源代码可以在GitHub上找到。

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
4个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Wesley13 Wesley13
3年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败,请联系管理员!');中国在东8区所以加8方法二:selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
Wesley13 Wesley13
3年前
Java 9 被无情抛弃,Java 8 直接升级到 Java 10!!
!(https://oscimg.oschina.net/oscnet/3e08a942dd884e9ab82b63a1f3c4aada.jpg"未命名文件.jpg")Java技术栈不可错过的Java 技术公众号!(https://oscimg.oschina.net/oscnet/00fcff52518e
Wesley13 Wesley13
3年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Stella981 Stella981
3年前
Docker 部署SpringBoot项目不香吗?
  公众号改版后文章乱序推荐,希望你可以点击上方“Java进阶架构师”,点击右上角,将我们设为★“星标”!这样才不会错过每日进阶架构文章呀。  !(http://dingyue.ws.126.net/2020/0920/b00fbfc7j00qgy5xy002kd200qo00hsg00it00cj.jpg)  2
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
10个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这