安卓下载多线程带进度条-低调大师

安卓下载多线程带进度条

2017-10-17 608

当我们学完java中多线程的下载后，能够将它移植到我们的安卓中来。以下是详细实现源代码：

DownActivity.java

[java]view plaincopy
package com.example.downloads;  
  
import java.io.File;  
import java.io.IOException;  
import java.io.RandomAccessFile;  
import java.net.HttpURLConnection;  
import java.net.MalformedURLException;  
import java.net.URL;  
import com.example.downloads.utils.DownLoadThread;  
import android.os.Bundle;  
import android.os.Environment;  
import android.os.Handler;  
import android.os.Message;  
import android.annotation.SuppressLint;  
import android.app.Activity;  
import android.text.TextUtils;  
import android.view.Menu;  
import android.view.View;  
import android.widget.EditText;  
import android.widget.ProgressBar;  
import android.widget.TextView;  
import android.widget.Toast;  
  
public class DownActivity extends Activity {  
    // 声明控件  
    // 路径与线程数量  
    public EditText et_url, et_num;  
    // 进度条  
    public static ProgressBar pb_thread;  
    // 显示运行进度的操作  
    public TextView tv_pb;  
    // 线程的数量  
    public static int threadNum = 3;  
    // 每一个线程负责下载的大小  
    public int blockSize;  
    public static int threadCount;// 数量  
    // 訪问的path  
    public String path;  
    public static boolean flag = true;  
    // 记录进度条的值  
    public static int pb_count = 0;  
    public static Handler handler;  
    public static final int TEXTVALUE = 1;  
    public static int pb_num = 0;  
    public static int size = 0;  
  
    @Override  
    protected void onCreate(Bundle savedInstanceState) {  
        super.onCreate(savedInstanceState);  
        setContentView(R.layout.activity_down);  
        et_url = (EditText) findViewById(R.id.et_path);  
        et_num = (EditText) findViewById(R.id.et_threadNum);  
        pb_thread = (ProgressBar) findViewById(R.id.pb_down);  
        tv_pb = (TextView) findViewById(R.id.tv_pb);  
        handler = new Handler() {  
            @SuppressLint("HandlerLeak")  
            @Override  
            public void handleMessage(Message msg) {  
                super.handleMessage(msg);  
                switch (msg.what) {  
                case TEXTVALUE:  
                    System.out.println("-------" + DownActivity.pb_count  
                            + "//////" + DownActivity.size);  
                    // 改变TEXTView  
                    pb_num = (DownActivity.pb_count * 100) / DownActivity.size;  
                    tv_pb.setText("当前进度是+" + pb_num + "%");  
                      
                    break;  
  
                default:  
                    break;  
                }  
            }  
  
        };  
  
    }  
  
    @Override  
    public boolean onCreateOptionsMenu(Menu menu) {  
        // Inflate the menu; this adds items to the action bar if it is present.  
        getMenuInflater().inflate(R.menu.main, menu);  
        return true;  
    }  
  
