快捷導(dǎo)航

Android 使用AsyncTask實(shí)現(xiàn)斷點(diǎn)續(xù)傳

更新時(shí)間：2018年05月29日 15:20:18 作者：殘劍_

這篇文章主要介紹了Android 使用AsyncTask實(shí)現(xiàn)斷點(diǎn)續(xù)傳的實(shí)例代碼，非常不錯(cuò)，具有一定的參考借鑒價(jià)值，需要的朋友參考下吧

之前公司里面項(xiàng)目的下載模塊都是使用xUtils提供的，最近看了下xUtils的源碼，它里面也是使用AsyncTask來執(zhí)行異步任務(wù)的，它的下載也包含了斷點(diǎn)續(xù)傳的功能。這里我自己也使用AsyncTask也實(shí)現(xiàn)了簡(jiǎn)單的斷點(diǎn)續(xù)傳的功能。

　　首先說一說AsyncTask吧，先來看看AsyncTask的定義：

 public abstract class AsyncTask<Params, Progress, Result>

　　三種泛型類型分別代表“啟動(dòng)任務(wù)執(zhí)行的輸入?yún)?shù)”、“后臺(tái)任務(wù)執(zhí)行的進(jìn)度”、“后臺(tái)計(jì)算結(jié)果的類型”。在特定場(chǎng)合下，并不是所有類型都被使用，如果沒有被使用，可以用java.lang.Void類型代替。

　　一個(gè)異步任務(wù)的執(zhí)行一般包括以下幾個(gè)步驟：

　　1.execute(Params... params)，執(zhí)行一個(gè)異步任務(wù)，需要我們?cè)诖a中調(diào)用此方法，觸發(fā)異步任務(wù)的執(zhí)行。

　　2.onPreExecute()，在execute(Params... params)被調(diào)用后立即執(zhí)行，一般用來在執(zhí)行后臺(tái)任務(wù)前對(duì)UI做一些標(biāo)記。

　　3.doInBackground(Params... params)，在onPreExecute()完成后立即執(zhí)行，用于執(zhí)行較為費(fèi)時(shí)的操作，此方法將接收輸入?yún)?shù)和返回計(jì)算結(jié)果。在執(zhí)行過程中可以調(diào)用publishProgress(Progress... values)來更新進(jìn)度信息。

　　4.onProgressUpdate(Progress... values)，在調(diào)用publishProgress(Progress... values)時(shí)，此方法被執(zhí)行，直接將進(jìn)度信息更新到UI組件上。

　　5.onPostExecute(Result result)，當(dāng)后臺(tái)操作結(jié)束時(shí)，此方法將會(huì)被調(diào)用，計(jì)算結(jié)果將做為參數(shù)傳遞到此方法中，直接將結(jié)果顯示到UI組件上。

　　在使用的時(shí)候，有幾點(diǎn)需要格外注意：

　　1.異步任務(wù)的實(shí)例必須在UI線程中創(chuàng)建。

　　2.execute(Params... params)方法必須在UI線程中調(diào)用。

　　3.不要手動(dòng)調(diào)用onPreExecute()，doInBackground(Params... params)，onProgressUpdate(Progress... values)，onPostExecute(Result result)這幾個(gè)方法。

　　4.不能在doInBackground(Params... params)中更改UI組件的信息。

　　5.一個(gè)任務(wù)實(shí)例只能執(zhí)行一次，如果執(zhí)行第二次將會(huì)拋出異常。

　　下面是使用AsyncTask實(shí)現(xiàn)斷點(diǎn)續(xù)傳的代碼：

　　斷點(diǎn)續(xù)傳的思路其實(shí)也挺簡(jiǎn)單，首先判斷待下載的文件在本地是否存在，如果存在，則表示該文件已經(jīng)下載過一部分了，只需要獲取文件當(dāng)前大小即已下載大小，設(shè)置給http的header就行了：

 Header header_size = new BasicHeader("Range", "bytes=" + readedSize + "-");
 request.addHeader(header_size);

