android多线程断点下载-带进度条和百分比进度显示

欢迎访问个人博客：www.yyxxk.com

android多线程断点下载，带进度条和百分比显示，断点下载的临时数据保存到SD卡的文本文档中，建议可以保存到本地数据库中，这样可以提高存取效率，从而提高系统性能。

效果：

打开软件：

下载中：

下载完毕：

附代码如下：

package com.yy.multiDownloadOfBreakPoint;

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

import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.text.TextUtils;
import android.view.View;
import android.widget.EditText;
import android.widget.ProgressBar;
import android.widget.TextView;
import android.widget.Toast;
/**
 * 多线程断点下载实例
 * @author YUANYUAN
 *
 */
public class MainActivity extends Activity {
    //下载所使用的线程数
    protected static final int threadCount = 3;
    //下载完毕的标记
    public static final int downloadOver = 1;
    //更新下载进度标记
    public static final int UPDATE_PROGRESS = 0;
    //下载资源的路径输入框
    private EditText et_path;
    //下载的进度条
    private ProgressBar pb;
    //进度显示
    private TextView tv_pb;
    //当前累计下载的数据
    int curDownCount=0;
    //当前活动的下载线程数
    protected static int activeThread;
    //加入消息处理机制
    private Handler handler=new Handler(){
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
            case downloadOver:
                Toast.makeText(MainActivity.this, "文件已下载完毕！", Toast.LENGTH_LONG).show();
                tv_pb.setText("下载完成");
                break;
            case UPDATE_PROGRESS:
                //更新进度显示
                tv_pb.setText("当前进度："+(pb.getProgress()*100/pb.getMax())+"%");
                break;
            default:
                break;
            }
        }
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        et_path=(EditText) findViewById(R.id.et_path);
        et_path.setText("http://192.168.2.114:8080/sqlite.exe");
        pb=(ProgressBar) findViewById(R.id.pb);
        tv_pb=(TextView) findViewById(R.id.tv_pb);
    }
    
    /**
     * 开始下载
     * @param view
     */
    public void down(View view){
        //获取下载资源的路径
        final String path=et_path.getText().toString().trim();
        //判断资源路径是否为空
        if (TextUtils.isEmpty(path)) {
            Toast.makeText(this, "请输入下载资源的路径", Toast.LENGTH_LONG).show();
            return;
        }
        //开启一个线程进行下载
        new Thread(){
            public void run() {
                try {
                    //构造URL地址
                    URL url=new URL(path);
                    //打开连接
                    HttpURLConnection conn=(HttpURLConnection) url.openConnection();
                    //设置请求超时的时间
                    conn.setConnectTimeout(5000);
                    //设置请求方式
                    conn.setRequestMethod("GET");
                    //获取相应码
                    int code=conn.getResponseCode();
                    if (code==200) {//请求成功
                        //获取请求数据的长度
                        int length=conn.getContentLength();
                        //设置进度条的最大值
                        pb.setMax(length);
                        //在客户端创建一个跟服务器文件大小相同的临时文件
                        RandomAccessFile raf=new RandomAccessFile("sdcard/setup.exe", "rwd");
                        //指定临时文件的长度
                        raf.setLength(length);
                        raf.close();
                        //假设3个线程去下载资源
                        //平均每一个线程要下载的文件的大小
                        int blockSize=length/threadCount;
                        for (int threadId = 1; threadId <= threadCount; threadId++) {
                            //当前线程下载数据的开始位置
                            int startIndex=blockSize*(threadId-1);
                            //当前线程下载数据的结束位置
                            int endIndex=blockSize*threadId-1;
                            //确定最后一个线程要下载数据的最大位置
                            if (threadId==threadCount) {
                                endIndex=length;
                            }
                            //显示下载数据的区间
                            System.out.println("线程【"+threadId+"】开始下载："+startIndex+"---->"+endIndex);
                            //开启下载的子线程
                            new DownloadThread(path, threadId, startIndex, endIndex).start();
                            //当前下载活动的线程数加1
                            activeThread++;
                            System.out.println("当前活动的线程数："+activeThread);
                        }
                        
                    }else{//请求失败
                        System.out.println("服务器异常，下载失败！");
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    System.out.println("服务器异常，下载失败！");
                }
            };
        }.start();
        
    }
    /**
     * 下载文件的子线程 每一个文件都下载对应的数据
     * @author YUANYUAN
     *
     */
    public class DownloadThread extends Thread{
        private String path;
        private int threadId;
        private int startIndex;
        private int endIndex;
        
        /**
         * 构造方法
         * @param path 下载文件的路径
         * @param threadId 下载文件的线程
         * @param startIndex 下载文件开始的位置
         * @param endIndex 下载文件结束的位置
         */
        public DownloadThread(String path, int threadId, int startIndex,
                int endIndex) {
            this.path = path;
            this.threadId = threadId;
            this.startIndex = startIndex;
            this.endIndex = endIndex;
        }



        @Override
        public void run() {
            //构造URL地址
            try {
                
                File tempFile=new File("sdcard/"+threadId+".txt");
                //检查记录是否存在,如果存在读取数据，设置真实下载开始的位置
                if (tempFile.exists()) {
                    FileInputStream fis=new FileInputStream(tempFile);
                    byte[] temp=new byte[1024];
                    int length=fis.read(temp);
                    //读取到已经下载的位置
                    int downloadNewIndex=Integer.parseInt(new String(temp, 0, length));
                    //计算出已经下载的数据长度
                    int areadyDown=downloadNewIndex-startIndex;
                    //累加已经下载的数据量
                    curDownCount+=areadyDown;
                    //设置进度条已经下载的数据量
                    pb.setProgress(curDownCount);
                    //设置重新开始下载的开始位置
                    startIndex=downloadNewIndex;
                    fis.close();
                    //显示真实下载数据的区间
                    System.out.println("线程【"+threadId+"】真实开始下载数据区间："+startIndex+"---->"+endIndex);
                }
                
                URL url = new URL(path);
                HttpURLConnection conn=(HttpURLConnection) url.openConnection();
                conn.setConnectTimeout(5000);
                conn.setRequestMethod("GET");
                //设置请求属性，请求部分资源
                conn.setRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);
                int code=conn.getResponseCode();
                if (code==206) {//下载部分资源，正常返回的状态码为206
                    InputStream is=conn.getInputStream();//已经设置了请求的位置，所以返回的是对应的部分资源
                    //构建随机访问文件
                    RandomAccessFile raf=new RandomAccessFile("sdcard/setup.exe", "rwd");
                    //设置 每一个线程随机写文件开始的位置
                    raf.seek(startIndex);
                    //开始写文件
                    int len=0;
                    byte[] buffer=new byte[1024];
                    //该线程已经下载数据的长度
                    int total=0;
                    
                    while((len=is.read(buffer))!=-1){//读取输入流
                        //记录当前线程已下载数据的长度
                        RandomAccessFile file=new RandomAccessFile("sdcard/"+threadId+".txt","rwd");
                        raf.write(buffer,0,len);//写文件
                        total+=len;//更新该线程已下载数据的总长度
                        System.out.println("线程【"+threadId+"】已下载数据："+(total+startIndex));
                        //将已下载数据的位置记录写入到文件
                        file.write((startIndex+total+"").getBytes());
                        //累加已经下载的数据量
                        curDownCount+=len;
                        //更新进度条【进度条的更新可以在非UI线程直接更新，具体见底层源代码】
                        pb.setProgress(curDownCount);
                        
                        //更新下载进度
                        Message msg=Message.obtain();
                        msg.what=UPDATE_PROGRESS;
                        handler.sendMessage(msg);
                        
                        file.close();
                    }
                    is.close();
                    raf.close();
                    //提示下载完毕
                    System.out.println("线程【"+threadId+"】下载完毕");
                }
            } catch (Exception e) {
                e.printStackTrace();
                System.out.println("线程【"+threadId+"】下载出现异常！！");
            }finally{
                //活动的线程数减少
                activeThread--;
                if (activeThread==0) {
                    for (int i = 1; i <= threadCount; i++) {
                        File tempFile=new File("sdcard/"+i+".txt");
                        tempFile.delete();
                    }
                    System.out.println("下载完毕，已清除全部临时文件");
                    //界面消息提示下载完毕
                    Message msg=new Message();
                    msg.what=downloadOver;
                    handler.sendMessage(msg);
                }
            }
            
        }
    }
}