    public void downLoad(View v) {  
        DownActivity.flag = true;  
        DownActivity.pb_count = 0;  
  
        path = et_url.getText().toString();  
        String threadNum_et = et_num.getText().toString();  
  
        if (TextUtils.isEmpty(path) || TextUtils.isEmpty(threadNum_et)) {  
            Toast.makeText(this, "不能为空", Toast.LENGTH_LONG).show();  
            return;  
        }  
        Toast.makeText(this, "url:" + path + "--" + threadNum_et,  
                Toast.LENGTH_LONG).show();  
        // 转换成数字  
        threadNum = Integer.valueOf(threadNum_et);  
        new Thread(new Runnable() {  
            @Override  
            public void run() {  
                try {  
                    // 创建出URL对象  
                    URL url = new URL(path);  
                    // 创建出 HttpURLConnection对象  
                    HttpURLConnection httpURLConnection = (HttpURLConnection) url  
                            .openConnection();  
  
                    // 设置 发请求发送的方式  
                    httpURLConnection.setRequestMethod("GET");  
                    // 设置请求是否超时时间  
                    httpURLConnection.setConnectTimeout(5000);  
                    // 设置  
                    httpURLConnection  
                            .setRequestProperty("User-Agent",  
                                    " Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.2; Trident/6.0)");  
  
                    // 是否响应成功  
                    if (httpURLConnection.getResponseCode() == 200) {  
                        // 获取文件的大小  
                        size = httpURLConnection.getContentLength();  
                        System.out.println("文件的大小" + size);  
                        // 设置进度条的最大值  
                        pb_thread.setMax(size);  
  
                        // 创建文件 //保存到SD卡上  
  
                        // 首先推断是否拥有sdcard  
                        if (Environment.getExternalStorageState().equals(  
                                Environment.MEDIA_MOUNTED)) {  
                            // 获取sdCard文件文件夹对象  
                            File sdFile = Environment  
                                    .getExternalStorageDirectory();  
                            // 创建文件对象  
                            File file = new File(sdFile, "youdao.exe");  
  
                            RandomAccessFile accessFile = new RandomAccessFile(  
                                    file, "rwd");  
                            // 设置文件的大小  
                            accessFile.setLength(size);  
                            // 每一个线程下载的大小  
                            blockSize = size / threadNum;  
                            // 开三个线程 操作此文件  
                            for (int i = 1; i <= threadNum; i++) {  
                                // 1 2 3  
                                // 计算出每一个线程開始的位置  
                                int startSize = (i - 1) * blockSize;  
                                // 结束位置  
                                int endSize = (i) * blockSize;  
                                // 当线程是最后一个线程的时候  
                                if (i == threadNum) {  
                                    // 推断文件的大小是否大于计算出来的结束位置  
                                    if (size > endSize) {  
                                        // 结束位置 等于 文件的大小  
                                        endSize = size;  
                                    }  
                                }  
                                // 为每一个线程创建一个随机的读取  
                                RandomAccessFile threadAccessFile = new RandomAccessFile(  
                                        file, "rwd");  
                                new Thread(new DownLoadThread(i,  
                                        threadAccessFile, startSize, endSize,  
                                        path)).start();  
                            }  
  
                        }  
  
                    }  
  
                } catch (MalformedURLException e) {  
                      
                    e.printStackTrace();  
                } catch (IOException e) {  
                      
                    e.printStackTrace();  
                }  
  
            }  
  
        }).start();  
    }  
  
    /** 
     * 暂停操作 
     *  
     * @param v 
     */  
    public void downPause(View v) {  
        Toast.makeText(this, "暂停", Toast.LENGTH_LONG).show();  
  
        this.flag = false;  
  
    }  
  
}  

DownLoadThread.java

[java]view plaincopy
package com.example.downloads.utils;  
  
import java.io.File;  
import java.io.FileInputStream;  
import java.io.FileOutputStream;  
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 com.example.downloads.DownActivity;  
  
import android.os.Environment;  
  
  
  
public class DownLoadThread implements Runnable {  
  
      
    public RandomAccessFile accessFile; // 每一个线程 都拥有一个accessFile的文件对象 线程1 线程2 线程3  
  
    // 线程下载文件的起始位置  
    public int startSize;  
    public int endSize;  
  
    // 文件下载的path路径  
    public String path;  
  
    public int threadId; // 线程的标识  
  
    public DownLoadThread(int threadId, RandomAccessFile accessFile,  
            int startSize, int endSize, String path) {  
  
        this.threadId = threadId;  
        this.accessFile = accessFile;  
        this.startSize = startSize;  
        this.endSize = endSize;  
        this.path = path;  
    }  
  
