Android的断点续传的下载在线文件示例

Android的断点续传的下载在线文件示例

文件的结构如下:

activity_main.xml:
<LinearLayout 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:orientation="vertical"
    tools:context=".MainActivity" >

    <EditText
        android:id="@+id/et_path"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:text="http://192.168.159.1:8080/gh.zip"
        android:hint="请输入下载路径"
        tools:ignore="HardcodedText" />

    <EditText
        android:id="@+id/et_threadCount"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:hint="请输入线程的数量" />

    <Button
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:onClick="click"
        android:text="下载" />

    <LinearLayout
        android:id="@+id/ll_pb"
        android:layout_width="match_parent"
        android:layout_height="match_parent"
        android:orientation="vertical" >
    </LinearLayout>

</LinearLayout>
item.xml:
<?xml version="1.0" encoding="utf-8"?>
<ProgressBar xmlns:android="http://schemas.android.com/apk/res/android"
    android:id="@+id/progressBar1"
    style="?android:attr/progressBarStyleHorizontal"
    android:layout_width="match_parent"
    android:layout_height="wrap_content" />
network_security_config.xml:
<?xml version="1.0" encoding="utf-8"?>
<network-security-config>
    <base-config cleartextTrafficPermitted="true" />
</network-security-config>
AndroidManifest.xml:
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="com.example.administrator.fdtest">

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

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

    <application
        android:usesCleartextTraffic="true"
        android:networkSecurityConfig="@xml/network_security_config"
        android:allowBackup="true"
        android:icon="@mipmap/ic_launcher"
        android:label="@string/app_name"
        android:roundIcon="@mipmap/ic_launcher_round"
        android:supportsRtl="true"
        android:theme="@style/AppTheme">
        <activity android:name=".MainActivity">
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>
    </application>

</manifest>
MainActivity:
package com.example.administrator.fdtest;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.List;

import android.Manifest;
import android.content.pm.PackageManager;
import android.os.Bundle;
import android.os.Environment;
import android.app.Activity;
import android.support.v4.app.ActivityCompat;
import android.view.Menu;
import android.view.View;
import android.widget.EditText;
import android.widget.LinearLayout;
import android.widget.ProgressBar;

public class MainActivity extends Activity {

    private EditText et_path;
    private EditText et_threadCount;
    private LinearLayout ll_pb_layout;
    private String path;
    private static int runningThread;  //代表当前正在运行的线程
    private int threadCount;
    private List<ProgressBar> pbLists; //用来存进度条的引用

    private  final int REQUEST_EXTERNAL_STORAGE = 1;
    private  String[] PERMISSIONS_STORAGE = {
            Manifest.permission.READ_EXTERNAL_STORAGE,
            Manifest.permission.WRITE_EXTERNAL_STORAGE };
    public  void verifyStoragePermissions(Activity activity) {
        // Check if we have write permission
        int permission = ActivityCompat.checkSelfPermission(activity,
                Manifest.permission.WRITE_EXTERNAL_STORAGE);
        if (permission != PackageManager.PERMISSION_GRANTED) {
            // We don't have permission so prompt the user
            ActivityCompat.requestPermissions(activity, PERMISSIONS_STORAGE,
                    REQUEST_EXTERNAL_STORAGE);
        }
    }

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        verifyStoragePermissions(this);
        // [1]找到我们关心的控件

        et_path = (EditText) findViewById(R.id.et_path);
        et_threadCount = (EditText) findViewById(R.id.et_threadCount);
        ll_pb_layout = (LinearLayout) findViewById(R.id.ll_pb);

        //[2]添加一个集合 用来存进度条的引用
        pbLists = new ArrayList<ProgressBar>();

    }

    //点击按钮实现下载的逻辑
    public void click(View v){

        //[2]获取下载的路径

//        path = et_path.getText().toString().trim();
        path = "http://192.168.159.1:8080/gh.zip";

        //[3]获取线程的数量
        String threadCountt  = et_threadCount.getText().toString().trim();
        //[3.0]先移除进度条 在添加
        ll_pb_layout.removeAllViews();

        threadCount = Integer.parseInt(threadCountt);
        pbLists.clear();
        for (int i = 0; i < threadCount; i++) {

            //[3.1]把我定义的item布局转换成一个view对象
            ProgressBar pbView = (ProgressBar) View.inflate(getApplicationContext(), R.layout.item, null);

            //[3.2]把pbView 添加到集合中
            pbLists.add(pbView);

            //[4]动态的添加进度条
            ll_pb_layout.addView(pbView);

        }

        //[5]开始移植   联网 获取文件长度
        new Thread(){public void run() {

            //[一 ☆☆☆☆]获取服务器文件的大小   要计算每个线程下载的开始位置和结束位置

            try {

                //(1) 创建一个url对象 参数就是网址
                URL url = new URL(path);
                //(2)获取HttpURLConnection 链接对象
                HttpURLConnection conn = (HttpURLConnection) url.openConnection();
                //(3)设置参数  发送get请求
                conn.setRequestMethod("GET"); //默认请求 就是get  要大写
                //(4)设置链接网络的超时时间
                conn.setConnectTimeout(5000);
                //(5)获取服务器返回的状态码
                int code = conn.getResponseCode(); //200  代表获取服务器资源全部成功  206请求部分资源
                if (code == 200) {

                    //(6)获取服务器文件的大小
                    int length = conn.getContentLength();

                    //[6.1]把线程的数量赋值给正在运行的线程
                    runningThread = threadCount;

                    System.out.println("length:"+length);

                    //[二☆☆☆☆ ] 创建一个大小和服务器一模一样的文件 目的提前把空间申请出来
                    RandomAccessFile rafAccessFile = new RandomAccessFile(getFilename(path), "rw");
                    rafAccessFile.setLength(length);

                    //(7)算出每个线程下载的大小
                    int blockSize = length /threadCount;

                    //[三☆☆☆☆  计算每个线程下载的开始位置和结束位置 ]
                    for (int i = 0; i < threadCount; i++) {
                        int startIndex = i * blockSize;   //每个线程下载的开始位置
                        int endIndex = (i+1)*blockSize - 1;
                        //特殊情况 就是最后一个线程
                        if (i == threadCount - 1) {
                            //说明是最后一个线程
                            endIndex = length - 1;

                        }

                        System.out.println("线程id:::"+i + "理论下载的位置"+":"+startIndex+"-----"+endIndex);

                        //四 开启线程去服务器下载文件
                        DownLoadThread downLoadThread = new DownLoadThread(startIndex, endIndex, i);
                        downLoadThread.start();

                    }

                }

            } catch (Exception e) {
                e.printStackTrace();
            }

        };}.start();
    }

    //定义线程去服务器下载文件
    private  class DownLoadThread extends Thread{
        //通过构造方法把每个线程下载的开始位置和结束位置传递进来

        private int startIndex;
        private int endIndex;
        private int threadId;

        private int PbMaxSize; //代表当前线程下载的最大值
        //如果中断过  获取上次下载的位置
        private int pblastPostion;

        public DownLoadThread(int startIndex,int endIndex,int threadId){
            this.startIndex = startIndex;
            this.endIndex  = endIndex;
            this.threadId = threadId;
        }

        @Override
        public void run() {
            //四  实现去服务器下载文件的逻辑

            try {
                //(0)计算当前进度条的最大值
                PbMaxSize = endIndex - startIndex;
                //(1) 创建一个url对象 参数就是网址
                URL url = new URL(path);
                //(2)获取HttpURLConnection 链接对象
                HttpURLConnection conn = (HttpURLConnection) url
                        .openConnection();
                //(3)设置参数  发送get请求
                conn.setRequestMethod("GET"); //默认请求 就是get  要大写
                //(4)设置链接网络的超时时间
                conn.setConnectTimeout(5000);

                //[4.0]如果中间断过  继续上次的位置 继续下载   从文件中读取上次下载的位置

                File file =new File(getFilename(path)+threadId+".txt");
                if (file.exists() && file.length()>0) {
                    FileInputStream fis = new  FileInputStream(file);
                    BufferedReader bufr = new  BufferedReader(new InputStreamReader(fis));
                    String lastPositionn = bufr.readLine();  //读取出来的内容就是上一次下载的位置
                    int lastPosition = Integer.parseInt(lastPositionn);

                    //[4.0]给我们定义的进度条条位置 赋值
                    pblastPostion = lastPosition - startIndex;

                    //[4.0.1]要改变一下 startIndex 位置
                    startIndex = lastPosition + 1;

                    System.out.println("线程id::"+threadId + "真实下载的位置"+":"+startIndex+"-----"+endIndex);

                    fis.close(); //关闭流
                }

                //[4.1]设置一个请求头Range (作用告诉服务器每个线程下载的开始位置和结束位置)
                conn.setRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);

                //(5)获取服务器返回的状态码
                int code = conn.getResponseCode(); //200  代表获取服务器资源全部成功  206请求部分资源 成功
                if (code == 206) {
                    //[6]创建随机读写文件对象
                    RandomAccessFile raf = new RandomAccessFile(getFilename(path), "rw");
                    //[6]每个线程要从自己的位置开始写
                    raf.seek(startIndex);

                    InputStream in = conn.getInputStream(); //存的是feiq.exe

                    //[7]把数据写到文件中
                    int len = -1;
                    byte[] buffer = new byte[1024*1024];//1Mb

                    int total = 0; //代表当前线程下载的大小

                    while((len = in.read(buffer))!=-1){
                        raf.write(buffer, 0, len);

                        total +=len;
                        //[8]实现断点续传 就是把当前线程下载的位置 给存起来 下次再下载的时候 就是按照上次下载的位置继续下载 就可以了
                        int currentThreadPosition =  startIndex + total;  //比如就存到一个普通的.txt文本中

                        //[9]用来存当前线程下载的位置
                        RandomAccessFile raff = new RandomAccessFile(getFilename(path)+threadId+".txt", "rwd");
                        raff.write(String.valueOf(currentThreadPosition).getBytes());
                        raff.close();

                        //[10]设置一下当前进度条的最大值 和 当前进度
                        pbLists.get(threadId).setMax(PbMaxSize);//设置进度条的最大值
                        pbLists.get(threadId).setProgress(pblastPostion+total);//设置当前进度条的当前进度
                    }
                    raf.close();//关闭流  释放资源

                    System.out.println("线程id:"+threadId + "---下载完毕了");

                    //[10]把.txt文件删除  每个线程具体什么时候下载完毕了 我们不知道

                    synchronized (DownLoadThread.class) {
                        runningThread--;
                        if (runningThread == 0) {
                            //说明所有的线程都执行完毕了 就把.txt文件删除
                            for (int i = 0; i < threadCount; i++) {
                                File  delteFile = new File(getFilename(path)+i+".txt");
                                delteFile.delete();
                            }
                        }
                    }
                }

            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    //获取文件的名字    "http://192.168.11.73:8080/feiq.exe";
    public  String getFilename(String path){

        int start =  path.lastIndexOf("/")+1;
        String substring = path.substring(start);

        String fileName = Environment.getExternalStorageDirectory().getPath()+"/"+substring;
        return fileName;
    }
}

原文地址:https://www.cnblogs.com/charlypage/p/10204691.html

时间: 12-31

Android的断点续传的下载在线文件示例的相关文章

Android 多线程断点续传同时下载多个大文件

最近学习在Android环境中一些网络请求方面的知识,其中有一部分是关于网络下载方面的知识.在这里解析一下自己写的demo,总结一下自己所学的知识.下图为demo的效果图,仿照一些应用下载商城在ListView中列出加载项,然后可以可以下载和停止. 1.概述 这里有几个比较重要的类DownloadManager.DownloadService.DownloadTask.ThreadDAOImpl.主要的下载流程如下. (1) DownloadManager 负责下载任务的调配,以及下载服务Dow

Android多线程断点续传下载

这个月接到一个项目,要写一个像360助手一样的对于软件管理的APP:其中,遇到了一个问题:多线程断点下载 这个 ,由于之前没有写过这方面的应用功能.所以,不免要自学了.然后就在各个昂站上收索并整理了一下.跟大家分享一下,也能加深我在这方面的理解. 什么是多线程下载? 多线程下载其实就是迅雷,BT一些下载原理,通过多个线程同时和服务器连接,那么你就可以榨取到较高的带宽了,大致做法是将文件切割成N块,每块交给单独一个线程去下载,各自下载完成后将文件块组合成一个文件,程序上要完成做切割和组装的小算法

在ASP.NET中支持断点续传下载大文件(ZT)

IE的自带下载功能中没有断点续传功能,要实现断点续传功能,需要用到HTTP协议中鲜为人知的几个响应头和请求头. 一. 两个必要响应头Accept-Ranges.ETag         客户端每次提交下载请求时,服务端都要添加这两个响应头,以保证客户端和服务端将此下载识别为可以断点续传的下载: Accept-Ranges:告知下载客户端这是一个可以恢复续传的下载,存放本次下载的开始字节位置.文件的字节大小: ETag:保存文件的唯一标识(我在用的文件名+文件最后修改时间,以便续传请求时对文件进行

android 播放语音文件出现 prepare failed ,不能下载amr文件

amr文件的路径正确,但是android 却不能播放出来. 调试发现时根本就没有下载下来 原因: IIS服务器不允许下载该文件,需要配置MIME 解决方法: 进入IIS目录,配置MIME

Android集成支付宝接口 实现在线支付

手机的在线支付,被认为是2012年最看好的功能,我个人认为这也是移动互联网较传统互联网将会大放光彩的一个功能. 人人有手机,人人携带手机,花钱买东西,不再需要取钱付现,不再需要回家上网银,想买什么,扫描一下,或者搜索一下,然后下单,不找零,直接送到你家,这将是手机支付给我们带来的全新交易体验.谷歌刚推出了谷歌钱包,这必是我们后面要使用的主要手段,但是鉴于当前国情,我觉得有必要介绍一下android手机集成支付宝功能. 1.下载官方架包和说明文档其实官方已经提供了安装指南,下载地址:https:/

集成Android免费语音合成功能(在线、离线、离在线融合)

集成Android免费语音合成功能(在线.离线.离在线融合),有这一篇文章就够了(离线)集成Android免费语音合成功能(在线.离线.离在线融合),有这一篇文章就够了(离在线融合) 转眼间,大半年没写文章了,没什么理由,就是人变懒了.囧~ 看标题,其实大家都被骗了,有这一篇文章还不够,我其实是打算分3篇文章来写的,如果合在一章里面就太长了,不过现在这个标题党横行的网络世界,我也被污染了,哈.那么为什么要分3篇文章来讲呢?看标题也能猜到了,就是在线.离线.离在线融合这3种语音合成方式,我将分别使

Android 解决图片大量下载:软引用必须懂4点

Android 解决图片大量下载:软引用必须懂4点 可能对于Android开发者来说,软引用这个词有的会不是很熟悉,软引用在Java开发中用的比较多,但是,在Android开发中引用软引用,会给我们解决很多难题. AD: 1.对象的强.软.弱和虚引用 为了能更加灵活控制对象的生命周期,需要知道对象引用的4中级别,由高到低依次为 :强引用.软引用.弱引用和虚引用 备注: 这四种的区别: ⑴强引用(StrongReference) 强引用是使用最普遍的引用.如果一个对象具有强引用,那垃圾回收器绝不会

Android App组件之ListFragment -- 说明和示例(转载)

转自:http://www.cnblogs.com/skywang12345/p/3160260.html 1 ListFragement介绍 ListFragment继承于Fragment.因此它具有Fragment的特性,能够作为activity中的一部分,目的也是为了使页面设计更加灵活. 相比Fragment,ListFragment的内容是以列表(list)的形式显示的. 1.1 ListFragment布局 ListFragment的布局默认包含一个list view.因此,在List

多线程断点续传及下载

断点下载 package com.example.downloaddemo; import java.io.File; import java.io.IOException; import java.net.MalformedURLException; import java.net.URL; import java.net.URLConnection; import android.os.Bundle; import android.os.Handler; import android.os.

IIS 服务器支持下载apk 文件

前不久,在本地IIS文件下部署一个网站,可以下载apk文件,就是测试apk应用升级,发现访问不能下载,原因是IIS没有配置对这种apk文件的处理程序. 解决方案如下所示: 1.打开IIS, 找到MIME选项 2.点击右边的添加在弹出的添加窗口里的文件扩展名输入:APK 在MIME类型输入:application/vnd.android.package-archive