多线程下载文件

创建类继承Thread类
重写run()方法

package com.downLoad;

import java.io.File;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;


public class DownLoad extends Thread{
    
    private int startIndex;//线程开始下载位置
    private int endIndex;//线程结束下载位置
    private int threadId;//线程编号

    public DownLoad(int startIndex, int endIndex, int threadId) {
    
        this.startIndex = startIndex;
        this.endIndex = endIndex;
        this.threadId = threadId;
    }

    @Override
    public void run() {
    
        try {
    
            //统一资源管理器  ,可以直接打开 网络地址
            URL url  = new URL(DownLoadTest.path);
            //因为基于http请求 , 获取HttpURLConnection   , 获取网络链接对象 ,就可以和服务器建立链接
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
            //设置一些参数
            conn.setRequestMethod("GET");   //get请求
            conn.setConnectTimeout(5000);   //链接超时
            conn.setReadTimeout(5000);      //读取超时
            conn.setRequestProperty("Range","bytes="+startIndex+"-"+endIndex);//设置 范围 请求参数  , 获取 线程下载范围

            if(conn.getResponseCode()==206){
        //部分数据 ok
                //取出 链接中的 数据
                InputStream is = conn.getInputStream(); //存储的是服务器上面  百度客户端数据
                //提供一个接收地方(本地接收)
                File file = new File("BaiduNetdisk_6.9.7.4.exe");
                //输出流  ,开始写数据  ,随机读写 流
                RandomAccessFile raf = new RandomAccessFile(file,"rwd");
                raf.seek(startIndex); //跳转到 每个线程 开始读取的位置
                System.out.println("线程:"+threadId+" 开始的位置:"+startIndex+"---"+" 结束位置"+endIndex);
                int len = 0;
                byte[] buf = new byte[1024];
                while((len=is.read(buf))!=-1){
    
                    raf.write(buf,0,len);
                }
                System.out.println("线程:"+threadId+"下载完毕...");
                raf.close();
                DownLoadTest.finishedThread++;
                //如果所有线程都下载完毕 ,让finishedThread 为0
                synchronized (DownLoadTest.path){
    
                    DownLoadTest.finishedThread=0;
                }
            }
        } catch (Exception e) {
    
            e.printStackTrace();
        }
    }
}

创建多线程测试类

package com.downLoad;

import java.net.HttpURLConnection;
import java.net.URL;
/**
 * 多线程测试类
 */
public class DownLoadTest {
    

    static String path = "http://softforspeed.51xiazai.cn/down/BaiduNetdisk_6.9.7.4.exe";

    static int threadCount = 3; //3个线程
    static int finishedThread = 0;  //和 线程数 有关  ,记录每一个线程是否执行完毕

    public static void main(String[] args) throws Exception {
    

        //统一资源管理器  ,可以直接打开 网络地址
        URL url  = new URL(DownLoadTest.path);
        //因为基于http请求 , 获取HttpURLConnection   , 获取网络链接对象 ,就可以和服务器建立链接
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        //设置一些参数
        conn.setRequestMethod("GET");   //get请求
        conn.setConnectTimeout(5000);   //链接超时
        conn.setReadTimeout(5000);      //读取超时

        if(conn.getResponseCode()==200){
    
            //1. 拿到 文件总长 (总大小)
            int contentLength = conn.getContentLength();
            //2. 每个线程下载的大小
            int size = contentLength/threadCount;
            //3.开启线程执行下载
            for (int i = 0; i < threadCount; i++) {
    
                int startIndex = i*size;        // (i从0开始 )
                int endIndex = (i+1)*size;     //结束位置
                DownLoad thread = new DownLoad(startIndex,endIndex,i);
                thread.start();
            }
        }
    }
}

执行结果：