    @Override  
    public void run() {  
        // 运行run方法  
        try {  
  
            // 创建文件到SD卡上去  
  
            // 首先推断是否拥有sdcard  
            if (Environment.getExternalStorageState().equals(  
                    Environment.MEDIA_MOUNTED)) {  
                // 获取sdCard文件文件夹对象  
                File sdFile = Environment.getExternalStorageDirectory();  
                File threadFile = new File(sdFile, threadId + ".txt");  
  
                if (threadFile.exists()) {  
  
                    // 读取该文件的内容  
                    // 创建文件的输入流对象  
                    FileInputStream fis = new FileInputStream(threadFile);  
                    // 採用工具类读取  
                    byte data[] = StreamTools.isToData(fis);  
                    // 转化成字符串  
                    String threadLen = new String(data);  
  
                    if ((threadLen != null) && (!"".equals(threadLen))) {  
                        startSize = Integer.valueOf(threadLen);  
  
                        // 解决 416bug的错误  
                        if (startSize > endSize) {  
                            startSize = endSize - 1;  
                        }  
                    }  
  
                }  
  
                // 创建文件  
  
                // 创建URL对象  
                URL url = new URL(path);  
                // 创建HttpURLConnection对象  
                HttpURLConnection httpURLConnection = (HttpURLConnection) url  
                        .openConnection();  
                // 设置请求的头  
  
                httpURLConnection.setRequestMethod("GET");  
                // 设置请求是否超时时间  
                httpURLConnection.setConnectTimeout(5000);  
                // 设置  
                httpURLConnection  
                        .setRequestProperty("User-Agent",  
                                " Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.2; Trident/6.0)");  
  
                // 关键的设置  
                httpURLConnection.setRequestProperty("Range", "bytes="  
                        + startSize + "-" + endSize);  
  
                // 输出当前线程  
                System.out.println("当前线程" + threadId + " 下载開始位置:" + startSize  
                        + " 下载结束位置:" + endSize);  
                // 响应成功  
  
                // 设置随机读取文件的 開始位置  
                accessFile.seek(startSize);  
                // 获取对应流对象  
                InputStream is = httpURLConnection.getInputStream();  
                // 创建输出流对象  
  
                byte buffer[] = new byte[1024];  
                int len = 0;  
                int threadTotal = 0;// 每一个线程下载后保存记录 /  
                while ((len = is.read(buffer)) != -1) {  
                    accessFile.write(buffer, 0, len);  
                    threadTotal += len;// 记录你写入的长度 //xml文件  
  
                    //改变进度条：  
                    setProgressBar(len);  
                    // 通过文件记录文件下载的长度  
                    FileOutputStream fos = new FileOutputStream(threadFile);  
                    fos.write((threadTotal + "").getBytes());  
                    fos.flush();  
                    fos.close();  
                    //发送handler消息  
                    DownActivity.handler.sendEmptyMessage(DownActivity.TEXTVALUE);  
                    if(!DownActivity.flag){  
                        return;  
                    }  
  
                }  
                accessFile.close();  
                is.close();  
                System.out.println(threadId + "线程运行完成");  
  
                // 线程操作  
                synchronized (DownActivity.class) {  
                    DownActivity.threadCount++;  
                    if (DownActivity.threadCount >= DownActivity.threadNum) {  
                        for (int i = 1; i <= DownActivity.threadNum; i++) {  
                            // 获取sdCard上的文件  
                            File deleteFile = new File(sdFile, i + ".txt");  
                            if (deleteFile.exists()) {  
                                // 文件删除  
                                deleteFile.delete();  
                            }  
                        }  
                    }  
                }  
            }  
        } catch (MalformedURLException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        } catch (IOException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }  
  
    }  
  
      
      
      
    public synchronized void setProgressBar(int len){  
        DownActivity.pb_count+=len;  
        DownActivity.pb_thread.setProgress(DownActivity.pb_count);  
    }  
      
      
      
}  

StreamTools.java

[java]view plaincopy
package com.example.downloads.utils;  
  
import java.io.ByteArrayOutputStream;  
import java.io.IOException;  
import java.io.InputStream;  
  
public class StreamTools {  
  
      
    public static byte[] isToData(InputStream is) throws IOException{  
        // 字节输出流  
        ByteArrayOutputStream bops = new ByteArrayOutputStream();  
        // 读取数据的缓存区  
        byte buffer[] = new byte[1024];  
        // 读取长度的记录  
        int len = 0;  
        // 循环读取  
        while ((len = is.read(buffer)) != -1) {  
            bops.write(buffer, 0, len);  
        }  
        // 把读取的内容转换成byte数组  
        byte data[] = bops.toByteArray();  
          
        bops.flush();  
        bops.close();  
        is.close();  
        return data;  
    }  
}  

strings.xml

[html]view plaincopy
<?xml version="1.0" encoding="utf-8"?>  
<resources>  
  
    <string name="app_name">downloads</string>  
    <string name="action_settings">Settings</string>  
    <string name="tv_down">文件下载的地址</string>  
    <string name="tv_threadNum">线程数量</string>  
    <string name="tv_num">0%</string>  
    <string name="btn_text">下载</string>  
    <string name="btn_pause">暂停</string>  
    <string name="et_path">http://172.22.64.8:8080/doudou/youdao.exe</string>  
    <string name="et_threadNum">3</string>  
  
</resources>  

布局文件：

[html]view plaincopy
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"  
    xmlns:tools="http://schemas.android.com/tools"  
    android:layout_width="match_parent"  
    android:layout_height="match_parent"  
    android:paddingBottom="@dimen/activity_vertical_margin"  
    android:paddingLeft="@dimen/activity_horizontal_margin"  
    android:paddingRight="@dimen/activity_horizontal_margin"  
    android:paddingTop="@dimen/activity_vertical_margin"  
    tools:context=".DownActivity" >  
  
    <TextView  
        android:id="@+id/textView1"  
        android:layout_width="wrap_content"  
        android:layout_height="wrap_content"  
        android:layout_alignParentLeft="true"  
        android:layout_alignParentTop="true"  
        android:text="@string/tv_down" />  
  
    <EditText  
        android:id="@+id/et_path"  
        android:layout_width="wrap_content"  
        android:layout_height="wrap_content"  
        android:layout_alignParentLeft="true"  
        android:layout_alignParentRight="true"  
        android:layout_below="@+id/textView1"  
        android:ems="10"  
        android:inputType="none"  
        android:text="@string/et_path" >  
  
        <requestFocus />  
    </EditText>  
  
    <TextView  
        android:id="@+id/textView2"  
        android:layout_width="wrap_content"  
        android:layout_height="wrap_content"  
        android:layout_alignParentLeft="true"  
        android:layout_below="@+id/et_path"  
        android:text="@string/tv_threadNum" />  
  
    <EditText  
        android:id="@+id/et_threadNum"  
        android:layout_width="wrap_content"  
        android:layout_height="wrap_content"  
        android:layout_alignLeft="@+id/textView2"  
        android:layout_alignRight="@+id/et_path"  
        android:layout_below="@+id/textView2"  
        android:ems="10"  
        android:inputType="number"  
        android:text="@string/et_threadNum" />  
  
    <ProgressBar  
        android:id="@+id/pb_down"  
        style="? 
android:attr/progressBarStyleHorizontal"  
        android:layout_width="wrap_content"  
        android:layout_height="wrap_content"  
        android:layout_alignLeft="@+id/et_threadNum"  
        android:layout_alignRight="@+id/et_threadNum"  
        android:layout_below="@+id/et_threadNum"  
        android:layout_marginTop="14dp" />  
  
    <TextView  
        android:id="@+id/tv_pb"  
        android:layout_width="wrap_content"  
        android:layout_height="wrap_content"  
        android:layout_alignRight="@+id/textView1"  
        android:layout_below="@+id/pb_down"  
        android:layout_marginTop="24dp"  
        android:text="@string/tv_num" />  
  
    <Button  
        android:id="@+id/btn_down"  
        android:layout_width="wrap_content"  
        android:layout_height="wrap_content"  
        android:layout_alignLeft="@+id/pb_down"  
        android:layout_below="@+id/tv_pb"  
        android:layout_marginTop="32dp"  
        android:onClick="downLoad"  
        android:text="@string/btn_text" />  
  
    <Button  
        android:id="@+id/button1"  
        android:layout_width="wrap_content"  
        android:layout_height="wrap_content"  
        android:layout_alignLeft="@+id/btn_down"  
        android:layout_below="@+id/btn_down"  
        android:layout_marginTop="16dp"  
        android:onClick="downPause"  
        android:text="@string/btn_pause" />  
  
</RelativeLayout>  

效果例如以下：

本文转自mfrbuaa博客园博客，原文链接：http://www.cnblogs.com/mfrbuaa/p/5203446.html，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/357714

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

android：unable to instantiate activity componentinfo

这问题一般是在manifest.xml中没有配置相应的activity，或者配置的android:name 的路径不对，没写全。可是今天我在manifest中已经配置正确了activity还有这错误。原因在activity的构造方法我的activity中的构造方法中写多了参数，导致跳转时，初始activity出错，把参数去掉就可以了。　本文转自老Zhan博客园博客，原文链接：http://www.cnblogs.com/mybkn/archive/2012/05/22/2513889.html，如需转载请自行联系原作者

2017-10-17

676

Android Loader详解四：回调及完整例子

From：http://blog.csdn.net/nkmnkm/article/details/7256605 onLoadFinished 这个方法是在前面已创建的装载器已经完成其加载过程后被调用．这个方法保证会在应用到装载器上的数据被释放之前被调用．在此方法中，你必须删除所有对旧数据的使用(因为它将很快会被删除),但是不要自己去释放它们，因为它们的装载器会做这些事情．装载器一旦了解到应用不再使用数据时，将马上释放这些数据．例如，如果数据是一个从CursorLoader来的游标，你不应调用游标的close()．如果游标被放置在一个CursorAdapter中，你应使用swapCursor()方法，以使旧的游标不被关闭．例如： [java] view plain copy //这个Adapter被用于显示列表的数据． SimpleCursorAdaptermAdapter; ... publicvoidonLoadFinished(Loader<Cursor>loader,Cursordata){ //Swapthenewcursorin.(Theframewor...

2017-10-17

716

发表评论

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。