用AsyncTask实现断点续传

       在学习四大组件之一的service时，正好可以利用asyncTask 和OKhttp来进行断点续传，并在手机的前台显示下载进度。

成都创新互联公司主营福建网站建设的网络公司,主营网站建设方案,app软件定制开发,福建h5重庆小程序开发搭建,福建网站营销推广欢迎福建等地区企业咨询

    尝试下载的是Oracle官网上的jdk1.7

    在AS中使用OKhttp，只需要简单的在app/build.gradle里加入一句就可以了，如下代码，就最后一行加入即可

dependencies {
    compile fileTree(dir: 'libs', include: ['*.jar'])
    androidTestCompile('com.android.support.test.espresso:espresso-core:2.2.2', {
        exclude group: 'com.android.support', module: 'support-annotations'
    })
    compile 'com.android.support:appcompat-v7:25.3.1'
    compile 'com.android.support.constraint:constraint-layout:1.0.2'
    testCompile 'junit:junit:4.12'
    compile 'com.squareup.okhttp3:okhttp:3.8.1'
}

1、DownloadTask.java

    在该类里主要进行了文件是否存在，存在的话是否已经下载完成等判断，还有利用OKhttp进行文件下载，最经典是是在文件写入RandomAccessFile里时，判断的当前状态，如果是isPaused是true,表示点了暂停键，那么就要暂停下载等等判断；还有使用asyncTask的方法，传递进度给前置通知显示下载进度。

package com.yuanlp.servicebestproject;

import android.os.AsyncTask;
import android.os.Environment;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

/**
 * Created by 原立鹏 on 2017/7/1.
 */

public class DownloadTask extends AsyncTask {
    private static final String TAG = "DownloadTask";

    public static final int TYPE_SUCCESS=0;
    public static final int TYPE_FAILED=1;
    public static final int TYPE_PAUSED=2;
    public static final int TYPE_CANCELD=3;

    private DownLoadListener listener;

    private boolean isCanceld=false;
    private boolean isPaused=false;
    private int lastProgress;

    public DownloadTask(DownLoadListener downloadListener){
        this.listener=downloadListener;
    }
    @Override
    protected Integer doInBackground(String... params) {
        InputStream is=null;
        RandomAccessFile savedFile=null;  //RandomAccessFile 用来访问指定的文件的
        File file=null;
        try{
            long downloadLength=0;  //记录已经下载的文件中长度
            String downloadUrl=params[0];
            String fileName=downloadUrl.substring(downloadUrl.lastIndexOf("/")); //获取文件名
            String directory= Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS).getPath(); //获取文件保存路径
            file=new File(directory+fileName);  //创建文件

            //如果文件存在
            if (file.exists()){
                downloadLength=file.length();  //获取已经存在的文件大小
            }
            long contentLength=getContentLength(downloadUrl);  //获取文件总大小
            if (contentLength==0){
                return TYPE_FAILED;  //已下载的文件异常，返回失败
            }else if (downloadLength==contentLength){
                return TYPE_SUCCESS;  //说明下载的文件和总长度一样，返回成功
            }
            OkHttpClient client=new OkHttpClient();
            Request request=new Request.Builder()
                    .header("RANGE","bytes="+downloadLength+"-")  //从下载之后的地方开始
                    .url(downloadUrl)
                    .build();
            Response response=client.newCall(request).execute();
            if (response!=null){
                is=response.body().byteStream();  //获取response中的输入流
                savedFile=new RandomAccessFile(file,"rw");  //开始访问指定的文件
                savedFile.seek(downloadLength);  //跳过已经下载的文件长度
                byte[] b=new byte[1024];
                long total=0;
                int len;
                while ((len=is.read(b))!=-1){   //这个时候说明还没有读取到输入流的最后
                    if (isCanceld){  //说明取消了下载
                        return TYPE_FAILED;
                    }else if (isPaused){
                        return TYPE_PAUSED;
                    }else{
                        total+=len;
                        savedFile.write(b,0,len);
                        int progress= (int) ((total+downloadLength)*100/contentLength);  //计算下载的百分比
                        publishProgress(progress);  //调用onProgressUpdate()更新下载进度
                    }
                }
                response.body().close();  //关闭reponse
                return TYPE_SUCCESS;  //返回下载成功
            }

        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try{
                if (is!=null){
                    is.close();  //关闭输入流
                }
                if (savedFile!=null){
                    savedFile.close();  //关闭查看文件
                }
                if (isCanceld&&file!=null){
                    file.delete();  //如果点击取消下载并且已经下载的文件存在，就删除文件
                }
            }catch(Exception e){
                e.printStackTrace();
            }
        }
        return TYPE_FAILED;
    }


    /**
     * 在doInBackground 里调用ublishProgress时调用此方法，更新UI进度
     * @param values
     */
    public void onProgressUpdate(Integer... values){
        int progress=values[0];  //获取传过来的百分比值
        if (progress>lastProgress){
            listener.onProgress(progress);
        }

    }

    /**
     * 当doInBackground 执行完成时，调用此方法
     * @param status
     */
    public void onPostExecute(Integer status){

        switch (status){
            case TYPE_SUCCESS:
                listener.onSuccess();
                break;
            case TYPE_FAILED:
                listener.onFailed();
                break;
            case TYPE_PAUSED:
                listener.onPause();
                break;
            case TYPE_CANCELD:
                listener.onCancled();
                break;
            default:
                break;
        }
    }

    /**
     * 按下暂停键时调用,暂停下载
     */
    public void pausedDownload(){
        isPaused=true;

    }

    public void canceledDownload(){

        isCanceld=true;
    }


    /**
     * 根据传入的rul地址，获取文件总长度
     * @param url
     * @return
     */
    public long getContentLength(String url) throws IOException {
        OkHttpClient client=new OkHttpClient();
        Request request=new Request.Builder()
                .url(url)
                .build();
        Response reponse=client.newCall(request).execute();
        if (reponse!=null&&reponse.isSuccessful()){  //成功返回reponse
            long contentLength=reponse.body().contentLength();  //获取文件中长度
            return contentLength;

        }
            return 0;
    }
}

