android多任务同时下载

简介:
 

学习android快两个月了,一直坚持从迷茫中寻找可以得到的尽可能多的东西

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

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

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

 

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

 

package oneRain.MulThreadDownload;

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 oneRain.MulThreadDownload.DownloadServicer.DownloadThread;

import android.app.Activity;
import android.content.Intent;
import android.os.Bundle;
import android.os.Environment;
import android.os.Handler;
import android.os.Looper;
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://192.168.1.5/android/test.zip";
    private String downloadFile1 = "http://192.168.1.5/android/test1.exe";
   
    //声明已经读过的长度变量
    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();
            } 
           
        }
    }
   
}

相关文章
|
4月前
|
存储 缓存 Android开发
安卓Jetpack Compose+Kotlin, 使用ExoPlayer播放多个【远程url】音频,搭配Okhttp库进行下载和缓存,播放完随机播放下一首
这是一个Kotlin项目,使用Jetpack Compose和ExoPlayer框架开发Android应用,功能是播放远程URL音频列表。应用会检查本地缓存,如果文件存在且大小与远程文件一致则使用缓存,否则下载文件并播放。播放完成后或遇到异常,会随机播放下一首音频,并在播放前随机设置播放速度(0.9到1.2倍速)。代码包括ViewModel,负责音频管理和播放逻辑,以及UI层,包含播放和停止按钮。
|
2月前
|
Ubuntu 开发工具 Android开发
Repo下载AOSP源码:基于ubuntu22.04 环境配置,android-12.0.0_r32
本文介绍了在基于Ubuntu 22.04的环境下配置Python 3.9、安装repo工具、下载和同步AOSP源码包以及处理repo同步错误的详细步骤。
171 0
Repo下载AOSP源码:基于ubuntu22.04 环境配置,android-12.0.0_r32
|
11天前
|
Android开发
Android gradle task任务检查各个module之间资源文件冲突.md
Android gradle task任务检查各个module之间资源文件冲突.md
Android gradle task任务检查各个module之间资源文件冲突.md
|
14天前
|
Android开发 Kotlin
Android面试题之Kotlin中如何实现串行和并行任务?
本文介绍了 Kotlin 中 `async` 和 `await` 在并发编程中的应用,包括并行与串行任务的处理方法。并通过示例代码展示了如何启动并收集异步任务的结果。
13 0
|
2月前
|
开发工具 uml git
AOSP源码下载方法,解决repo sync错误:android-13.0.0_r82
本文分享了下载AOSP源码的方法,包括如何使用repo工具和处理常见的repo sync错误,以及配置Python环境以确保顺利同步特定版本的AOSP代码。
277 0
AOSP源码下载方法,解决repo sync错误:android-13.0.0_r82
|
2月前
|
API 开发工具 Android开发
Android源码下载
Android源码下载
331 0
|
2月前
|
存储 监控 数据库
Android经典实战之OkDownload的文件分段下载及合成原理
本文介绍了 OkDownload,一个高效的 Android 下载引擎,支持多线程下载、断点续传等功能。文章详细描述了文件分段下载及合成原理,包括任务创建、断点续传、并行下载等步骤,并展示了如何通过多种机制保证下载的稳定性和完整性。
71 0
|
2月前
|
Ubuntu 开发工具 Android开发
Repo下载、编译AOSP源码:基于Ubuntu 21.04,android-12.1.0_r27
文章记录了作者在Ubuntu 21.04服务器上配置环境、下载并编译基于Android 12.1.0_r27版本的AOSP源码的过程,包括解决编译过程中遇到的问题和错误处理方法。
111 0
|
4月前
|
Android开发 Windows
如何离线下载 Microsoft Corporation II Windows Subsystem for Android
如何离线下载 Microsoft Corporation II Windows Subsystem for Android