long size = len / FileCopyUtil.THREAD_NUM + 1;

try (
		BufferedInputStream bis = new BufferedInputStream(new FileInputStream(targetFile));
		RandomAccessFile raf = new RandomAccessFile(outputFile, "rw")){
		bis.skip(position);  
		raf.seek(position);  
		int hasRead = 0;
		byte[] b = new byte[1024];
		long curlen = 0;
		while(curlen < size && (hasRead = bis.read(b)) != -1) {
			raf.write(b, 0, hasRead);
			curlen += (long)hasRead;
		}
		System.out.println(n+" "+position+" "+curlen+" "+size);
	} catch (IOException e) {
		e.printStackTrace();
}

		bis.skip(position);  
		raf.seek(position);  

package dragon;

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

/**
 * 用于進(jìn)行文件復(fù)制，但不是常規(guī)的文件復(fù)制 。
 * 準(zhǔn)備仿照瘋狂Java，寫一個(gè)多線程的文件復(fù)制工具。
 * 即可以本地復(fù)制和網(wǎng)絡(luò)復(fù)制
 * */

/**
 * 設(shè)計(jì)思路：
 * 獲取目標(biāo)文件的大小，然后設(shè)置復(fù)制文件的大?。ㄟ@樣做是有好處的），
 * 然后使用將文件分為 n 分，使用 n 個(gè)線程同時(shí)進(jìn)行復(fù)制（這里我將 n 取為 4）。
 * 
 * 可以進(jìn)一步拓展：
 * 加強(qiáng)為斷點(diǎn)復(fù)制功能，即程序中斷以后，
 * 仍然可以繼續(xù)從上次位置恢復(fù)復(fù)制，減少不必要的重復(fù)開銷
 * */

public class FileCopyUtil {
	//設(shè)置一個(gè)常量，復(fù)制線程的數(shù)量
	private static final int THREAD_NUM = 4;
	
	private FileCopyUtil() {}
	
	/**
	 * @param targetPath 目標(biāo)文件的路徑
	 * @param outputPath 復(fù)制輸出文件的路徑
	 * @throws IOException 
	 * */
	public static void transferFile(String targetPath, String outputPath) throws IOException {
		File targetFile = new File(targetPath);
		File outputFilePath = new File(outputPath);
		if (!targetFile.exists() || targetFile.isDirectory()) {   //目標(biāo)文件不存在，或者是一個(gè)文件夾，則拋出異常
			throw new FileNotFoundException("目標(biāo)文件不存在："+targetPath);
		}
		if (!outputFilePath.exists()) {     //如果輸出文件夾不存在，將會(huì)嘗試創(chuàng)建，創(chuàng)建失敗，則拋出異常。
			if(!outputFilePath.mkdir()) {
				throw new FileNotFoundException("無法創(chuàng)建輸出文件："+outputPath);
			}
		}
		
		long len = targetFile.length();
		
		File outputFile = new File(outputFilePath, "copy"+targetFile.getName());
		createOutputFile(outputFile, len);    //創(chuàng)建輸出文件，設(shè)置好大小。
		
		long[] position = new long[4];
		//每一個(gè)線程需要復(fù)制文件的起點(diǎn)
		long size = len / FileCopyUtil.THREAD_NUM + 1;
		for (int i = 0; i < FileCopyUtil.THREAD_NUM; i++) {
			position[i] = i*size;
			copyThread(i, position[i], size, targetFile, outputFile);
		}
	}
	
	//創(chuàng)建輸出文件，設(shè)置好大小。
	private static void createOutputFile(File file, long length) throws IOException {
		try (   
			RandomAccessFile raf = new RandomAccessFile(file, "rw")){
			raf.setLength(length);
		}
	}
	
	private static void copyThread(int i, long position, long size, File targetFile, File outputFile) {
		int n = i;   //Lambda 表達(dá)式的限制，無法使用變量。
		new Thread(()->{
			try (
				BufferedInputStream bis = new BufferedInputStream(new FileInputStream(targetFile));
				RandomAccessFile raf = new RandomAccessFile(outputFile, "rw")){
				bis.skip(position);  //跳過不需要讀取的字節(jié)數(shù)，注意只能先后跳
				raf.seek(position);  //跳到需要寫入的位置，沒有這句話，會(huì)出錯(cuò)，但是很難改。
				int hasRead = 0;
				byte[] b = new byte[1024];
				/**
				 * 注意，每個(gè)線程只是讀取一部分?jǐn)?shù)據(jù)，不能只以 -1 作為循環(huán)結(jié)束的條件
				 * 循環(huán)退出條件應(yīng)該是兩個(gè)，即寫入的字節(jié)數(shù)大于需要讀取的字節(jié)數(shù) 或者 文件讀取結(jié)束（最后一個(gè)線程讀取到文件末尾）
				 */
				long curlen = 0;
				while(curlen < size && (hasRead = bis.read(b)) != -1) {
					raf.write(b, 0, hasRead);
					curlen += (long)hasRead;
				}
				System.out.println(n+" "+position+" "+curlen+" "+size);
			} catch (IOException e) {
				e.printStackTrace();
			}
		}).start(); 
	}
}

package dragon;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.net.URL;
import java.net.URLConnection;

/*
 * 多線程下載文件：
 * 通過一個(gè) URL 獲取文件輸入流，使用多線程技術(shù)下載這個(gè)文件。
 * */
public class FileDownloadUtil {
	//下載線程數(shù)
	private static final int THREAD_NUM = 4;
	
	/**
	 * @param url 資源位置
	 * @param output 輸出路徑
	 * @throws IOException 
	 * */
	public static void transferFile(String url, String output) throws IOException {
		init(output);
		URL resource = new URL(url);
		URLConnection connection = resource.openConnection();
		
		//獲取文件類型
		String type = connection.getContentType();
		if (type != null) {
			type = "."+type.split("/")[1];
		} else {
			type = "";
		}
		
		//創(chuàng)建文件，并設(shè)置長(zhǎng)度。
		long len = connection.getContentLength();
		String filename = System.currentTimeMillis()+type;
		try (RandomAccessFile raf = new RandomAccessFile(new File(output, filename), "rw")){
			raf.setLength(len);
		}
		
		//為每一個(gè)線程分配相應(yīng)的下載其實(shí)位置
		long size = len / THREAD_NUM + 1;  
		long[] position = new long[THREAD_NUM];

		File downloadFile = new File(output, filename);
		//開始下載文件: 4個(gè)線程
		download(url, downloadFile, position, size);
	}
	
	private static void download(String url, File file, long[] position, long size) throws IOException {
		//開始下載文件: 4個(gè)線程
		for (int i = 0 ; i < THREAD_NUM; i++) {
			position[i] = i * size;   //每一個(gè)線程下載的起始位置
			int n = i;  // Lambda 表達(dá)式的限制，無法使用變量
			new Thread(()->{
				URL resource = null;
				URLConnection connection = null;
				try {
					resource = new URL(url);
					connection = resource.openConnection();
				} catch (IOException e) {
					e.printStackTrace();
				}
				
				try (
					BufferedInputStream bis = new BufferedInputStream(connection.getInputStream());
					RandomAccessFile raf = new RandomAccessFile(file, "rw")){  //每個(gè)流一旦關(guān)閉，就不能打開了
					raf.seek(position[n]);     //跳到需要下載的位置
					bis.skip(position[n]);   //跳過不需要下載的部分
					
					int hasRead = 0;
					byte[] b = new byte[1024];	
					long curlen = 0;
					while(curlen < size && (hasRead = bis.read(b)) != -1) {
						raf.write(b, 0, hasRead); 
						curlen += (long)hasRead;
					}
					System.out.println(n+" "+position[n]+" "+curlen+" "+size);
				} catch (FileNotFoundException e) {
					e.printStackTrace();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}) .start();
		}
	}
	
	private static void init(String output) throws FileNotFoundException {
		File path = new File(output);
		if (!path.exists()) {
			if (!path.mkdirs()) {
				throw new FileNotFoundException("無法創(chuàng)建輸出路徑："+output);
			}
		} else if (path.isFile()) {
			throw new FileNotFoundException("輸出路徑不是一個(gè)目錄："+output);
		}
	}	
}

public File(URI uri)

package dragon;

import java.io.IOException;

public class FileCopyTest {
	public static void main(String[] args) throws IOException {
		//復(fù)制文件
		long start = System.currentTimeMillis();
		try {
			FileCopyUtil.transferFile("D:\\DB\\download\\timg.jfif", "D:\\DBC");
		} catch (IOException e) {
			e.printStackTrace();
		}
		
		long time = System.currentTimeMillis()-start;
		System.out.println("time: "+time);
		
		//下載文件
		start = System.currentTimeMillis();
		FileDownloadUtil.transferFile("https://timgsa.baidu.com/timg?image&quality=80&size=b9999_10000&sec=1578151056184&di=594a34f05f3587c31d9377a643ddd72e&imgtype=0&src=http%3A%2F%2Fn.sinaimg.cn%2Fsinacn%2Fw1600h1000%2F20180113%2F0bdc-fyqrewh5850115.jpg", "D:\\DB\\download");
		System.out.println("time: "+(System.currentTimeMillis()-start));
	}
}