java多线程实现文件下载功能

 更新时间:2017年01月18日 09:21:26   作者:augfun  
这篇文章主要介绍了java多线程实现文件下载功能的相关资料,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

多线程下载文件的思路:

1.首先获取到文件的总大小
获取文件大小的方式是通过网络读取,getContentLength()即可获取到文件的大小,使用RandomAccessFile()支持随机访问

2.根据所准备的线程数据,计算每一个线程需要下载的文件的大小

上图显示下载400M的电影分4个线程下载,每一个线程分别下载各自数据段中的数据,第一个线程下载0-100M,第二个下载100M-200M之间的数据,依次类推。因此下载过程中需要记住的是的开始位置段和结束位置段,其实只需要开始位置就可以了,结束为止可以根据开始位置加上下载的大小来推断获取。

3.获取到大小数据以后,开始用线程循环读取每一个区间的数据
这个里面需要注意的是,要更新数据的写入位置seek(startIndex),逐段填满,不然会出现覆盖以前的数据。

package com.ldw.multilthreaddownload; 
 
import java.io.File; 
import java.io.InputStream; 
import java.io.RandomAccessFile; 
import java.net.HttpURLConnection; 
import java.net.URL; 
 
public class Multidownload { 
 
 static int ThreadCount = 3; //线程的个数 
 static String path = "http://192.168.0.102:8080/QQ.exe"; //确定下载地址 
 public static void main(String[] args) { 
  // TODO Auto-generated method stub 
   
  //发送get请求,请求这个地址的资源 
  try { 
   URL url = new URL(path); 
   HttpURLConnection conn = (HttpURLConnection) url.openConnection(); 
   conn.setRequestMethod("GET"); 
   conn.setConnectTimeout(5000); 
   conn.setReadTimeout(5000); 
   if(conn.getResponseCode() == 200){ 
    //获取到请求资源文件的长度 
    int length = conn.getContentLength(); 
    File file = new File("QQ.exe"); 
    //创建随机存储文件 
    RandomAccessFile raf = new RandomAccessFile(file, "rwd"); 
    //设置临时文件的大小 
    raf.setLength(length); 
    //关闭raf 
    raf.close(); 
    //计算出每一个线程下载多少字节 
     
    int size = length / Multidownload.ThreadCount; 
     
    for(int i = 0; i < Multidownload.ThreadCount; i ++){ 
     //startIndex,endIndex分别代表线程的开始和结束位置 
     int startIndex = i * size; 
     int endIndex = (i + 1) * size - 1; 
     if(i == ThreadCount - 1){ 
      //如果是最后一个线程,那么结束位置写死 
      endIndex = length -1; 
     } 
     System.out.println("线程" + i + "的下载区间是" + startIndex + "到" + endIndex); 
     new DownLoadThread(startIndex, endIndex, i).start(); //创建线程下载数据 
    } 
   } 
  } catch (Exception e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
 
 } 
 
} 
 
class DownLoadThread extends Thread{ 
 int startIndex; 
 int endIndex; 
 int threadId; 
  
 public DownLoadThread(int startIndex, int endIndex, int threadId) { 
  super(); 
  this.startIndex = startIndex; 
  this.endIndex = endIndex; 
  this.threadId = threadId; 
 } 
 
 @Override 
 public void run(){ 
  //使用http请求下载安装包文件 
  URL url; 
  try { 
   url = new URL(Multidownload.path); 
   HttpURLConnection conn = (HttpURLConnection) url.openConnection(); 
   conn.setRequestMethod("GET"); 
   conn.setConnectTimeout(5000); 
   conn.setReadTimeout(5000); 
   //设置请求数据的区间 
   conn.setRequestProperty("Range", "bytes=" + startIndex + "-" + endIndex); 
   //请求部分数据的响应码是206 
   if(conn.getResponseCode() == 206){ 
    //获取一部分数据来读取 
    InputStream is = conn.getInputStream(); 
    byte[] b = new byte[1024]; 
    int len = 0; 
    int total = 0; 
    //拿到临时文件的引用 
    File file = new File("QQ.exe"); 
    RandomAccessFile raf = new RandomAccessFile(file, "rwd"); 
    //更新文件的写入位置,startIndex 
    raf.seek(startIndex); 
    while((len = is.read(b)) != -1 ){ 
     //每次读取流里面的数据,同步吧数据写入临时文件 
     raf.write(b, 0, len); 
     total += len; 
     System.out.println("线程" + threadId + "下载了" + total); 
    } 
    System.out.println("线程" + threadId + "下载过程结束==========================="); 
    raf.close(); 
   } 
  } catch (Exception e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
   
 }; 
} 

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • 对Java中传值调用的理解分析

    对Java中传值调用的理解分析

    这篇文章主要介绍了对Java中传值调用的理解分析,通过分析对比,较为深入的分析了Java中传值调用的原理与用法,需要的朋友可以参考下
    2015-01-01
  • Java实现单例模式的五种方式总结

    Java实现单例模式的五种方式总结

    这篇文章主要介绍了如何实现一个单例模式,包括构造器私有化、提供静态私有变量和公共获取实例接口,文中通过代码介绍的非常详细,需要的朋友可以参考下
    2025-01-01
  • Springboot项目的服务器部署与发布方式

    Springboot项目的服务器部署与发布方式

    本文记录了将Springboot项目部署到服务器并发布的过程,包括在IDEA中打包、选择服务器、连接服务器、安装环境、上传jar包、配置环境变量以及运行项目等步骤
    2025-03-03
  • Spring Security添加二次认证的项目实践

    Spring Security添加二次认证的项目实践

    在用户自动登录后,可以通过对密码进行二次校验进而确保用户的真实性,本文就来介绍一下Spring Security添加二次认证的项目实践,具有一定的参考价值,感兴趣的可以了解一下
    2023-12-12
  • IDEA报错:Unable to save settings Failed to save settings

    IDEA报错:Unable to save settings Failed to save settings

    这篇文章主要介绍了IDEA报错:Unable to save settings Failed to save settings的相关知识,本文给大家分享问题原因及解决方案,需要的朋友可以参考下
    2020-09-09
  • java接口自动化测试框架及断言详解

    java接口自动化测试框架及断言详解

    这篇文章主要介绍了java接口自动化测试框架及断言详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-07-07
  • Java如何通过反射将map转换为实体对象

    Java如何通过反射将map转换为实体对象

    在Java开发中,常需要将XML配置数据转为Map,并最终映射到实体对象上,通过单例模式管理XML转换后的Map,并利用Java反射机制,通过属性名称匹配将Map的值赋给实体对象的对应属性,这种方法忽略了数据类型转换,适用于数据类型一致的简单场景,需要类型转换时
    2024-09-09
  • Java使用MyBatis框架分页的5种方式

    Java使用MyBatis框架分页的5种方式

    这篇文章主要为大家详细介绍了Java使用MyBatis框架分页的5种方式,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-08-08
  • java使用ajax完成上传文件

    java使用ajax完成上传文件

    这篇文章主要为大家详细介绍了java使用ajax完成上传文件,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-06-06
  • Java 二分查找的实现及图例解析

    Java 二分查找的实现及图例解析

    这篇文章主要介绍了Java 二分查找的实现,帮助大家更好的理解和使用Java,感兴趣的朋友可以了解下
    2020-12-12

最新评论