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

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

在隨州等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強發(fā)展的系統(tǒng)性、市場前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供網(wǎng)站建設(shè)、做網(wǎng)站網(wǎng)站設(shè)計制作按需制作網(wǎng)站,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),品牌網(wǎng)站建設(shè),成都全網(wǎng)營銷,成都外貿(mào)網(wǎng)站建設(shè)公司,隨州網(wǎng)站建設(shè)費用合理。

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

 public abstract class AsyncTask

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

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

1.execute(Params... params)，執(zhí)行一個異步任務(wù)，需要我們在代碼中調(diào)用此方法，觸發(fā)異步任務(wù)的執(zhí)行。

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

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

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

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

在使用的時候，有幾點需要格外注意：

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

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

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

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

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

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

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

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

　1、布局文件代碼：

布局比較簡單，就兩個按鈕和一個進度條控件，按鈕控制下載與暫停。

2、斷點續(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) {
        /**
         * 一個AsyncTask只能被執(zhí)行一次，否則會拋異常
         * java.lang.IllegalStateException: Cannot execute task: the task is already running.
         * 如果要重新開始任務(wù)的話要重新創(chuàng)建AsyncTask對象
         */
        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 {
    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)建存儲文件夾
        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;
          //獲取文件總大小，用于計算進度
          long total = response.getEntity().getContentLength();
          int count = 0; //已下載大小
          while((inputSize = is.read(buffer)) != -1) {
            output.write(buffer, 0, inputSize);
            count += inputSize;
            //更新進度
            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í)行請求獲取下載輸入流
          response = client.execute(request);
          is = response.getEntity().getContent();
          //文件總大小=已下載大小+未下載大小
          long total = readedSize + response.getEntity().getContentLength();
          //創(chuàng)建文件輸出流
          fos = new RandomAccessFile(file, "rw");
          //從文件的size以后的位置開始寫入，其實也不用，直接往后寫就可以。有時候多線程下載需要用
          fos.seek(readedSize);
          //這里用RandomAccessFile和FileOutputStream都可以，只是使用FileOutputStream的時候要傳入第二哥參數(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]);
      //更新界面進度條
      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);
    }
  }
}

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

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

總結(jié)

以上所述是小編給大家介紹的Android 使用AsyncTask實現(xiàn)斷點續(xù)傳，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復(fù)大家的。在此也非常感謝大家對創(chuàng)新互聯(lián)網(wǎng)站的支持！

分享題目：Android使用AsyncTask實現(xiàn)斷點續(xù)傳
鏈接地址：http://weahome.cn/article/iegjed.html

真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

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

其他資訊

網(wǎng)站制作

企業(yè)服務(wù)

網(wǎng)站建設(shè)

服務(wù)器托管