使用多线程实现文件的下载_多线程写同一个文件

使用多线程实现文件的下载_多线程写同一个文件首先,我们要下载一个文件,可以通过多线程的方式快速下载!!!多线程下载文件的步骤:1、首先要知道请求下载的服务器支持断点下载,即支持request头信息中的Range的设置2、然后通过对请求头设置httpRequest.setRequestProperty(“Range”,”bytes=”+startIndex+”-“+endIndex);3、然后获取整个文件的大小4、在……

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

首先,我们要下载一个文件,可以通过多线程的方式快速下载!!!

多线程下载文件的步骤:

1、首先要知道请求下载的服务器支持断点下载,即支持request头信息中的Range的设置

2、然后通过对请求头设置

httpConnection.setRequestProperty("Range","bytes="+startIndex+"-"+endIndex);

3、然后获取整个文件的大小

4、在本地创建一个一样大的文件,然后根据线程数进行分配startIndex和endIndex

5、线程下载的同时,使用RandomAccessFile对所下载的内容随机对应写入文件

这里要注意,你所访问的文件在服务器端必须吧能够返回Content-Length这个参数才行!!!

完整的示例代码:

package cn.ljxwtl.plugin.common.util;

import com.alibaba.fastjson.JSON;
import cn.ljxwtl.plugin.engine.EngineAssistant;
import org.apache.commons.io.IOUtils;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.RandomAccess;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * @author: wtl
 * @License: (C) Copyright 2022, wtl Corporation Limited.
 * @Contact: 1050100468@qq.com
 * @Date: 2022/4/1 10:50
 * @Version: 1.0
 * @Description:
 */
public class DownloadFileUtil {

    public static void downloadFileWithMultiThread(String url,String filePath,Runnable runnable) throws Exception {
        List<long[]> perThreadDownloadFileOffset = getPerThreadDownloadFileOffset(url, 1024* 1024);
        ThreadPoolExecutor threadPoolExecutor = EngineAssistant.THREAD_POOL_EXECUTOR;

        int size = Objects.requireNonNull(perThreadDownloadFileOffset).size();

        CyclicBarrier cyclicBarrier = new CyclicBarrier(size, ()->{
            if (null != runnable){
                runnable.run();
            }
        });

        URL openUrl = new URL(url);

        for (int i = 0; i< size; i++){
            int finalI = i;
            new Thread(()->{
                try {
                    HttpURLConnection urlConnection = (HttpURLConnection) openUrl.openConnection();
                    urlConnection.setRequestProperty("Range","bytes="+perThreadDownloadFileOffset.get(finalI)[0]+"-"+perThreadDownloadFileOffset.get(finalI)[1]);
                    urlConnection.setDoInput(true);
                    BufferedInputStream bufferedInputStream = new BufferedInputStream(urlConnection.getInputStream());
                    int length = -1;
                    byte [] buffer = new byte[102400];
                    RandomAccessFile randomAccessFile = new RandomAccessFile(filePath,"rw");
                    System.out.println(perThreadDownloadFileOffset.get(finalI)[1] - perThreadDownloadFileOffset.get(finalI)[0]);
                    randomAccessFile.seek(perThreadDownloadFileOffset.get(finalI)[0]);
                    int perSize = 0;
                    while ((length = bufferedInputStream.read(buffer))!=-1){
                        randomAccessFile.write(buffer,0,length);
                        perSize +=length;
                    }
                    randomAccessFile.close();
                    System.out.println(perThreadDownloadFileOffset.get(finalI)[0] + "------------------" +(perThreadDownloadFileOffset.get(finalI)[0] +  perSize));
                } catch (Exception e) {
                    e.printStackTrace();
                }
                finally {
                    try {
                        cyclicBarrier.await();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        }

    }


    /**
     * 获取每个线程所需要的File的offset
     * @param url url地址
     * @param perThreadDealFileSize 每个线程处理的文件下载大小
     * @return List<int []>
     */
    private static List<long []> getPerThreadDownloadFileOffset(String url,long perThreadDealFileSize){
        URLConnection urlConnection = null;
        try {
            urlConnection = new URL(url).openConnection();
            long contentLengthLong = urlConnection.getContentLengthLong();
            List<long[]> threadOffsetDatas = new ArrayList<>();
            long size = (long) Math.ceil(contentLengthLong * 1.0 / perThreadDealFileSize);
            for (int i = 0; i < size; i++) {
                long start = i * perThreadDealFileSize;
                long end = (i + 1) * perThreadDealFileSize - 1;

                if (i == size - 1) {
                    start = i * perThreadDealFileSize;
                    end = contentLengthLong;
                }

                threadOffsetDatas.add(new long[]{start,end});
            }

            System.out.println(JSON.toJSONString(threadOffsetDatas));
            return threadOffsetDatas;
        }
        catch (Exception e){
            e.printStackTrace();
        }
        return null;
    }
}
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195242.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 10条PHP编程习惯助你找工作

    10条PHP编程习惯助你找工作

    2021年10月15日
  • 7款公认比较出色的Python IDE,你值得拥有![通俗易懂]

    7款公认比较出色的Python IDE,你值得拥有![通俗易懂]Python作为一款比较“简洁”的编程语言,它拥有很多性价比高的性能,造就了它现在比较火热的局面,很多人都来学习Python。Python的学习过程少不了IDE或者代码编辑器,或者集成的开发编辑

  • 小树剪发网1114_aow把抓

    小树剪发网1114_aow把抓乔治拿来一组等长的木棒,将它们随机地砍断,使得每一节木棍的长度都不超过 50 个长度单位。然后他又想把这些木棍恢复到为裁截前的状态,但忘记了初始时有多少木棒以及木棒的初始长度。请你设计一个程序,帮助乔治计算木棒的可能最小长度。每一节木棍的长度都用大于零的整数表示。输入格式输入包含多组数据,每组数据包括两行。第一行是一个不超过 64 的整数,表示砍断之后共有多少节木棍。第二行是截断以后,所得到的各节木棍的长度。在最后一组数据之后,是一个零。输出格式为每组数据,分别输出原始木棒的可能最小长度

  • pygame安装(2020版超详细)[通俗易懂]

    pygame安装(2020版超详细)[通俗易懂]在网上找了很多安装教程但是没有成功,最后结合很多教程的步骤终于安装成功啦下面分享一下步骤:1.查看安装版本输入d:(因为我的python是安装在d盘的)输入python会出现安装的版本

  • idea2022 3.4激活码【2022免费激活】[通俗易懂]

    (idea2022 3.4激活码)好多小伙伴总是说激活码老是失效,太麻烦,关注/收藏全栈君太难教程,2021永久激活的方法等着你。IntelliJ2021最新激活注册码,破解教程可免费永久激活,亲测有效,下面是详细链接哦~https://javaforall.cn/100143.html40ZKSWCX8G-eyJsaWNlbnNlSW…

  • 特殊多位数乘法口算算法

    特殊多位数乘法口算算法本文转自:我爱口算网,但是本人有一定更正,因此转载请注明出处一、关于9的数学口算技巧(两位数乘法)关于9的口诀:1×9=9  2×9=18  3×9=27    4×9=365×9=45  6×9=54  7×9=63    8×9=729×9=81上面的口诀小朋友们已经会了吗?小学

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号