2、DownloadService.java

    在这个里面，主要是根据Mainactivity里的指令，进行调用downloadTask类里的方法，以及调用前置通知，显示进度。

package com.yuanlp.servicebestproject;

import android.app.Notification;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.app.Service;
import android.content.Intent;
import android.graphics.BitmapFactory;
import android.os.Binder;
import android.os.Environment;
import android.os.IBinder;
import android.support.v4.app.NotificationCompat;
import android.widget.Toast;

import java.io.File;

public class DownloadService extends Service {
    private static final String TAG = "DownloadService";
    private DownloadTask downloadTask;
    private String downloadUrl;

    public DownloadService() {
    }

    @Override
    public IBinder onBind(Intent intent) {
        return mBinder;
    }

    private DownLoadListener listener=new DownLoadListener() {
        @Override
        public void onProgress(int progress) {
           getNotifactionManager().notify(1,getNotification("Downloading....",progress));
        }

        @Override
        public void onSuccess() {
            downloadTask=null;
            //下载成功后，将前台通知关闭，并创建一个下载成功的通告
            stopForeground(true);

            getNotifactionManager().notify(1,getNotification("Download Success",-1));
            Toast.makeText(DownloadService.this,"Download Success",Toast.LENGTH_SHORT).show();
        }

        @Override
        public void onFailed() {
            downloadTask=null;
            stopForeground(true);
            getNotifactionManager().notify(1,getNotification("Down Failed",-1));
            Toast.makeText(DownloadService.this,"Down Failed",Toast.LENGTH_SHORT).show();

        }

        @Override
        public void onPause() {
            downloadTask=null;
            Toast.makeText(DownloadService.this,"Paused",Toast.LENGTH_SHORT).show();

        }

        @Override
        public void onCancled() {
            downloadTask=null;
            Toast.makeText(DownloadService.this,"Canceled",Toast.LENGTH_SHORT).show();

        }
    };

    private DownloadBinder mBinder=new DownloadBinder();
    class DownloadBinder extends Binder{
        public void startDownload(String url){
            if (downloadTask==null){
                downloadUrl=url;
                downloadTask=new DownloadTask(listener);
                Toast.makeText(DownloadService.this, "Downloading....", Toast.LENGTH_SHORT).show();
                downloadTask.execute(downloadUrl);
                startForeground(1,getNotification("Downloading...",0));

            }
        }

