Android实现多线程下载文件的方法

本文实例讲述了Android实现多线程下载文件的方法。分享给大家供大家参考。具体如下:

多线程下载大概思路就是通过Range 属性实现文件分段,然后用RandomAccessFile 来读写文件,最终合并为一个文件

首先看下效果图:

创建工程 ThreadDemo

首先布局文件 threaddemo.xml

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
  android:orientation="vertical"
  android:layout_width="fill_parent"
  android:layout_height="fill_parent"
  >
<TextView
  android:layout_width="fill_parent"
  android:layout_height="wrap_content"
  android:text="下载地址"
  />
<TextView
  android:id="@+id/downloadurl"
  android:layout_width="fill_parent"
  android:layout_height="wrap_content"
  android:lines="5"
  />
<TextView
  android:layout_width="fill_parent"
  android:layout_height="wrap_content"
  android:text="线程数"
  />
<EditText
  android:id="@+id/downloadnum"
  android:layout_width="fill_parent"
  android:layout_height="wrap_content"
  />
<ProgressBar
  android:id="@+id/downloadProgressBar"
  android:layout_width="fill_parent"
  style="?android:attr/progressBarStyleHorizontal"
  android:layout_height="wrap_content"
  />
<TextView
  android:id="@+id/downloadinfo"
  android:layout_width="fill_parent"
  android:layout_height="wrap_content"
  android:text="下载进度 0"
  />
<Button
  android:id="@+id/downloadbutton"
  android:layout_width="wrap_content"
  android:layout_height="wrap_content"
  android:text="开始下载"
  />
</LinearLayout>
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"  android:orientation="vertical" android:layout_width="fill_parent"  android:layout_height="fill_parent"  >
<TextView   android:layout_width="fill_parent"   android:layout_height="wrap_content" android:text="下载地址"  />
<TextViewandroid:id="@+id/downloadurl"android:layout_width="fill_parent" android:layout_height="wrap_content" android:lines="5"/>
<TextView   android:layout_width="fill_parent"   android:layout_height="wrap_content" android:text="线程数"  />
<EditTextandroid:id="@+id/downloadnum"android:layout_width="fill_parent" android:layout_height="wrap_content" />
<ProgressBarandroid:id="@+id/downloadProgressBar"android:layout_width="fill_parent" style="?android:attr/progressBarStyleHorizontal"  android:layout_height="wrap_content" />
<TextViewandroid:id="@+id/downloadinfo"android:layout_width="fill_parent" android:layout_height="wrap_content" android:text="下载进度 0"/>
<Buttonandroid:id="@+id/downloadbutton"android:layout_width="wrap_content" android:layout_height="wrap_content" android:text="开始下载"/>
</LinearLayout>

主界面 Acitivity

