java多线程读取大文件（日后还会复盘）

首先讲解一下Java RandomAccessFile用法：

动态读取文件内容：所谓动态读取是指从文件的任意位置开始访问文件，而不是必须从文件开始位置读取到文件末尾。动态读取需要用到 Java 中的 RandomAccessFile 类。

• RandomAccessFile 是 Java 输入/输出流体系中功能最丰富的文件内容访问类，它提供了众多的方法来访问文件内容，它既可以读取文件内容，也可以向文件输出数据。由于 RandomAccessFile 可以从任意位置访问文件，所以在只需要访问文件部分内容的情况下，使用 RandonAccessFile 类是一个很好的选择。

• RandomAccessFile 对象包含了一个记录指针，用以标识当前读写处的位置，当程序新创建一个 RandomAccessFile 对象时，该对象的文件记录指针位于文件头（也就是 0 处），当读/写了 n 个字节后，文件记录指针将会向后移动 n 个字节。除此之外，RandonAccessFile 可以自由移动该记录指针，既可以向前移动，也可以向后移动。

RandomAccessFile 类中提供了一些常用读取和写入数据的方法，如表 1 所示。

RandomAccessFile 类的构造方法有如下两种重载形式。

• RandomAccessFile(File file, String mode)：访问参数 file 指定的文件，访问形式由参数 mode 指定，mode 参数有两个常用的可选值 r 和 rw，其中 r 表示只读，rw 表示读写。

• RandomAccessFile(String name, String mode)：访问参数 name 指定的文件，mode 参数的含义同上。

注意：如果使用 rw 方式声明 RandomAccessFile 对象时，要写入的文件不存在，系统将自动进行创建。

例 1

编写一个程序，使用 RandomAccessFileDemo 类创建一个 words.txt 文件，然后写入一个长中文字符串，再从第 6 个字节开始读取并输出。:

1:创建一个 RandomAccessFileDemo 类对象。在 main() 方法中创建到 D:\JavaCodes\words.txt 的 File 对象，如果该文件已经存在则先删除再创建，代码如下所示:

public class RandomAccessFileDemo {
    public static void main(String[] args) {
        try {
            File file = new File("D:\\myJava\\words.txt"); // 指定文件路径
            if (file.exists()) { // 判断文件是否存在
                file.delete();
                file.createNewFile();
            }
        } catch (IOException e) {
            System.out.print(e);
        }
    }
}

2：创建 RandomAccessFile 对象，以读写方式操作 File 对象。定义一个要写入的字符串，再将其进行格式的转换。这样是为了使其写入文件的内容不出现乱码，再将转换后的内容写入文件，代码如下所示。

RandomAccessFile raf = new RandomAccessFile(file,"rw");
String str1 = "晴天，阴天，多云，小雨，大风，中雨，小雪，雷阵雨";    // 要写入的字符串
String str2 = new String(str1.getBytes("GBK"),"ISO-8859-1");    // 编码转换
raf.writeBytes(str2);    //写入文件

3）打印出当前指针的位置，然后将其移动到第 6 个字节。再定义一个长度为 2 的 byte 数组，然后开始进行内容的循环读取，将读出的内容以字符串的形式输出到控制台，代码如下所示。

System.out.println("当前文件指针的位置：" + raf.getFilePointer());
raf.seek(6); // 移动文件指针
System.out.println("从文件头跳过6个字节，现在文件内容如下：");
byte[] buffer = new byte[2];
int len = 0;
while ((len = raf.read(buffer, 0, 2)) != -1) {
    System.out.print(new String(buffer, 0, len)); // 输出文件内容
}

4）运行程序，程序运行结果如下所示，显示了写入字符串后指针的位置，以及从文件开关跳过 6 个字节后读取到的字符串，图 1 为写入文件中的字符串内容：

当前文件指针的位置：48
从文件头跳过6个字节，现在文件内容如下：
阴天，多云，小雨，大风，中雨，小雪，雷阵雨

开启任务：代码实现

import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;

class CopyFileThread extends Thread{
    private RandomAccessFile in;
    private RandomAccessFile out;
    private long start;
    private long end;

    /**
     * 
     * @param in 源文件地址
     * @param out 目标文件地址
     * @param start 分段复制的开始位置
     * @param end  分段复制的结束位置
     */
    public CopyFileThread(String in, String out,
            long start, long end){
        this.start = start;
        this.end = end;
        try {
            this.in = new RandomAccessFile(in, "rw");
            this.out = new RandomAccessFile(out, "rw");
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
    }

    public void run(){
        try {
            in.seek(start);
            out.seek(start);
            int hasRead = 0;
            byte[] buff = new byte[1024*1024];
            while(start<end && (hasRead = in.read(buff)) != -1){
                start += hasRead;
                out.write(buff, 0, hasRead);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                in.close();
                out.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

public class ThreadsCopyFile {

    /**
     * 
     * @param sourcePath 源文件路径
     * @param targetPath 目标文件路径
     * @param ThreadNums 设定的线程数
     * @throws IOException
     */
    public void startCopy(String sourcePath, String targetPath, int ThreadNums)
            throws IOException{
        long fileLength = new File(sourcePath).length();
        //很有可能文件长度线程不能均分下载，预留一个线程复制最后剩余的部分
        long segmentLength = fileLength/(ThreadNums-1);
        int i;
        for (i = 0; i < ThreadNums-1; i++) {
            new CopyFileThread(sourcePath, targetPath, i*segmentLength, (i+1)*segmentLength).start();
        }
        new CopyFileThread(sourcePath, targetPath, i*segmentLength, fileLength).start();
    }


    public static void main(String[] args) throws IOException {
    //demo中实现的是将e盘中这个目录下的电影复制到d盘下的tttt.rmvb
        ThreadsCopyFile tcf = new ThreadsCopyFile();
        String sourcePath = "E:\\NewFile\\AppData\\Xunlei\\[阳光电影www.ygdy8.com].金刚狼3：殊死一战.HD.720p.中英双字幕.rmvb";
        String targetPath = "D:\\tttt.rmvb";
        tcf.startCopy(sourcePath, targetPath, 3);
    }
}