        public void  pauseDownload(){
            if (downloadTask==null){
                downloadTask.pausedDownload();
            }
        }

        public void cancelDownload(){
            if (downloadTask==null){
                downloadTask.canceledDownload();
            }else{
                if (downloadUrl!=null){
                    String filename=downloadUrl.substring(downloadUrl.lastIndexOf("/"));
                    String directory= Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS).getPath();
                    File file=new File(directory);
                    if (file.exists()){
                        file.delete();
                    }
                    getNotifactionManager().cancel(1);
                    stopForeground(true);
                    Toast.makeText(DownloadService.this,"Canceled",Toast.LENGTH_SHORT).show();
                }
            }

        }
    }

    private NotificationManager getNotifactionManager(){
        return (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
    }

    private Notification getNotification(String title,int progress){
        Intent intent =new Intent(this,MainActivity.class);
        PendingIntent pi=PendingIntent.getActivity(this,0,intent,0);
        NotificationCompat.Builder builder=new NotificationCompat.Builder(this);
        builder.setSmallIcon(R.mipmap.ic_launcher);
        builder.setLargeIcon(BitmapFactory.decodeResource(getResources(),R.mipmap.ic_launcher));
        builder.setContentIntent(pi);
        builder.setContentTitle(title);

        if (progress>=0){
            builder.setContentText(progress+"%");
            builder.setProgress(100,progress,false);
        }
        return builder.build();
    }


}

3、MainActivity.java

    主要是进行了开启服务和绑定服务，对应按钮的操作，以及运行时权限申请。

package com.yuanlp.servicebestproject;

import android.Manifest;
import android.content.ComponentName;
import android.content.Intent;
import android.content.ServiceConnection;
import android.content.pm.PackageManager;
import android.os.Bundle;
import android.os.IBinder;
import android.support.v4.app.ActivityCompat;
import android.support.v4.content.ContextCompat;
import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.Toast;

public class MainActivity extends AppCompatActivity {
    private static final String TAG = "MainActivity";

    private DownloadService.DownloadBinder mDownloadBinder;
    @Override
    protected void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        Intent intent=new Intent(this,DownloadService.class);
        startService(intent);
        bindService(intent,conn,BIND_AUTO_CREATE);

        if (ContextCompat.checkSelfPermission(MainActivity.this, Manifest.permission.WRITE_EXTERNAL_STORAGE)!= PackageManager.PERMISSION_GRANTED);

        ActivityCompat.requestPermissions(MainActivity.this,new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE},1);
    }
    private ServiceConnection conn=new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            mDownloadBinder= (DownloadService.DownloadBinder) service;
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {

        }
    };

    /**
     * 点击开始下载
     * @paam view
     */
    public void startService(View view){
        Toast.makeText(this,"点击下载",Toast.LENGTH_SHORT).show();
        if (mDownloadBinder==null){
            return;
        }
        String url="http://download.java.net/java/jdk9/archive/176/binaries/jdk-9+176_windows-x86_bin.exe";
        mDownloadBinder.startDownload(url);
    }

    public void pauseService(View view){
        if (mDownloadBinder==null){
            return;
        }
        mDownloadBinder.pauseDownload();
    }

    public void cancelSerivce(View view){
        if (mDownloadBinder==null){
            return;
        }
        mDownloadBinder.cancelDownload();
    }

    public void onRequestPermissiosResult(int requestCode,String[] permissions,int[] grantResult){
        switch (requestCode){
            case 1:
                if (grantResult.length>0&&grantResult[0]!=PackageManager.PERMISSION_GRANTED){
                    Toast.makeText(this,"拒绝授权将无法使用程序",Toast.LENGTH_SHORT).show();
                    finish();
                }
                break;
            default:
        }
    }

    public void onDestroy(){
        super.onDestroy();
        unbindService(conn);
    }
}

网站标题：用AsyncTask实现断点续传
转载注明：http://mswzjz.cn/article/pijgpd.html