public class ThreadDownloadDemo extends Activity {
  private TextView downloadurl;
  private EditText downloadnum;
  private Button downloadbutton;
  private ProgressBar downloadProgressBar;
  private TextView downloadinfo;
  private int downloadedSize = 0;
  private int fileSize = 0;
  private long downloadtime;
  @Override
  public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.threaddemo);
    downloadurl = (TextView) findViewById(R.id.downloadurl);
    downloadurl.setText("http://file16.top100.cn/201105110911/AA5CC27CBE34DEB50A194581D1300881/Special_323149/%E8%8D%B7%E5%A1%98%E6%9C%88%E8%89%B2.mp3");
    downloadnum = (EditText) findViewById(R.id.downloadnum);
    downloadinfo = (TextView) findViewById(R.id.downloadinfo);
    downloadbutton = (Button) findViewById(R.id.downloadbutton);
    downloadProgressBar = (ProgressBar) findViewById(R.id.downloadProgressBar);
    downloadProgressBar.setVisibility(View.VISIBLE);
    downloadProgressBar.setMax(100);
    downloadProgressBar.setProgress(0);
    downloadbutton.setOnClickListener(new OnClickListener() {
      public void onClick(View v) {
        download();
        downloadtime = SystemClock.currentThreadTimeMillis();
      }
    });
  }
  private void download() {
    // 获取SD卡目录
    String dowloadDir = Environment.getExternalStorageDirectory()
        + "/threaddemodownload/";
    File file = new File(dowloadDir);
    //创建下载目录
    if (!file.exists()) {
      file.mkdirs();
    }
    //读取下载线程数,如果为空,则单线程下载
    int downloadTN = Integer.valueOf("".equals(downloadnum.getText()
        .toString()) ? "1" : downloadnum.getText().toString());
    String fileName = "hetang.mp3";
    //开始下载前把下载按钮设置为不可用
    downloadbutton.setClickable(false);
    //进度条设为0
    downloadProgressBar.setProgress(0);
    //启动文件下载线程
    new downloadTask("http://file16.top100.cn/201105110911/AA5CC27CBE34DEB50A194581D1300881/Special_323149/%E8%8D%B7%E5%A1%98%E6%9C%88%E8%89%B2.mp3", Integer
        .valueOf(downloadTN), dowloadDir + fileName).start();
  }
  Handler handler = new Handler() {
    @Override
    public void handleMessage(Message msg) {
      //当收到更新视图消息时,计算已完成下载百分比,同时更新进度条信息
      int progress = (Double.valueOf((downloadedSize * 1.0 / fileSize * 100))).intValue();
      if (progress == 100) {
        downloadbutton.setClickable(true);
        downloadinfo.setText("下载完成!");
        Dialog mdialog = new AlertDialog.Builder(ThreadDownloadDemo.this)
          .setTitle("提示信息")
          .setMessage("下载完成,总用时为:"+(SystemClock.currentThreadTimeMillis()-downloadtime)+"毫秒")
          .setNegativeButton("确定", new DialogInterface.OnClickListener(){
            @Override
            public void onClick(DialogInterface dialog, int which) {
              dialog.dismiss();
            }
          })
          .create();
        mdialog.show();
      } else {
        downloadinfo.setText("当前进度:" + progress + "%");
      }
      downloadProgressBar.setProgress(progress);
    }
  };
  public class downloadTask extends Thread {
    private int blockSize, downloadSizeMore;
    private int threadNum = 5;
    String urlStr, threadNo, fileName;
    public downloadTask(String urlStr, int threadNum, String fileName) {
      this.urlStr = urlStr;
      this.threadNum = threadNum;
      this.fileName = fileName;
    }
    @Override
    public void run() {
      FileDownloadThread[] fds = new FileDownloadThread[threadNum];
      try {
        URL url = new URL(urlStr);
        URLConnection conn = url.openConnection();
        //防止返回-1
        InputStream in = conn.getInputStream();
        //获取下载文件的总大小
        fileSize = conn.getContentLength();
        Log.i("bb", "======================fileSize:"+fileSize);
        //计算每个线程要下载的数据量
        blockSize = fileSize / threadNum;
        // 解决整除后百分比计算误差
        downloadSizeMore = (fileSize % threadNum);
        File file = new File(fileName);
        for (int i = 0; i < threadNum; i++) {
          Log.i("bb", "======================i:"+i);
          //启动线程,分别下载自己需要下载的部分
          FileDownloadThread fdt = new FileDownloadThread(url, file, i * blockSize, (i + 1) * blockSize - 1);
          fdt.setName("Thread" + i);
          fdt.start();
          fds[i] = fdt;
        }
        boolean finished = false;
        while (!finished) {
          // 先把整除的余数搞定
          downloadedSize = downloadSizeMore;
          finished = true;
          for (int i = 0; i < fds.length; i++) {
            downloadedSize += fds[i].getDownloadSize();
            if (!fds[i].isFinished()) {
              finished = false;
            }
          }
          handler.sendEmptyMessage(0);
          //线程暂停一秒
          sleep(1000);
        }
      } catch (Exception e) {
        e.printStackTrace();
      }
    }
  }
}
public class ThreadDownloadDemo extends Activity {
private TextView downloadurl;
private EditText downloadnum;
private Button downloadbutton;
private ProgressBar downloadProgressBar;
private TextView downloadinfo;
private int downloadedSize = 0;
private int fileSize = 0;
private long downloadtime;
@Overridepublic void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.threaddemo);
downloadurl = (TextView) findViewById(R.id.downloadurl);
downloadurl.setText("http://file16.top100.cn/201105110911/AA5CC27CBE34DEB50A194581D1300881/Special_323149/%E8%8D%B7%E5%A1%98%E6%9C%88%E8%89%B2.mp3");
downloadnum = (EditText) findViewById(R.id.downloadnum);
downloadinfo = (TextView) findViewById(R.id.downloadinfo);
downloadbutton = (Button) findViewById(R.id.downloadbutton);
downloadProgressBar = (ProgressBar) findViewById(R.id.downloadProgressBar);
downloadProgressBar.setVisibility(View.VISIBLE);
downloadProgressBar.setMax(100);
downloadProgressBar.setProgress(0);
downloadbutton.setOnClickListener(new OnClickListener() {
public void onClick(View v) {download();
downloadtime = SystemClock.currentThreadTimeMillis();
}
}
);
}
private void download() {// 获取SD卡目录
String dowloadDir = Environment.getExternalStorageDirectory()+ "/threaddemodownload/";
File file = new File(dowloadDir);
//创建下载目录
if (!file.exists()) {file.mkdirs();
}//读取下载线程数,如果为空,则单线程下载
int downloadTN = Integer.valueOf("".equals(downloadnum.getText().toString()) ? "1" : downloadnum.getText().toString());
String fileName = "hetang.mp3";
//开始下载前把下载按钮设置为不可用
downloadbutton.setClickable(false);
//进度条设为0
downloadProgressBar.setProgress(0);
//启动文件下载线程
new downloadTask("http://file16.top100.cn/201105110911/AA5CC27CBE34DEB50A194581D1300881/Special_323149/%E8%8D%B7%E5%A1%98%E6%9C%88%E8%89%B2.mp3", Integer.valueOf(downloadTN), dowloadDir + fileName).start();
}
Handler handler = new Handler() {@Overridepublic void handleMessage(Message msg) {
//当收到更新视图消息时,计算已完成下载百分比,同时更新进度条信息
int progress = (Double.valueOf((downloadedSize * 1.0 / fileSize * 100))).intValue();
if (progress == 100) {downloadbutton.setClickable(true);
downloadinfo.setText("下载完成!");
Dialog mdialog = new AlertDialog.Builder(ThreadDownloadDemo.this).setTitle("提示信息").setMessage("下载完成,总用时为:"+(SystemClock.currentThreadTimeMillis()-downloadtime)+"毫秒").setNegativeButton("确定", new DialogInterface.OnClickListener(){@Overridepublic void onClick(DialogInterface dialog, int which) {dialog.dismiss();
}}).create();
mdialog.show();
} else {
downloadinfo.setText("当前进度:" + progress + "%");
}
downloadProgressBar.setProgress(progress);
}
};
public class downloadTask extends Thread {private int blockSize, downloadSizeMore;
private int threadNum = 5;
String urlStr, threadNo, fileName;
public downloadTask(String urlStr, int threadNum, String fileName) {
this.urlStr = urlStr;
this.threadNum = threadNum;
this.fileName = fileName;
}
@Overridepublic void run() {
FileDownloadThread[] fds = new FileDownloadThread[threadNum];
try {URL url = new URL(urlStr);
URLConnection conn = url.openConnection();
//防止返回-1
InputStream in = conn.getInputStream();
//获取下载文件的总大小
fileSize = conn.getContentLength();
Log.i("bb", "======================fileSize:"+fileSize);
//计算每个线程要下载的数据量
blockSize = fileSize / threadNum;
// 解决整除后百分比计算误差
downloadSizeMore = (fileSize % threadNum);
File file = new File(fileName);
for (int i = 0; i < threadNum; i++) {
Log.i("bb", "======================i:"+i);
//启动线程,分别下载自己需要下载的部分
FileDownloadThread fdt = new FileDownloadThread(url, file, i * blockSize, (i + 1) * blockSize - 1);
fdt.setName("Thread" + i);
fdt.start();
fds[i] = fdt;
}
boolean finished = false;
while (!finished) {
// 先把整除的余数搞定
downloadedSize = downloadSizeMore;
finished = true;
for (int i = 0; i < fds.length; i++) {
downloadedSize += fds[i].getDownloadSize();
if (!fds[i].isFinished()) {
finished = false;
}
}
handler.sendEmptyMessage(0);
//线程暂停一秒sleep(1000);
}
}
catch (Exception e) {
e.printStackTrace();
}
}
}
}

