java代码实现零拷贝 java代码实现零拷贝的方法

RocketMq中零拷贝

说起零拷贝之前，先来了解下服务器中文件数据通过网络传输到客户端的流程。作为应用服务器，其中会有很多从磁盘中读取数据，然后应用程序对加载到内存中的数据进行处理，然后通过网卡发送给客户端，传统数据处理通过以下两个函数实现：

创新互联于2013年成立，是专业互联网技术服务公司，拥有项目网站建设、网站制作网站策划，项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命，1280元天元做网站,已为上家服务,为天元各地企业和个人服务,联系电话:18982081108

在这个过程中，数据流转的大致过程如下：

可以见到，在这个过程中发生了2次cpu copy和2次DMA copy，以及发生了数次cpu状态切换。 这个操作对于应用服务器来说很频繁，因此带来的开销也是非常大。

因此所谓的零拷贝就是，让其中的2次cpu拷贝省略掉，因为这两次cpu拷贝的数据其实已经在内存中，没有必要再让cpu参与进来进行数据的拷贝，浪费cpu。在大量文件读写的时候，这个优化带来的收益还是比较可观的。

零拷贝的实现方式有两种：

mmap通过虚拟内存映射，让多个虚拟地址指向同一个物理内存地址，用户空间的虚拟地址和内核空间的虚拟地址指向同一个物理内存地址，这样用户空间和内核空间共享同一个内存数据。这样DMA引擎从磁盘上加载的数据不需要在内核空间和用户空间进行复制，减少了一次cpu拷贝。

sendfile通过系统调用，并且规定了in_fd文件描述符必须是可以mmap的，sendfile只能将文件数据发送到socket中，sendfile减少了一次cpu状态的切换

无论是mmap结合write方式还是sendfile方式都只是减少了一次cpu拷贝，而后DMA引擎还具有了收集功能，可以在内核缓存区发送到socket缓冲区的时候避免掉cpu复制，只是将缓冲区地址和数据长度发送给socket缓冲区，然后DMA引擎通过收集功能直接读取收集数据发送到网卡中。这里依赖DMA引擎的收集功能省略掉了最后一次cpu拷贝，到此才是真正的零拷贝。

所谓的零拷贝就是避免数据在内核空间缓存区和用户空间缓缓冲区之间的复制，避免掉2次cpu复制，释放cpu。

在RocketMq中采用的是mmap()结合write()方式来实现零拷贝。

在java中还可以通过FileChannel.transferTo()来实现数据从文件描述符传输到socket中，它的底层是通过sendfile系统调用来实现。

利用JAVA语言编写一个 名为copy的程序 实现文件的拷贝功能，应该怎样做？

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

public class Copy {

/**

* @param args

*/

public static void main(String[] args) {

// TODO Auto-generated method stub

if(args.length!=2){

System.out.print("没有输入正确数目的参数，程序退出！");

System.exit(0);

}

File fileS = new File("./"+args[0]);

File fileD = new File("./"+args[1]);

if(fileD.exists())System.out.println("目标文件 "+args[1]+" 已存在！");

byte[] temp = new byte[50];

int totalSize = 0;

try {

FileInputStream fr = new FileInputStream(fileS);

FileOutputStream fo = new FileOutputStream(fileD);

int length = 0;

while((length = fr.read(temp, 0, temp.length)) != -1){

totalSize += length;

fo.write(temp, 0, length);

}

System.out.println("文件 "+args[0]+" 有 "+totalSize+" 个字节");

System.out.println("复制完成！");

} catch (FileNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

System.out.println("源文件 "+args[0]+" 不存在！");

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

java如何拷贝文件到另一个目录下

下面列举出4种方式：

1、使用FileStreams复制

这是最经典的方式将一个文件的内容复制到另一个文件中。 使用FileInputStream读取文件A的字节，使用FileOutputStream写入到文件B。正如你所看到的我们执行几个读和写操作try的数据,所以这应该是一个低效率的,下一个方法我们将看到新的方式。 这是第一个方法的代码:

2、使用FileChannel复制

Java NIO包括transferFrom方法,根据文档应该比文件流复制的速度更快。 这是第二种方法的代码:

3、使用Commons IO复制

Apache Commons IO提供拷贝文件方法在其FileUtils类,可用于复制一个文件到另一个地方。它非常方便使用Apache Commons FileUtils类时,您已经使用您的项目。基本上,这个类使用Java NIO FileChannel内部。 这是第三种方法的代码:

4、使用Java7的Files类复制

如果你有一些经验在Java 7中你可能会知道,可以使用复制方法的Files类文件,从一个文件复制到另一个文件。 这是第四个方法的代码:

怎样用java程序实现文件拷贝

通过输入输出流解决此问题，具体的可以查看JDK的API，实在不会的话，百度一下应该都有一堆这方面的代码。