android 多线程断点续传下载 一

转载自：http://blog.csdn.net/shimiso/article/details/6763664

android 多线程断点续传下载 一

想做一个下载功能，当然理想的功能要支持多任务同时下载，断点续传的功能，我想一步一步来，首先困难摆在了多任务这里

开始我的思路是在一个Service中启动下载的流操作，然后通过Service中声明一个Activity中的Handler更新UI(比如进度条。。。)

可是我发现在Service中声明一个Activity中的Handler是做不到的（可能只是我做不到吧，无法申请内存）

于是，我决定在Activity中直接启动线程，让其运行，调用自身的Handler来更新UI，没想到在这个下载Activity onPause（）的时候，线程还是活的，也就是说可以继续下载，下例是我做的一个两个任务同时下载的小例子，后面会把理想中的功能都陆续添加上的...

main.xml配置:

[html] view
plain copy

<?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">  

    <ProgressBar style="?android:attr/progressBarStyleHorizontal"  

        android:layout_height="wrap_content" android:id="@+id/progressBar1"  

        android:layout_width="fill_parent"></ProgressBar>  

  

    <TextView android:layout_width="fill_parent" android:id="@+id/textView1"  

        android:layout_height="wrap_content" />  

    <ProgressBar style="?android:attr/progressBarStyleHorizontal"  

        android:layout_height="wrap_content" android:id="@+id/progressBar2"  

        android:layout_width="fill_parent"></ProgressBar>  

  

    <TextView android:layout_width="fill_parent" android:id="@+id/textView2"  

        android:layout_height="wrap_content" />  

</LinearLayout>  

AndroidManifest.xml配置:

[html] view
plain copy

<?xml version="1.0" encoding="utf-8"?>  

<manifest xmlns:android="http://schemas.android.com/apk/res/android"  

      package="sms.down"  

      android:versionCode="1"  

      android:versionName="1.0">  

    <uses-sdk android:minSdkVersion="9" />  

  

    <application android:icon="@drawable/icon" android:label="@string/app_name">  

        <activity android:name=".MulThreadDownload"  

                  android:label="@string/app_name">  

            <intent-filter>  

                <action android:name="android.intent.action.MAIN" />  

                <category android:name="android.intent.category.LAUNCHER" />  

            </intent-filter>  

        </activity>  

  

    </application>  

      

    <!-- 访问 internet 权限 -->  

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

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

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

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

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

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

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

</manifest>  

activity程序:

[java] view
plain copy

package sms.down;  

  

import java.io.File;  

import java.io.FileOutputStream;  

import java.io.IOException;  

import java.io.InputStream;  

import java.io.OutputStream;  

import java.net.HttpURLConnection;  

import java.net.MalformedURLException;  

import java.net.URL;  

import android.app.Activity;  

import android.os.Bundle;  

import android.os.Environment;  

import android.os.Handler;  

import android.os.Message;  

import android.widget.ProgressBar;  

import android.widget.TextView;  

  

public class MulThreadDownload extends Activity {  

    /** Called when the activity is first created. */  

    private ProgressBar pb1 = null;  

    private TextView tv1 = null;  

    private ProgressBar pb2 = null;  

    private TextView tv2 = null;  

  

    private String root = Environment.getExternalStorageDirectory()  

            .getAbsolutePath() + File.separator;  

    private String downloadFile = "http://gongxue.cn/yingyinkuaiche/UploadFiles_9323/201008/2010082909434077.mp3";  

    private String downloadFile1 = "http://gongxue.cn/yingyinkuaiche/UploadFiles_9323/201008/2010082909434077.mp3";  

  

    // 声明已经读过的长度变量  

    private int hasRead = 0;  

  

    public void onCreate(Bundle savedInstanceState) {  

        super.onCreate(savedInstanceState);  

        setContentView(R.layout.main);  

  

        pb1 = (ProgressBar) findViewById(R.id.progressBar1);  

        tv1 = (TextView) findViewById(R.id.textView1);  

  

        pb2 = (ProgressBar) findViewById(R.id.progressBar2);  

        tv2 = (TextView) findViewById(R.id.textView2);  

  

        download(downloadFile, root, pb1, tv1);  

  

        download(downloadFile1, root, pb2, tv2);  

    }  

  

    private void download(String url, String targetPath, ProgressBar pb,  

            TextView tv) {  

        DownloadThread dt = new DownloadThread(url, targetPath, pb, tv);  

  

        dt.start();  

    }  

  

    // 自定义一个Handler类，处理线程消息  

    public class MyHandler extends Handler {  

        private ProgressBar progressBar;  

        private TextView textView;  

  

        // 通过构造函数来确定给哪个ProgressBar刷新  

        public MyHandler(ProgressBar progressBar, TextView textView) {  

            this.progressBar = progressBar;  

            this.textView = textView;  

        }  

  

        public void handleMessage(Message msg) {  

            this.progressBar.setProgress(msg.arg1);  

            this.textView.setText(msg.arg1 + "%");  

  

            super.handleMessage(msg);  

        }  

    }  

  

    // 下载线程  

    public class DownloadThread extends Thread {  

        private String url = "";  

        private String targetPath = "";  

  

        private int hasDownload = 0;  

  

        private int len = -1;  

        private byte buffer[] = new byte[4 * 1024];  

        private int size = 0;  

        private int rate = 0;  

  

        private MyHandler myHandler = null;  

        private Message msg = null;  

  

        private ProgressBar pb = null;  

        private TextView tv = null;  

  

        public DownloadThread(String url, String targetPath, ProgressBar pb,  

                TextView tv) {  

            this.url = url;  

            this.targetPath = targetPath;  

  

            this.pb = pb;  

            this.tv = tv;  

  

            myHandler = new MyHandler(this.pb, this.tv);  

        }  

  

        public void run() {  

            String targetFileName = this.targetPath  

                    + this.url.substring(this.url.lastIndexOf("/") + 1,  

                            this.url.length());  

            File downloadFile = new File(targetFileName);  

  

            if (!downloadFile.exists()) {  

                try {  

                    downloadFile.createNewFile();  

                } catch (IOException e) {  

                    // TODO Auto-generated catch block  

                    e.printStackTrace();  

                }  

            }  

  

            try {  

                URL fileUrl = new URL(this.url);  

                HttpURLConnection conn = (HttpURLConnection) fileUrl  

                        .openConnection();  

  

                // 获取文件大小  

                size = conn.getContentLength();  

  

                InputStream is = conn.getInputStream();  

  

                OutputStream os = new FileOutputStream(targetFileName);  

  

                while ((len = is.read(buffer)) != -1) {  

                    os.write(buffer);  

  

                    hasDownload += len;  

  

                    rate = (hasDownload * 100 / size);  

  

                    msg = new Message();  

  

                    msg.arg1 = rate;  

  

                    myHandler.sendMessage(msg);  

  

                    System.out.println(rate + "%");  

                }  

            } catch (MalformedURLException e) {  

                // TODO Auto-generated catch block  

                e.printStackTrace();  

            } catch (IOException e) {  

                e.printStackTrace();  

            }  

  

        }  

    }  

  

}  

程序运行效果:



源码下载

下一步将实现断点续传和暂停删除开始事件,更多更新敬请关注....