这里启动线程将文件分割为几个部分,每一个部分再启动一个线程去下载数据
下载文件的线程

public class FileDownloadThread extends Thread{
  private static final int BUFFER_SIZE=1024;
  private URL url;
  private File file;
  private int startPosition;
  private int endPosition;
  private int curPosition;
  //标识当前线程是否下载完成
  private boolean finished=false;
  private int downloadSize=0;
  public FileDownloadThread(URL url,File file,int startPosition,int endPosition){
    this.url=url;
    this.file=file;
    this.startPosition=startPosition;
    this.curPosition=startPosition;
    this.endPosition=endPosition;
  }
  @Override
  public void run() {
    BufferedInputStream bis = null;
    RandomAccessFile fos = null;
    byte[] buf = new byte[BUFFER_SIZE];
    URLConnection con = null;
    try {
      con = url.openConnection();
      con.setAllowUserInteraction(true);
      //设置当前线程下载的起止点
      con.setRequestProperty("Range", "bytes=" + startPosition + "-" + endPosition);
      Log.i("bb", Thread.currentThread().getName()+" bytes=" + startPosition + "-" + endPosition);
      //使用java中的RandomAccessFile 对文件进行随机读写操作
      fos = new RandomAccessFile(file, "rw");
      //设置写文件的起始位置
      fos.seek(startPosition);
      bis = new BufferedInputStream(con.getInputStream());
      //开始循环以流的形式读写文件
      while (curPosition < endPosition) {
        int len = bis.read(buf, 0, BUFFER_SIZE);
        if (len == -1) {
          break;
        }
        fos.write(buf, 0, len);
        curPosition = curPosition + len;
        if (curPosition > endPosition) {
          downloadSize+=len - (curPosition - endPosition) + 1;
        } else {
          downloadSize+=len;
        }
      }
      //下载完成设为true
      this.finished = true;
      bis.close();
      fos.close();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
  public boolean isFinished(){
    return finished;
  }
  public int getDownloadSize() {
    return downloadSize;
  }
}
public class FileDownloadThread extends Thread{
private static final int BUFFER_SIZE=1024;
private URL url;
private File file;
private int startPosition;
private int endPosition;
private int curPosition;//标识当前线程是否下载完成
private boolean finished=false;
private int downloadSize=0;
public FileDownloadThread(URL url,File file,int startPosition,int endPosition){
this.url=url;
this.file=file;
this.startPosition=startPosition;
this.curPosition=startPosition;
this.endPosition=endPosition;
}
@Overridepublic void run() {
BufferedInputStream bis = null;
RandomAccessFile fos = null;
byte[] buf = new byte[BUFFER_SIZE];
URLConnection con = null;
try {
con = url.openConnection();
con.setAllowUserInteraction(true);
//设置当前线程下载的起止点
con.setRequestProperty("Range", "bytes=" + startPosition + "-" + endPosition);
Log.i("bb", Thread.currentThread().getName()+" bytes=" + startPosition + "-" + endPosition);
//使用java中的RandomAccessFile 对文件进行随机读写操作
fos = new RandomAccessFile(file, "rw");
//设置写文件的起始位置
fos.seek(startPosition);
bis = new BufferedInputStream(con.getInputStream());
//开始循环以流的形式读写文件
while (curPosition < endPosition) {
int len = bis.read(buf, 0, BUFFER_SIZE);
if (len == -1) {
break;
}
fos.write(buf, 0, len);
curPosition = curPosition + len;
if (curPosition > endPosition) {
downloadSize+=len - (curPosition - endPosition) + 1;
} else {
downloadSize+=len;
}
}
//下载完成设为true
this.finished = true;
bis.close();
fos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public boolean isFinished(){return finished;}
public int getDownloadSize() {return downloadSize;}
}

这里通过RandomAccessFile 的seek方法定位到相应的位置 并实时记录下载量
当然这里需要联网和访问SD卡 所以要加上相应的权限

<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"></uses-permission>
<uses-permission android:name="android.permission.INTERNET" /><uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"></uses-permission>

这样就OK了 下面可以看看断点续传的问题了。有待测试~~

希望本文所述对大家的Android程序设计有所帮助。

时间: 2015-10-13

Android中实现下载和解压zip文件功能代码分享

本文提供了2段Android代码,实现了从Android客户端下载ZIP文件并且实现ZIP文件的解压功能,非常实用,有需要的Android开发者可以尝试一下. 下载: DownLoaderTask.java 复制代码 代码如下: package com.johnny.testzipanddownload; import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.File; im

Android实现文件下载进度显示功能

和大家一起分享一下学习经验,如何实现Android文件下载进度显示功能,希望对广大初学者有帮助. 先上效果图: 上方的蓝色进度条,会根据文件下载量的百分比进行加载,中部的文本控件用来现在文件下载的百分比,最下方的ImageView用来展示下载好的文件,项目的目的就是动态向用户展示文件的下载量. 下面看代码实现:首先是布局文件: <RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android" xm

Android使用缓存机制实现文件下载及异步请求图片加三级缓存

首先给大家介绍Android使用缓存机制实现文件下载 在下载文件或者在线浏览文件时,或者为了保证文件下载的正确性,需要使用缓存机制,常使用SoftReference来实现. SoftReference的特点是它的一个实例保存对一个Java对象的软引用,该软引用的存在不妨碍垃圾收集线程对该Java对象的回收.也就是说,一旦SoftReference保存了对一个Java对象的软引用后,在垃圾线程对这个Java对象回收前,SoftReference类所提供的get()方法返回Java对象的强引用.另外

Android 将文件下载到指定目录的实现代码

废话不多说了额,直接给大家贴代码了,具体代码如下所示: /** * 下载指定路径的文件,并写入到指定的位置 * * @param dirName * @param fileName * @param urlStr * @return 返回0表示下载成功,返回1表示下载出错 */ public int downloadFile(String dirName, String fileName, String urlStr) { OutputStream output = null; try { //

Android通过startService实现文件批量下载

关于startService的基本使用概述及其生命周期可参见<Android中startService基本使用方法概述>. 本文通过批量下载文件的简单示例,演示startService以及stopService(startId)的使用流程,具体内容如下 系统界面如下: 界面很简单,就一个按钮"批量下载文章",通过该Activity上的按钮启动DownloadService. DownloadService是用来进行下载CSDN上博客文章的服务,代码如下: package c

python FTP批量下载/删除/上传实例

最近几天,学习python3的对FTP操作,做下总结!!!! 1.FTP链接 这样写的好处就是如果报错,很快就能找到错在哪里,方便找到问题. 2.FTP文件批量下载 有点要注意的: 如果for循环中不加while..try..except..,当然也可以下载,但经常会出现500网络连接错误类似这种错误!! 3.FTP文件批量删除 4.FTP文件上传 5.FTP关闭连接 目前就先分享到这里,新手上路多多关照!!!! 以上这篇python FTP批量下载/删除/上传实例就是小编分享给大家的全部内容了

Python实现批量下载文件

Python实现批量下载文件 #!/usr/bin/env python # -*- coding:utf-8 -*- from gevent import monkey monkey.patch_all() from gevent.pool import Pool import requests import sys import os def download(url): chrome = 'Mozilla/5.0 (X11; Linux i86_64) AppleWebKit/537.36

ASP.NET批量下载文件的方法

本文实例讲述了ASP.NET批量下载文件的方法.分享给大家供大家参考.具体方法如下: 一.实现步骤 在用户操作界面,由用户选择需要下载的文件,系统根据所选文件,在服务器上创建用于存储所选文件的临时文件夹,将所选文件拷贝至临时文件夹.然后调用 RAR程序,对临时文件夹进行压缩,然后输出到客户端.最后删除临时文件夹.   二.代码实现   1.ASP.NET批量下载 核心代码 复制代码 代码如下: //遍历服务器指定文件夹下的所有文件 string path = "uploads/Image/&qu

使用Linux shell脚本实现FTP定时执行批量下载指定文件

使用FTP定时批量下载指定文件的shell脚本,具体实例介绍如下所示: 1.目标FTP服务器地址 #FTP服务器地址 ip=10.19.15.23 2.FTP账号和密码 u=账号 p=密码 3.使用mget结合正则表达式下载文件 #获取昨天日期,为后面下载使用 T=`date -d yesterday +%Y%m%d` 4.连接FTP服务器,到指定路径下下载文件 ftp -n <<EOF open $ip user $u $p binary cd /hour #远程服务器文件目录 lcd /h

JAVA SFTP文件上传、下载及批量下载实例

1.jsch官方API查看地址(附件为需要的jar) http://www.jcraft.com/jsch/ 2.jsch简介 JSch(Java Secure Channel)是一个SSH2的纯Java实现.它允许你连接到一个SSH服务器,并且可以使用端口转发,X11转发,文件传输等,当然你也可以集成它的功能到你自己的应用程序. SFTP(Secure File Transfer Protocol)安全文件传送协议.可以为传输文件提供一种安全的加密方法.SFTP 为 SSH的一部份,是一种传输

javaweb文件打包批量下载代码

本文实例为大家分享了javaweb文件打包批量下载,供大家参考,具体内容如下 // 批量下载未批改作业 @RequestMapping(value = "/downloadAllHomework", method = RequestMethod.GET) public void downloadAllHomework(HttpSession httpSession, HttpServletRequest request, HttpServletResponse response, St

php实现网站文件批量压缩下载功能

利用php实现将文件批量压缩打包下载,这个过程中将使用到 ZipArchive 这个类,注意使用该类之前,linux需开启zlib,windows需取消php_zip.dll前的注释.下面直接给出一个简单的将文件压缩为 zip 格式的示例.具体用法请查询php相关文档. <?php $filename='test.zip'; //最终生成的文件名(含路径) if(file_exists($filename)){ unlink($filename); } //重新生成文件 $zip=new Zip

Android 实现单线程轮循机制批量下载图片

Android 实现单线程轮循机制批量下载图片 listview 在为item 添加从网上下载下来的图片时, 如果每次都整合一个item时都需要new一个Thread去下载图片,listview长时间滑动时会产生大量线程. 用单线程轮循机制则可以解决这个问题 步骤如下: 1.需要一个任务集合 class imageViewTask{ String path; Bitmap bitmap; int position; } // 任务集合 private List<imageViewTask> i

使用Android系统提供的DownloadManager来下载文件

在android2.3以后android系统提供了一个系统组件来供其他app调用来下载东西,使用起来非常方便. 例如我们可以拿来下载app的新版本apk,同时在同时注册一个广播接收器来接收下载完成时DownloadManager发出的的广播,然后自动安装程序. SDK在API Level 9中加入了DownloadManager服务,可以将长时间的下载任务交给系统,完全由系统管理. 直接看实例代码: package com.hebaijun.downloadtest; import java.i