安卓开发笔记——关于文件断点续传

什么是断点续传？

客户端软件断点续传指的是在下载或上传时，将下载或上传任务（一个文件或一个压缩包）人为的划分为几个部分，每一个部分采用一个线程进行上传或下载，如果碰到网络故障，可以从已经上传或下载的部分开始继续上传下载未完成的部分，而没有必要从头开始上传下载。用户可以节省时间，节省流量，也提高速度。

我写了个小Demo，先看下实现效果图：

  

断点续传的原理?

断点续传其实并没有那么神秘，它只不过是利用了HTTP传输协议中请求头(REQUEST HEADER)的不同来进行断点续传的。

以下是我刚在百度音乐下载MP3的时候用Firebug截下来的HTTP请求头:

Accept:image/webp,*/*;q=0.8
Accept-Encoding:gzip, deflate, sdch
Accept-Language:zh-CN,zh;q=0.8
Connection:keep-alive
Cookie:BIDUPSID=6B8AF721169ED82B182A7EE22F75BB87; BAIDUID=6B8AF721169ED82B182A7EE22F75BB87:FG=1; BDUSS=1pWS14dzl6Ry02MVJoN0toT1RlTzRIdkdBRVlsN1JJdG9OVmQ5djAybTJ1a1JWQVFBQUFBJCQAAAAAAAAAAAEAAACkSkgjTXJfTGVlX-fiAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAALYtHVW2LR1VaW; __xsptplus188=188.1.1428024707.1428024712.2%234%7C%7C%7C%7C%7C%23%23QdAfR9H5KZHSIGakiCWebLQCd6CjKjz5%23; locale=zh; cflag=65279%3A3; BDRCVFR[-z8N-kPXoJt]=I67x6TjHwwYf0; H_PS_PSSID=11099_13386_1439_13425_13075_10902_12953_12868_13320_12691_13410_12722_12737_13085_13325_13203_12835_13161_8498
Host:b.hiphotos.baidu.com
Referer:http://music.baidu.com/song/124380645
User-Agent:Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/39.0.2171.95 Safari/537.36

这是百度音乐服务器给我返回的信息:

Age:347651
Cache-Control:max-age=31536000
Connection:keep-alive
Content-Length:16659
Content-Type:image/jpeg
Date:Sat, 11 Apr 2015 06:48:45 GMT
Error-Message:OK
ETag:"10487865676202532488"
Expires:Wed, 06 Apr 2016 06:02:50 GMT
Last-Modified:Tue, 07 Apr 2015 05:45:32 GMT
Ohc-Cachable:1
Server:JSP3/2.0.7

这是一般的下载请求，服务器会给我们返回我们请求下载文件的长度(Content-Length)，成功状态码为：200。

而断点续传是要从我们之前已经下载好的文件位置继续上一次的传输，顾名思义我们需要告诉服务器我们上一次已经下载到哪里了，所以在我们的HTTP请求头里要额外的包含一条信息，而这也就是断点续传的奥秘所在了。

这条信息为：（RANGE为请求头属性，X为从什么地方开始，Y为到什么地方结束）

RANGE: bytes=X-Y 

例如：

Range : 用于客户端到服务器端的请求，可通过该字段指定下载文件的某一段大小，及其单位。典型的格式如：
Range: bytes=0-499 下载第0-499字节范围的内容
Range: bytes=500-999 下载第500-999字节范围的内容
Range: bytes=-500 下载最后500字节的内容
Range: bytes=500- 下载从第500字节开始到文件结束部分的内容

以上是HTTP需要注意的地方，接下来讲讲Java里需要注意的几个类

关于这个HTTP请求，在Java的Net包下，给我们封装好了一系列的类，我们直接拿来使用就行了。

这是java.net.URLConnection类下的一个方法，用来设置HTTP请求头的，Key对应HTTP请求头属性，Value对应请求头属性的值。

这是java.io.RandomAccessFile类，这个类的实例支持对随机访问文件的读取和写入，这个类里有个很重要的seek(long pos)方法，

这个方法可以在你设置的长度的下一个位置进行写入，例如seek(599),那么系统下一次写入的位置就是该文件的600位置。

既然是断点续传，那么我们自身肯定也要记录断点位置，所以这里数据库也是必不可少的。

具体实现：

好了，了解了上面的知识点后，可以开始动手写程序了。

下面是我写的一个小Demo，用单线程来实现的断点续传的，注释非常全。

 这是Demo的结构图：（实在不会画图，凑合着看哈）

主类（Activity）：

package com.example.ui;

import android.app.Activity;
import android.app.AlertDialog;
import android.app.ProgressDialog;
import android.app.AlertDialog.Builder;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.DialogInterface;
import android.content.Intent;
import android.content.IntentFilter;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.ProgressBar;
import android.widget.TextView;

import com.example.downloadfiletest.R;
import com.example.entity.FileInfo;
import com.example.logic.DownloadService;

public class MainActivity extends Activity {

    private TextView textView;
    private ProgressBar progressBar;
    private Button bt_start;
    private Button bt_stop;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        initView(); // 初始化控件

        // 注册广播接收者
        IntentFilter intentFilter = new IntentFilter();
        intentFilter.addAction(DownloadService.UPDATE);
        registerReceiver(broadcastReceiver, intentFilter);

    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        // 解绑
        unregisterReceiver(broadcastReceiver);
    }

    // 初始化控件
    private void initView() {
        textView = (TextView) findViewById(R.id.textView);
        progressBar = (ProgressBar) findViewById(R.id.progressBar);
        bt_start = (Button) findViewById(R.id.bt_start);
        bt_stop = (Button) findViewById(R.id.bt_stop);
        progressBar.setMax(100);

        final FileInfo fileInfo = new FileInfo(0, "Best Of Joy.MP3-Michael Jackson", "http://music.baidu.com/data/music/file?link=http://yinyueshiting.baidu.com/data2/music/38264529/382643441428735661128.mp3?xcode=46e7c02e3acba184b6145f688bb9f2422c866f9e4969f410&song_id=38264344", 0, 0);

        // 点击开始下载
        bt_start.setOnClickListener(new OnClickListener() {

            @Override
            public void onClick(View v) {
                Intent intent = new Intent(MainActivity.this, DownloadService.class);
                intent.setAction(DownloadService.START);
                intent.putExtra("FileInfo", fileInfo);
                startService(intent);
                textView.setText("正在下载文件：" + fileInfo.getFileName());

            }
        });

        // 点击停止下载
        bt_stop.setOnClickListener(new OnClickListener() {

            @Override
            public void onClick(View v) {
                Intent intent = new Intent(MainActivity.this, DownloadService.class);
                intent.setAction(DownloadService.STOP);
                intent.putExtra("FileInfo", fileInfo);
                startService(intent);
                textView.setText("任务已暂停，请点击下载继续");
            }
        });

    }

    // 广播接收者
    BroadcastReceiver broadcastReceiver = new BroadcastReceiver() {

        @Override
        public void onReceive(Context context, Intent intent) {
            if (intent.getAction().equals(DownloadService.UPDATE)) {
                int finished = intent.getIntExtra("finished", 0);
                progressBar.setProgress(finished);
                
                //用户界面友好，提醒用户任务下载完成
                if (finished ==100) {
                    AlertDialog.Builder builder=new AlertDialog.Builder(MainActivity.this);
                    builder.setTitle("任务状态");
                    builder.setMessage("文件下载已完成！");
                    builder.setPositiveButton("确认", new DialogInterface.OnClickListener() {
                        
                        @Override
                        public void onClick(DialogInterface dialog, int which) {
                                    progressBar.setProgress(0);
                                    textView.setText("请点击下载");
                        }
                    });
                    builder.show();
                }
            }
        }
    };
}

后台服务类（Service）

package com.example.logic;

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

import org.apache.http.HttpStatus;
import org.apache.http.client.ClientProtocolException;

import android.app.Service;
import android.content.Intent;
import android.os.Environment;
import android.os.Handler;
import android.os.IBinder;
import android.util.Log;

import com.example.entity.FileInfo;

public class DownloadService extends Service {

    // 按钮标志符
    public static final String START = "START";
    public static final String STOP = "STOP";
    // 更新进度标志
    public static final String UPDATE = "UPDATE";
    // 下载路径(内存卡（SD）根目录下的/downloads/)
    public static final String DOWNLOADPATH = Environment.getExternalStorageDirectory().getAbsolutePath() + "/downloads/";
    // 定义初始化文件操作标志
    public static final int INIT = 0;

    private DownloadTask downloadTask;

    private Handler handler = new Handler() {
        public void handleMessage(android.os.Message msg) {
            switch (msg.what) {
            case INIT:
                FileInfo fileInfo = (FileInfo) msg.obj;
                Log.i("init", fileInfo.toString());
                // 进行下载任务操作
                downloadTask = new DownloadTask(DownloadService.this, fileInfo);
                downloadTask.download();
                break;
            }
        };
    };

    /**
     * 当Service启动时会被调用，用来接收Activity传送过来的数据
     */
    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        if (intent.getAction().equals(START)) {
            // 当点击开始下载操作时
            // 接收Activity(putExtra)过来的数据
            FileInfo fileInfo = (FileInfo) intent.getSerializableExtra("FileInfo");
            Log.i(START, fileInfo.toString());
            new Thread(new InitFileThread(fileInfo)).start();

        } else if (intent.getAction().equals(STOP)) {
            // 当点击停止下载操作时
            FileInfo fileInfo = (FileInfo) intent.getSerializableExtra("FileInfo");
            Log.i(STOP, fileInfo.toString());
            // 暂定任务
            if (downloadTask != null) {
                downloadTask.flag = true;
            }
        }

        return super.onStartCommand(intent, flags, startId);
    }

    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }

    // 初始化文件操作获取网络资源大小长度，开辟子线程
    class InitFileThread implements Runnable {

        private FileInfo fileInfo;

        // 构造方法，获取文件对象
        public InitFileThread(FileInfo fileInfo) {
            this.fileInfo = fileInfo;
        }

        @Override
        public void run() {
            /*
             * 1、打开网络连接，获取文件长度 2、创建本地文件，长度和网络文件相等
             */
            HttpURLConnection httpURLConnection = null;
            RandomAccessFile randomAccessFile = null;
            try {
                URL url = new URL(fileInfo.getUrl());
                httpURLConnection = (HttpURLConnection) url.openConnection();
                // 知识点：除了下载文件，其他一律用POST
                httpURLConnection.setConnectTimeout(3000);
                httpURLConnection.setRequestMethod("GET");
                // 定义文件长度
                int length = -1;
                // 网络连接成功
                if (httpURLConnection.getResponseCode() == HttpStatus.SC_OK) {
                    length = httpURLConnection.getContentLength();
                }
                // 判断是否取得文件长度
                if (length <= 0) {
                    return;
                }

                // 创建文件目录对象
                File dir = new File(DOWNLOADPATH);
                if (!dir.exists()) {
                    // 若目录不存在，创建
                    dir.mkdir();
                }
                // 创建文件对象
                File file = new File(dir, fileInfo.getFileName());
                // 创建随机访问文件流 参数二为权限：读写删
                randomAccessFile = new RandomAccessFile(file, "rwd");
                randomAccessFile.setLength(length);
                fileInfo.setLength(length);
                // 发送handler
                handler.obtainMessage(INIT, fileInfo).sendToTarget();

            } catch (ClientProtocolException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (randomAccessFile != null) {
                    try {
                        randomAccessFile.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }

        }

    }

}

下载任务类：

package com.example.logic;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.List;

import org.apache.http.HttpStatus;

import android.content.Context;
import android.content.Intent;
import android.util.Log;

import com.example.dao.ThreadDAO;
import com.example.dao.ThreadDAOImpl;
import com.example.entity.FileInfo;
import com.example.entity.ThreadInfo;

/**
 * 下载任务类
 * 
 * @author Balla_兔子
 * 
 */
public class DownloadTask {
    private Context context;
    private ThreadDAO dao;
    private FileInfo fileInfo;
    // 初始化下载进度，默认为0
    private int finished = 0;

    // 是否暂停下载标识符
    public boolean flag = false;

    public DownloadTask(Context context, FileInfo fileInfo) {
        this.context = context;
        this.fileInfo = fileInfo;
        dao = new ThreadDAOImpl(context);
    }

    public void download() {
        // 线程信息的url和文件的url对应
        List<ThreadInfo> threadInfos = dao.getThreadInfo(fileInfo.getUrl());
        ThreadInfo threadInfo = null;
        if (threadInfos.size() == 0) {
            // 若数据库无此线程任务
            threadInfo = new ThreadInfo(0, fileInfo.getUrl(), 0, fileInfo.getLength(), 0);
        } else {
            threadInfo = threadInfos.get(0);
        }
        // 创建子线程进行下载
        new Thread(new DownloadThread(threadInfo)).start();
    }

    // 执行下载任务，开辟子线程
    class DownloadThread implements Runnable {

        private ThreadInfo threadInfo;

        public DownloadThread(ThreadInfo threadInfo) {
            this.threadInfo = threadInfo;
        }

        @Override
        public void run() {
            HttpURLConnection urlConnection = null;
            InputStream inputStream = null;
            RandomAccessFile randomAccessFile = null;

            /**
             * 执行下载任务 
             * 1、查询数据库，确定是否已存在此下载线程，便于继续下载 
             * 2、设置从哪个位置开始下载 
             * 3、设置文件的写入位置
             * 4、开始下载 
             * 5、广播通知UI更新下载进度 
             * 6、暂停线程的操作 
             * 7、下载完毕，删除数据库信息
             */
            // 1、查询数据库
            if (!dao.isExists(threadInfo.getUrl(), threadInfo.getThread_id())) {
                // 若不存在，插入新线程信息
                dao.insertThread(threadInfo);
            }

            // 2、设置下载位置
            try {
                URL url = new URL(threadInfo.getUrl());
                urlConnection = (HttpURLConnection) url.openConnection();
                // 设置连接超时时间
                urlConnection.setConnectTimeout(3000);
                urlConnection.setRequestMethod("GET");

                // 设置请求属性
                // 参数一：Range头域可以请求实体的一个或者多个子范围(一半用于断点续传)，如果用户的请求中含有range
                // ，则服务器的相应代码为206。
                // 参数二：表示请求的范围：比如头500个字节：bytes=0-499

                // 获取线程已经下载的进度
                int start = threadInfo.getStart() + threadInfo.getFinished();
                urlConnection.setRequestProperty("range", "bytes=" + start + "-" + threadInfo.getEnd());

                // 3、设置文件的写入位置
                File file = new File(DownloadService.DOWNLOADPATH, fileInfo.getFileName());
                randomAccessFile = new RandomAccessFile(file, "rwd");
                // 设置从哪里开始写入，如参数为100，那就从101开始写入
                randomAccessFile.seek(start);

                finished += threadInfo.getFinished();
                Intent intent = new Intent(DownloadService.UPDATE);
                // 4、开始下载
                if (urlConnection.getResponseCode() == HttpStatus.SC_PARTIAL_CONTENT) {
                    inputStream = urlConnection.getInputStream();
                    // 设置字节数组缓冲区
                    byte[] data = new byte[1024*4];
                    // 读取长度
                    int len = -1;
                    // 取得当前时间
                    long time = System.currentTimeMillis();
                    while ((len = inputStream.read(data)) != -1) {
                        // 读取成功,写入文件
                        randomAccessFile.write(data, 0, len);

                        // 避免更新过快，减缓主线程压力，让其0.5秒发送一次进度
                        if (System.currentTimeMillis() - time > 500) {
                            time = System.currentTimeMillis();
                            // 把当前进度通过广播传递给UI
                            finished += len;
                            Log.i("finished:", finished+"");
                            Log.i("file:", fileInfo.getLength()+"");
                            intent.putExtra("finished", finished*100 / fileInfo.getLength());
                            context.sendBroadcast(intent);
                        }

                        if (flag) {
                            // 暂停下载，更新进度到数据库
                            dao.updateThread(threadInfo.getUrl(), threadInfo.getThread_id(), finished);
                            // 结束线程
                            return;
                        }

                    }
                    // 当下载执行完毕时，删除数据库线程信息
                    dao.deleteThread(threadInfo.getUrl(), threadInfo.getThread_id());
                }

            } catch (MalformedURLException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (urlConnection != null) {
                    urlConnection.disconnect();
                }
                if (inputStream != null) {
                    try {
                        inputStream.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
                if (randomAccessFile != null) {
                    try {
                        randomAccessFile.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }

            }

        }
    }
}

数据库帮助类：

package com.example.db;

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;

public class DBHelper extends SQLiteOpenHelper {
    public static final String DBNAME = "download.db";
    public static final int VERSION = 1;
    public static final String TABLE="threadinfo";
    public static final String CREATE_DB = "create table threadinfo (_id integer primary key autoincrement,thread_id integer,url text,start integer,end integer,finished integer) ";
    public static final String DROP_DB = "drop table if exists threadinfo";

    public DBHelper(Context context) {
        super(context, DBNAME, null, VERSION);
    }

    @Override
    public void onCreate(SQLiteDatabase db) {
        db.execSQL(CREATE_DB);

    }

    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        db.execSQL(DROP_DB);
        db.execSQL(CREATE_DB);
    }

}

数据库表接口类：

package com.example.dao;

import java.util.List;

import com.example.entity.ThreadInfo;

public interface ThreadDAO {
    // 新增一条线程信息
    public void insertThread(ThreadInfo threadInfo);

    // 删除一条线程信息(多线程下载，可能一个url对应多个线程，所以需要2个条件)
    public void deleteThread(String url, int thread_id);

    // 修改一条线程信息
    public void updateThread(String url, int thread_id, int finished);

    // 查询线程有关信息（根据url查询下载该url的所有线程信息）
    public List<ThreadInfo> getThreadInfo(String url);

    // 判断线程是否已经存在
    public boolean isExists(String url, int thread_id);


}

数据库表接口实现类：

package com.example.dao;

import java.util.ArrayList;
import java.util.List;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;

import com.example.db.DBHelper;
import com.example.entity.ThreadInfo;

/**
 * ThreadDAO接口实现类
 * 
 * @author Balla_兔子
 * 
 */
public class ThreadDAOImpl implements ThreadDAO {

    private DBHelper dbHelper;

    public ThreadDAOImpl(Context context) {
        dbHelper = new DBHelper(context);
    }

    @Override
    public void insertThread(ThreadInfo threadInfo) {
        SQLiteDatabase db = dbHelper.getWritableDatabase();
        ContentValues values = new ContentValues();
        values.put("thread_id", threadInfo.getThread_id());
        values.put("url ", threadInfo.getUrl());
        values.put("start ", threadInfo.getStart());
        values.put("end ", threadInfo.getEnd());
        values.put("finished ", threadInfo.getFinished());
        db.insert(DBHelper.TABLE, null, values);
        db.close();
    }

    @Override
    public void deleteThread(String url, int thread_id) {
        SQLiteDatabase db = dbHelper.getWritableDatabase();
        db.delete(DBHelper.TABLE, "url=? and thread_id=?", new String[] { url, String.valueOf(thread_id) });
        db.close();
    }

    @Override
    public void updateThread(String url, int thread_id, int finished) {
        SQLiteDatabase db = dbHelper.getWritableDatabase();
        db.execSQL("update threadinfo set finished = ? where url = ? and thread_id=?", new Object[] { finished, url, thread_id });
        db.close();
    }

    @Override
    public List<ThreadInfo> getThreadInfo(String url) {
        List<ThreadInfo> list = new ArrayList<ThreadInfo>();
        SQLiteDatabase db = dbHelper.getWritableDatabase();
        Cursor cursor = db.query(DBHelper.TABLE, null, "url=?", new String[] { url }, null, null, null);
        while (cursor.moveToNext()) {
            ThreadInfo threadInfo = new ThreadInfo();
            threadInfo.setThread_id(cursor.getInt(cursor.getColumnIndex("thread_id")));
            threadInfo.setUrl(cursor.getString(cursor.getColumnIndex("url")));
            threadInfo.setStart(cursor.getInt(cursor.getColumnIndex("start")));
            threadInfo.setEnd(cursor.getInt(cursor.getColumnIndex("end")));
            threadInfo.setFinished(cursor.getInt(cursor.getColumnIndex("finished")));
            list.add(threadInfo);
        }
        cursor.close();
        db.close();
        return list;
    }

    @Override
    public boolean isExists(String url, int thread_id) {
        SQLiteDatabase db = dbHelper.getWritableDatabase();
        Cursor cursor = db.query(DBHelper.TABLE, null, "url=? and thread_id=?", new String[] { url, String.valueOf(thread_id) }, null, null, null);
        boolean isExists = cursor.moveToNext();
        db.close();
        return isExists;
    }

}

实体类：（文件，线程）

文件实体类：

package com.example.entity;

import java.io.Serializable;

public class FileInfo implements Serializable {

    private int id;
    private String fileName;
    private String url;
    private int length;
    private int finished;

    public FileInfo() {
    }

    public FileInfo(int id, String fileName, String url, int length,
            int finished) {
        super();
        this.id = id;
        this.fileName = fileName;
        this.url = url;
        this.length = length;
        this.finished = finished;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getFileName() {
        return fileName;
    }

    public void setFileName(String fileName) {
        this.fileName = fileName;
    }

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    public int getLength() {
        return length;
    }

    public void setLength(int length) {
        this.length = length;
    }

    public int getFinished() {
        return finished;
    }

    public void setFinished(int finished) {
        this.finished = finished;
    }

    @Override
    public String toString() {
        return "FileInfo [id=" + id + ", fileName=" + fileName + ", url=" + url
                + ", length=" + length + ", finished=" + finished + "]";
    }

}

线程实体类：

package com.example.entity;

import java.io.Serializable;

public class ThreadInfo implements Serializable {

    private int thread_id;
    private String url;
    private int start;
    private int end;
    private int finished;

    public ThreadInfo() {
    }

    public ThreadInfo(int thread_id, String url, int start, int end, int finished) {
        super();
        this.thread_id = thread_id;
        this.url = url;
        this.start = start;
        this.end = end;
        this.finished = finished;
    }

    public int getThread_id() {
        return thread_id;
    }

    public void setThread_id(int thread_id) {
        this.thread_id = thread_id;
    }

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    public int getStart() {
        return start;
    }

    public void setStart(int start) {
        this.start = start;
    }

    public int getEnd() {
        return end;
    }

    public void setEnd(int end) {
        this.end = end;
    }

    public int getFinished() {
        return finished;
    }

    public void setFinished(int finished) {
        this.finished = finished;
    }

    @Override
    public String toString() {
        return "ThreadInfo [thread_id=" + thread_id + ", url=" + url + ", start=" + start + ", end=" + end + ", finished=" + finished + "]";
    }

}

关于多线程的断点续传，其实原理差不多，还是一样把一个文件分成不同区域，然后每个区域各用一条线程去执行下载任务，然后再把文件合并，改天有时间再上个Demo给大家看吧。

 

作者：Balla_兔子
出处：http://www.cnblogs.com/lichenwei/
本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文链接。
正在看本人博客的这位童鞋，我看你气度不凡，谈吐间隐隐有王者之气，日后必有一番作为！旁边有“推荐”二字，你就顺手把它点了吧，相得准，我分文不收；相不准，你也好回来找我！