　　1、布局文件代碼：

<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:paddingLeft="@dimen/activity_horizontal_margin"
  android:paddingRight="@dimen/activity_horizontal_margin"
  android:paddingTop="@dimen/activity_vertical_margin"
  android:paddingBottom="@dimen/activity_vertical_margin" tools:context=".AsyncTaskDemoActivity"
  android:orientation="vertical">
  <Button
    android:id="@+id/begin"
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:text="開始下載"/>
  <Button
    android:id="@+id/end"
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:text="暫停下載"/>
  <ProgressBar
    android:id="@+id/progressbar"
    style="?android:attr/progressBarStyleHorizontal"
    android:layout_width="fill_parent"
    android:layout_height="3dp"
    android:layout_marginTop="10dp"
    android:max="100" />
</LinearLayout>

布局比較簡(jiǎn)單，就兩個(gè)按鈕和一個(gè)進(jìn)度條控件，按鈕控制下載與暫停。

　　2、斷點(diǎn)續(xù)傳核心代碼：

package com.bbk.lling.myapplication;
import android.app.Activity;
import android.os.AsyncTask;
import android.os.Bundle;
import android.os.Environment;
import android.util.Log;
import android.view.View;
import android.widget.ProgressBar;
import android.widget.Toast;
import org.apache.http.Header;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicHeader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.RandomAccessFile;
import java.net.MalformedURLException;
public class AsyncTaskDemoActivity extends Activity {
  private ProgressBar progressBar;
  //下載路徑
  private String downloadPath = Environment.getExternalStorageDirectory() +
      File.separator + "download";
  private DownloadAsyncTask downloadTask;
  @Override
  protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_async_task_demo);
    progressBar = (ProgressBar) findViewById(R.id.progressbar);
    //開始下載
    findViewById(R.id.begin).setOnClickListener(new View.OnClickListener() {
      @Override
      public void onClick(View v) {
        /**
         * 一個(gè)AsyncTask只能被執(zhí)行一次，否則會(huì)拋異常
         * java.lang.IllegalStateException: Cannot execute task: the task is already running.
         * 如果要重新開始任務(wù)的話要重新創(chuàng)建AsyncTask對(duì)象
         */
        if(downloadTask != null && !downloadTask.isCancelled()) {
          return;
        }
        downloadTask = new DownloadAsyncTask("http://bbk-lewen.u.qiniudn.com/3d5b1a2c-4986-4e4a-a626-b504a36e600a.flv");
        downloadTask.execute();
      }
    });
    //暫停下載
    findViewById(R.id.end).setOnClickListener(new View.OnClickListener() {
      @Override
      public void onClick(View v) {
        if(downloadTask != null && downloadTask.getStatus() == AsyncTask.Status.RUNNING) {
          downloadTask.cancel(true);
        }
      }
    });
  }
  /**
   * 下載的AsyncTask
   */
  private class DownloadAsyncTask extends AsyncTask<String, Integer, Long> {
    private static final String TAG = "DownloadAsyncTask";
    private String mUrl;
    public DownloadAsyncTask(String url) {
      this.mUrl = url;
    }
    @Override
    protected Long doInBackground(String... params) {
      Log.i(TAG, "downloading");
      if(mUrl == null) {
        return null;
      }
      HttpClient client = new DefaultHttpClient();
      HttpGet request = new HttpGet(mUrl);
      HttpResponse response = null;
      InputStream is = null;
      RandomAccessFile fos = null;
      OutputStream output = null;
      try {
        //創(chuàng)建存儲(chǔ)文件夾
        File dir = new File(downloadPath);
        if(!dir.exists()) {
          dir.mkdir();
        }
        //本地文件
        File file = new File(downloadPath + File.separator + mUrl.substring(mUrl.lastIndexOf("/") + 1));
        if(!file.exists()){
          //創(chuàng)建文件輸出流
          output = new FileOutputStream(file);
          //獲取下載輸入流
          response = client.execute(request);
          is = response.getEntity().getContent();
          //寫入本地
          file.createNewFile();
          byte buffer [] = new byte[1024];
          int inputSize = -1;
          //獲取文件總大小，用于計(jì)算進(jìn)度
          long total = response.getEntity().getContentLength();
          int count = 0; //已下載大小
          while((inputSize = is.read(buffer)) != -1) {
            output.write(buffer, 0, inputSize);
            count += inputSize;
            //更新進(jìn)度
            this.publishProgress((int) ((count / (float) total) * 100));
            //一旦任務(wù)被取消則退出循環(huán)，否則一直執(zhí)行，直到結(jié)束
            if(isCancelled()) {
              output.flush();
              return null;
            }
          }
          output.flush();
        } else {
          long readedSize = file.length(); //文件大小，即已下載大小
          //設(shè)置下載的數(shù)據(jù)位置XX字節(jié)到XX字節(jié)
          Header header_size = new BasicHeader("Range", "bytes=" + readedSize + "-");
          request.addHeader(header_size);
          //執(zhí)行請(qǐng)求獲取下載輸入流
          response = client.execute(request);
          is = response.getEntity().getContent();
          //文件總大小=已下載大小+未下載大小
          long total = readedSize + response.getEntity().getContentLength();
          //創(chuàng)建文件輸出流
          fos = new RandomAccessFile(file, "rw");
          //從文件的size以后的位置開始寫入，其實(shí)也不用，直接往后寫就可以。有時(shí)候多線程下載需要用
          fos.seek(readedSize);
          //這里用RandomAccessFile和FileOutputStream都可以，只是使用FileOutputStream的時(shí)候要傳入第二哥參數(shù)true,表示從后面填充
//          output = new FileOutputStream(file, true);
          byte buffer [] = new byte[1024];
          int inputSize = -1;
          int count = (int)readedSize;
          while((inputSize = is.read(buffer)) != -1) {
            fos.write(buffer, 0, inputSize);
//            output.write(buffer, 0, inputSize);
            count += inputSize;
            this.publishProgress((int) ((count / (float) total) * 100));
            if(isCancelled()) {
//              output.flush();
              return null;
            }
          }
//          output.flush();
        }
      } catch (MalformedURLException e) {
        Log.e(TAG, e.getMessage());
      } catch (IOException e) {
        Log.e(TAG, e.getMessage());
      } finally{
        try{
          if(is != null) {
            is.close();
          }
          if(output != null) {
            output.close();
          }
          if(fos != null) {
            fos.close();
          }
        } catch(Exception e) {
          e.printStackTrace();
        }
      }
      return null;
    }
    @Override
    protected void onPreExecute() {
      Log.i(TAG, "download begin ");
      Toast.makeText(AsyncTaskDemoActivity.this, "開始下載", Toast.LENGTH_SHORT).show();
      super.onPreExecute();
    }
    @Override
    protected void onProgressUpdate(Integer... values) {
      super.onProgressUpdate(values);
      Log.i(TAG, "downloading " + values[0]);
      //更新界面進(jìn)度條
      progressBar.setProgress(values[0]);
    }
    @Override
    protected void onPostExecute(Long aLong) {
      Log.i(TAG, "download success " + aLong);
      Toast.makeText(AsyncTaskDemoActivity.this, "下載結(jié)束", Toast.LENGTH_SHORT).show();
      super.onPostExecute(aLong);
    }
  }
}

這樣簡(jiǎn)單的斷點(diǎn)續(xù)傳功能就實(shí)現(xiàn)了，這里只是單個(gè)線程的，如果涉及多個(gè)線程同時(shí)下載，那復(fù)雜很多，后面再琢磨琢磨。

源碼下載：https://github.com/liuling07/MultiTaskAndThreadDownload

總結(jié)

以上所述是小編給大家介紹的Android 使用AsyncTask實(shí)現(xiàn)斷點(diǎn)續(xù)傳，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

您可能感興趣的文章: