Android 断点续传功能的实现

目录

实现效果

按照惯例，效果奉上


Kapture 2018-12-01 at 16.44.09.gif

前言

日更啊！日更！，上一篇比较划水的给大家分享了一下，在做这个功能时候的一点Java基础，IO流，在这个过程中顺便再讲一下另一个IO流中的RandomAccessFile类，那么今天分享一下。

  1. OKHttp依赖：使用的是OKhttp来连接网络
  2. RandomAccessFile 来进行IO的读写
  3. BroadcastReceiver：用来接受和更新UI的

正文

OKManger

OKManger类中实现了 网络连接方法，下载文件方法，启用线程方法；

public class OkManager {
    private File rootFile;//文件的路径
    private File file;//文件
    private long downLoadSize;//下载文件的长度
    private final ThreadPoolExecutor executor;// 线程池
    private boolean isDown = false; //是否已经下载过了（下载后点击暂停） 默认为false
    private String name; //名称
    private String path;// 下载的网址
    private RandomAccessFile raf; // 读取写入IO方法
    private long totalSize = 0;
    private MyThread thread;//线程
    private Handler handler;//Handler 方法
    private DownLoad.IProgress progress;// 下载进度方法，内部定义的抽象方法


    /**
     * 构造方法  OKhttp
     * @param path  网络连接路径
     * @param progress  更新路径
     */
    public OkManager(String path, DownLoad.IProgress progress) {
        this.path = path;
        this.progress = progress;
        this.handler = new Handler();
        this.name = path.substring(path.lastIndexOf("/") + 1);
        rootFile = FileUtils.getRootFile();
        executor = new ThreadPoolExecutor(5, 5, 50, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(3000));
        //executor.execute(new MyThread());
          }

    /**
     *  自定义线程
     */
    class MyThread extends Thread {
        @Override
        public void run() {
            super.run();
            downLoadFile();
        }

    }

    /**
     * 这就是下载方法
     */
    private void downLoadFile() {
        try {
            if (file == null) {//判断是否拥有相应的文件
                file = new File(rootFile, name); //很正常的File() 方法
                raf = new RandomAccessFile(file, "rwd");//实例化一下我们的RandomAccessFile()方法
            } else {
                downLoadSize = file.length();// 文件的大小
                if (raf == null) {//判断读取是否为空
                    raf = new RandomAccessFile(file, "rwd");
                }
                raf.seek(downLoadSize);
            }
            totalSize = getContentLength(path);//获取文件的大小
            if (downLoadSize == totalSize) {// 判断是否下载完成
                //已经下载完成
                return;
            }

            OkHttpClient client = new OkHttpClient();
            Request request = new Request.Builder().url(path).
                    addHeader("Range", "bytes=" + downLoadSize + "-" + totalSize).build();
            Response response = client.newCall(request).execute();
            InputStream ins = response.body().byteStream();
            //上面的就是简单的OKHttp连接网络，通过输入流进行写入到本地
            int len = 0;
            byte[] by = new byte[1024];
            long endTime = System.currentTimeMillis();
            while ((len = ins.read(by)) != -1 && isDown) {//如果下载没有出错并且已经开始下载，循环进行以下方法
                raf.write(by, 0, len);
                downLoadSize += len;
                if (System.currentTimeMillis() - endTime > 1000) {
                    final double dd = downLoadSize / (totalSize * 1.0);
                    DecimalFormat format = new DecimalFormat("#0.00");
                    String value = format.format((dd * 100)) + "%";//计算百分比
                    Log.i("tag", "==================" + value);
                    handler.post(new Runnable() {//通过Handler发送消息到UI线程，更新
                        @Override
                        public void run() {
                            progress.onProgress((int) (dd * 100));
                        }
                    });
                }
            }
            response.close();//最后要把response关闭
        } catch (Exception e) {
            e.getMessage();
        }

    }

    /**
     * 线程开启方法
     */
    public void start() {
        if (thread == null) {
            thread = new MyThread();
            isDown = true;
            executor.execute(thread);
        }
    }

    /**
     * 线程停止方法
     */
    public void stop() {
        if (thread != null) {
            isDown = false;
            executor.remove(thread);
            thread = null;
        }
    }

    //通过OkhttpClient获取文件的大小
    public long getContentLength(String url) throws IOException {
        OkHttpClient client = new OkHttpClient();
        Request request = new Request.Builder().url(url).build();
        Response response = client.newCall(request).execute();
        long length = response.body().contentLength();
        response.close();
        return length;
    }

    public interface IProgress {
        void onProgress(int progress);
    }

}

以上的方法，大家仔细的看一看，这里面有详细的注释，大家主要关注downLoadFile()方法，

FileUtils
public class FileUtils {
    //判断是否安装SDCard
    public static boolean isSdOk(){
        if (Environment.getExternalStorageState().equals(Environment.MEDIA_MOUNTED)){
            return true;
        }
        return false;
    }
    //创建一个文件夹，用来存放下载的文件
    public static File getRootFile(){
        File sd = Environment.getExternalStorageDirectory();
        File rootFile = new File(sd,"TEMPFILE");
        if (!rootFile.exists()){
            rootFile.mkdirs();
        }
        return rootFile;
    }
}

这个就是文件写入的路径，封装的方法，第一个就是判断是否安装SDCard ，第二个方法创建文件夹，存放下载的文件；

activity_main.xml

布局文件，视图，用了两个按钮和progressBar

<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    tools:context="us.mifeng.downloader.MainActivity">
    <ProgressBar
        android:layout_margin="10dp"
        android:layout_marginTop="20dp"
        android:id="@+id/progress"
        android:layout_width="match_parent"
        android:layout_height="5dp"
        style="@android:style/Widget.ProgressBar.Horizontal"/>
    <LinearLayout
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:layout_below="@id/progress"
        android:orientation="horizontal">

        <Button
            android:id="@+id/start"
            android:layout_width="wrap_content"
            android:layout_height="wrap_content"
            android:text="开始" />
        <Button
            android:id="@+id/stop"
            android:layout_width="wrap_content"
            android:layout_height="wrap_content"
            android:text="停止"/>
    </LinearLayout>

</RelativeLayout>
主方法 Mainactivity()
public class MainActivity extends AppCompatActivity implements View.OnClickListener, DownLoad.IProgress {
    private String path = "https://download.alicdn.com/wireless/taobao4android/latest/702757.apk";
    //private DownLoad downLoad;
    private ProgressBar pBar;
    private OkManager downLoad;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        //downLoad = new DownLoad(path,this);
        downLoad = new OkManager(path,this);
        initView();
    }

    private void initView() {
        Button start = (Button) findViewById(R.id.start);
        Button stop = (Button) findViewById(R.id.stop);
        pBar = (ProgressBar) findViewById(R.id.progress);
        pBar.setMax(100);
        start.setOnClickListener(this);
        stop.setOnClickListener(this);
    }
    @Override
    public void onClick(View v) {
        switch (v.getId()){
            case R.id.start:
                downLoad.start();
                break;
            case R.id.stop:
                downLoad.stop();
                break;
        }
    }
    //显示进度条
    @Override
    public void onProgress(int progress) {
        pBar.setProgress(progress);
    }
}

很简单就是调用了之前封装的方法，大家好好地看响应的方法就可以了

总结

  1. 断点续传的关键是断点，所以在制定传输协议的时候要设计好，如上图，我自定义了一个交互协议，每次下载请求都会带上下载的起始点，这样就可以支持从断点下载了， 其实HTTP里的断点续传也是这个原理，在HTTP的头里有个可选的字段RANGE，表示下载的范围。
  2. Range : 用于客户端到服务器端的请求，可通过该字段指定下载文件的某一段大小，及其单位。典型的格式如：
    Range: bytes=0-499 下载第0-499字节范围的内容
    Range: bytes=500-999 下载第500-999字节范围的内容
    Range: bytes=-500 下载最后500字节的内容
    Range: bytes=500- 下载从第500字节开始到文件结束部分的内容

感谢

这个代码其实是我在Github上面找到的响应的方法，比较简单，所以可以更好的放入项目中，希望大家多去大神github上面star

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 199,830评论 5赞 468
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 83,992评论 2赞 376
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 146,875评论 0赞 331
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 53,837评论 1赞 271
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 62,734评论 5赞 360
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,091评论 1赞 277
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,550评论 3赞 390
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,217评论 0赞 254
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,368评论 1赞 294
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,298评论 2赞 317
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,350评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,027评论 3赞 315
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,623评论 3赞 303
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,706评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,940评论 1赞 255
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 42,349评论 2赞 346
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 41,936评论 2赞 341