使用多线程以及RandomAccessfile来实现多线程复制文件

Class RandomAccessFile 介绍

• 该类的实例支持读取和写入随机访问文件。 随机访问文件的行为类似于存储在文件系统中的大量字节。 有一种游标，或索引到隐含的数组，称为文件指针 ; 输入操作读取从文件指针开始的字节，并使文件指针超过读取的字节。 如果在读/写模式下创建随机访问文件，则输出操作也可用; 输出操作从文件指针开始写入字节，并将文件指针提前到写入的字节。 写入隐式数组的当前端的输出操作会导致扩展数组。 文件指针可以通过读取getFilePointer方法和由设置seek方法。

• 在这个类中的所有读取例程通常都是如果在读取所需的字节数之前到达文件结尾，则抛出一个EOFException （这是一种IOException ）。 如果任何字节由于除文件末尾之外的任何原因而无法读取，则抛出IOException以外的EOFException 。 特别地，如果流已经被关闭，则可以抛出IOException。

方法摘要:

String	readUTF() 从该文件读取字符串。
void	seek(long pos) 设置文件指针偏移，从该文件的开头测量，发生下一次读取或写入。
void	setLength(long newLength) 设置此文件的长度。
int	skipBytes(int n) 尝试跳过 n字节的输入丢弃跳过的字节。
void	write(byte[] b) 从指定的字节数组写入 b.length个字节到该文件，从当前文件指针开始。
void	write(byte[] b, int off, int len) 从指定的字节数组写入 len个字节，从偏移量 off开始写入此文件。

代码示例:

package com.edu.testThreadDlFile;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.concurrent.TimeUnit;

/**
 * @作者 five-five
 * @创建时间 2020/10/15
 */
public class DownloadUtil {
    private File fromFile;//源文件
    private File toFile;//要拷贝到的地方
    private int threadNum;//线程数量

    //下载的方法
    public void doDownLoad() {
        System.out.println(fromFile.length());
        for (int i=0;i<threadNum;i++){
            MydownLoadThread thread = new MydownLoadThread(i);
            thread.setName("线程"+(i+1));
            System.out.println(thread.getName()+"的任务量是	"+thread.getBlockSize());
            thread.start();
        }
        System.out.println("文件上传完毕");
    }

    public DownloadUtil() {
    }

    public DownloadUtil(File fromFile, File toFile, int threadNum) {
        this.fromFile = fromFile;
        this.toFile = toFile;
        this.threadNum = threadNum;
    }

    class MydownLoadThread extends Thread {

        private volatile int index;//表示第几个线程
        private long blockSize = fromFile.length() % threadNum == 0
                ? fromFile.length() / threadNum
                : fromFile.length() / threadNum + (fromFile.length() % threadNum); //每个线程下载的文件大小
        private volatile long startPos;//起始位置

        /**
         * 第多少个线程
         *
         * @param index
         */
        public MydownLoadThread(int index) {
            this.index = index;
            startPos = index * blockSize;//计算下载了多少
        }

        @Override
        public void run() {
            RandomAccessFile rf = null;
            RandomAccessFile wf = null;
            try {
//                System.out.println("起始位置"+startPos);
                //"r", "rw", "rws", or "rwd"
                rf = new RandomAccessFile(fromFile, "r");//只读
                wf = new RandomAccessFile(toFile, "rw");//只写
                rf.seek(startPos);
                wf.seek(startPos);
                byte[] buf = new byte[1024 * 1024];//缓存区为1MB
                int len = -1;
                do {
                    //记录每次读取的大小(缓冲区可能大于线程任务量)
                    len = blockSize > buf.length ? buf.length : (int) blockSize;
                    //io操作
                    rf.read(buf, 0, len);
                    wf.write(buf, 0, len);
                    blockSize -= len;
                    System.out.println(Thread.currentThread().getName() + "读取了" + len + "个字节");
                } while (blockSize>0);
                wf.close();
                rf.close();
//                TimeUnit.SECONDS.sleep(1);//每次睡一秒
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        public int getIndex() {
            return index;
        }

        public void setIndex(int index) {
            this.index = index;
        }

        public long getBlockSize() {
            return blockSize;
        }

        public void setBlockSize(long blockSize) {
            this.blockSize = blockSize;
        }

        public long getStartPos() {
            return startPos;
        }

        public void setStartPos(long startPos) {
            this.startPos = startPos;
        }
    }

    public File getFromFile() {
        return fromFile;
    }

    public void setFromFile(File fromFile) {
        this.fromFile = fromFile;
    }

    public File getToFile() {
        return toFile;
    }

    public void setToFile(File toFile) {
        this.toFile = toFile;
    }

    public int getThreadNum() {
        return threadNum;
    }

    public void setThreadNum(int threadNum) {
        this.threadNum = threadNum;
    }
}

package com.edu.testThreadDlFile;

import java.io.File;

/**
 *
 * @作者 five-five
 * @创建时间 2020/10/15
 */
public class TestRandomAccessFile {
    public static void main(String[] args) throws Exception {
        File from=new File("D:\图片\Saved Pictures\图片\街道.jpg");
        File to=new File("C:\Users\15713\Desktop\新建文件夹\"+from.getName());
        DownloadUtil downloadUtil = new DownloadUtil(from,to,8);
        downloadUtil.doDownLoad();
    }
}

控制台截图: