网络多线线程下载并合并文件示例

　　本示例的采用IO流与多线程下载同一张图片，下载完后进行合并；使用方法内创建线程方式，控制主线程的执行时机，即主线程调用方法，方法内创建线程，再返回调用方法的对象，随即往下执行其他程序，可有效防止主线程的其他方法在下载线程（即其他线程）未完成时执行，而出现数据错位缺失。

import java.io.*;
import java.net.URL;
import java.net.URLConnection;

/**
 * Created by gdkong on 07/11/2017.
 */

public class Test {

    public static void main(String[] args) throws IOException, InterruptedException {
        //主线程采用调用方法模式创建其他线程，可让其他线程执行完后才继续执行主线中的其他方法，此方式可控制主线的执行时机
　　　　　　multithreadedDownload ("http://localhost:8080/image/a.jpg","/Users/Shared/abc",3);
    }

    /**
     * 多线程下载并合并文件，仅适用于Http协议，未尝试其他网络协议
     * @param srcPath  下载源文件路径名
     * @param destPath 保存文件夹路径名
     * @param count    指定线程个数
     */
    public static void multithreadedDownload(String srcPath, String destPath, int count) throws IOException, InterruptedException {

        //定义一个文件下载的文件夹路径
        File dir = new File (destPath);
        if (!dir.exists ()) {
            dir.mkdirs ();
        }
        long total = getFileLength (srcPath);
        //开启下载线程
        OpenMultithreadedDownload (srcPath, dir, total, count);

        //获取文件的后缀名
        String suffix = srcPath.substring (srcPath.lastIndexOf ("."));
        //合并文件
        FileUtils.merge (dir, suffix);

        System.out.println ("文件下载完成");
    }

    /**
     * 多线程下载块
     * @param path 下载源文件路径名
     * @param dir 目标文件存储目录
     * @param total 下载源文件大小
     * @param count 指定线程个数
     */
    private static void OpenMultithreadedDownload(String path, File dir, long total, int count) throws InterruptedException {

        //计算出每个线程平均现在的字节个数
        long size = total / count;
        //使用循环，计算每个线程下载开始和结束位置
        for (int i = 1; i <= count; i++) {
            //开始位置
            long starIndex = (i - 1) * size;
            //结束位置
            long endIndex = i * size - 1;
            //最后一个线程
            if (i == 3) {
                endIndex = total - 1;
            }
            DownloadThread dt = new DownloadThread (path, dir, starIndex, endIndex, i);
            dt.start ();
        }
    }

    /**
     * 获取下载源文件大小
     * @param path 下载源文件路径名
     * */
    public static long getFileLength(String path) throws IOException {

        URL url = new URL (path);
        //获得连接对象
        URLConnection con = url.openConnection ();
        long total = con.getContentLengthLong ();
        return total;
    }
    /**
     * 合并文件功能
     * @param dir 源文件存储的父目录
     * @param suffix 文件的后缀名，用于过滤文件
     */
    public static void merge(File dir,String suffix) throws IOException {

        File[] files = dir.listFiles (FileUtils.getFileFilter (suffix,false));
        FileOutputStream fos = getFileOutputStream (dir, files[0]);

        for(File file : files){
            FileInputStream fis = new FileInputStream (file);
            int len;
            byte[] buf = new byte[8192];
            while ((len=fis.read (buf)) != -1){
                fos.write (buf,0,len);
            }
            fis.close ();
            //把已经合并过的文件删除
            file.delete ();
        }
        fos.close ();
    }
    //获取合并文件输出流
    private static FileOutputStream getFileOutputStream(File dir, File file) throws FileNotFoundException {
        File file1 = file;
        String name = file1.getName ();
        name = name.substring (1);
        File destFile = new File (dir,name);
        return new FileOutputStream (destFile);
    }
    /**
     * 文件过滤器
     * @param suffix 文件后缀名
     * @param containDirectory 是否显示子文件夹文件，true为显示，false不显示
     */
    public static FileFilter getFileFilter(String suffix,boolean containDirectory) {
        return new FileFilter () {
            @Override
            public boolean accept(File file) {
                String name = file.getName ();
                boolean destFormat = file.isFile()&& name.endsWith(suffix);
                boolean b;

                b = containDirectory && file.isDirectory ();

                if (destFormat || b) return true;
                else return false;
            }
        };
    }
}

//下载线程代码
class DownloadThread extends Thread {

    private final String path;
    private final File dir;
    private final long startIndex;
    private final long endIndex;
    private final int threadID;
　　//使用构造方法传入参数
    public DownloadThread(String path, File dir, long startIndex,
                          long endIndex, int threadID) {
        this.path = path;
        this.dir = dir;
        this.startIndex = startIndex;
        this.endIndex = endIndex;
        this.threadID = threadID;
    }
    @Override
    public void run() {
        try {
            InputStream in = getInputStream ();
            FileOutputStream fos = getFileOutputStream ();
            int len ;
            byte[] arr = new byte[8192];
            while ((len = in.read (arr)) != -1){
                fos.write (arr,0,len);
            }
            in.close ();
            fos.close ();
        } catch (Exception e) {
            e.printStackTrace ();
        }

    }
    //获取下载输出流
    private FileOutputStream getFileOutputStream() throws FileNotFoundException {
        //获取到文件的名字
        int index = path.lastIndexOf ("/")+1;
        String name = path.substring (index);
        File file = new File (dir,threadID+name);//创建目标文件键,防止文件覆盖
        //创建一个输出流
        return new FileOutputStream (file);
    }
    //获取下载的输入流
    private InputStream getInputStream() throws IOException {
        //创建一个URL对象
        URL url= new URL (path);
        //获取到连接对象
        URLConnection con = url.openConnection ();
        con.setRequestProperty ("Range","bytes="+startIndex+"-"+endIndex);
        //获取到输入流
        return con.getInputStream ();
    }
}