Android使用多線程實現(xiàn)斷點下載

更新時間：2016年03月30日 17:08:15 作者：Darker

這篇文章主要介紹了Android使用多線程實現(xiàn)斷點下載，多線程下載是加快下載速度的一種方式，感興趣的小伙伴們可以參考一下

多線程下載是加快下載速度的一種方式，通過開啟多個線程去執(zhí)行一個任務(wù)..可以使任務(wù)的執(zhí)行速度變快..多線程的任務(wù)下載時常都會使用得到..比如說我們手機內(nèi)部應(yīng)用寶的下載機制..一定是通過使用了多線程創(chuàng)建的下載器..并且這個下載器可以實現(xiàn)斷點下載..在任務(wù)被強行終止之后..下次可以通過觸發(fā)按鈕來完成斷點下載...那么如何實現(xiàn)斷點下載這就是一個問題了..

首先我們需要明確一點就是多線程下載器通過使用多個線程對同一個任務(wù)進行下載..但是這個多線程并不是線程的數(shù)目越多，下載的速度就越快..當(dāng)線程增加的很多的時候,單個線程執(zhí)行效率也會變慢..因此線程的數(shù)目需要有一個限度..經(jīng)過樓主親自測試..多線程下載同一個任務(wù)時，線程的數(shù)目5-8個算是比較高效的..當(dāng)線程的數(shù)量超過10個之后，那么多線程的效率反而就變慢了(前提：網(wǎng)速大體相同的時候..)

那么在實現(xiàn)多線程下載同一個任務(wù)的時候我們需要明白其中的道理..下面先看一張附加圖..

這個圖其實就很簡單的說明了其中的原理..我們將一個任務(wù)分成多個部分..然后開啟多個線程去下載對應(yīng)的部分就可以了..那么首先要解決的問題就是如何使各自的線程去下載各自對應(yīng)的任務(wù)，不能越界..那么我們來看看具體的實現(xiàn)過程..首先我們使用普通Java代碼去實現(xiàn)..最后將Java代碼移植到Android就可以了..

public class Download {

  public static int threadCount = 5;  //線程開啟的數(shù)量..
  public static void main(String[] args) {
    // TODO Auto-generated method stub

    String path = "http://192.168.199.172:8080/jdk.exe";
    try {
      URL url = new URL(path);
      HttpURLConnection conn = (HttpURLConnection) url.openConnection();
      conn.setRequestMethod("GET");
      conn.setConnectTimeout(5000);
      int status = conn.getResponseCode();
      
      if(status == 200){
        int length = conn.getContentLength();
      
        System.out.println(length);
        
        int blocksize = length/threadCount; //將文件長度進行平分..
        
        for(int threadID=1; threadID<=threadCount;threadID++){
          
          int startIndex = (threadID-1)*blocksize; //開始位置的求法..
          int endIndex = threadID*blocksize -1;   //結(jié)束位置的求法..
           
          /**
           * 如果一個文件的長度無法整除線程數(shù)..
           * 那么最后一個線程下載的結(jié)束位置需要設(shè)置文件末尾..
           * */
          if(threadID == threadCount){        
            endIndex = length;           
          }
          
          System.out.println("線程下載位置："+startIndex+"---"+endIndex);
        }
      }
      
      
    } catch (Exception e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
  }
}

這樣只是實現(xiàn)了通過連接服務(wù)器來獲取文件的長度..然后去設(shè)置每一個線程下載的開始位置和結(jié)束位置..這里只是完成了這些步驟..有了下載的開始位置和結(jié)束位置..我們就需要開啟線程來完成下載了...因此我們需要自己定義下載的過程...

首先我們需要明確思路：既然是斷點下載..那么如果一旦發(fā)生了斷點情況..我們在下一次進行下載的時候需要從原來斷掉的位置進行下載..已經(jīng)下載過的位置我們就不需要進行下載了..因此我們需要記載每一次的下載記錄..那么有了記錄之后..一旦文件下載完成之后..這些記錄就需要被清除掉...因此明確了這兩個地方的思路就很容易書寫了..

//下載線程的定義..  
public static class DownLoadThread implements Runnable{

    private int threadID;
    private int startIndex;
    private int endIndex;
    private String path;
    
    public DownLoadThread(int threadID,int startIndex,int endIndex,String path){
      
      this.threadID = threadID;
      this.startIndex = startIndex;
      this.endIndex = endIndex;
      this.path = path;
      
    }
    
    @Override
    public void run() {
      // TODO Auto-generated method stub
      
      try {
        
        //判斷上一次是否下載完畢..如果沒有下載完畢需要繼續(xù)進行下載..這個文件記錄了上一次的下載位置..
        File tempfile =new File(threadID+".txt");
        if(tempfile.exists() && tempfile.length()>0){
          
          FileInputStream fis = new FileInputStream(tempfile);
          byte buffer[] = new byte[1024];
          int leng = fis.read(buffer);
          int downlength = Integer.parseInt(new String(buffer,0,leng));//從上次下載后的位置開始下載..重新擬定開始下載的位置..
          startIndex = downlength;
          fis.close();
        }
        
        URL url = new URL(path);
        HttpURLConnection conn =(HttpURLConnection) url.openConnection();
        conn.setRequestMethod("GET");
        conn.setConnectTimeout(5000);
        conn.setRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);
        
        int status = conn.getResponseCode();
        //206也表示服務(wù)器響應(yīng)成功..
        if(status == 206){
          
          //獲取服務(wù)器返回的I/O流..然后將數(shù)據(jù)寫入文件當(dāng)中..
          InputStream in = conn.getInputStream();
          
          //文件寫入開始..用來保存當(dāng)前需要下載的文件..
          RandomAccessFile raf = new RandomAccessFile("jdk.exe", "rwd");
          raf.seek(startIndex);
          
          
          int len = 0;
          byte buf[] =new byte[1024];
          
          //記錄已經(jīng)下載的長度..
          int total = 0;
          
          while((len = in.read(buf))!=-1){
            
            //用于記錄當(dāng)前下載的信息..
            RandomAccessFile file =new RandomAccessFile(threadID+".txt", "rwd");
            total += len;
            file.write((total+startIndex+"").getBytes());
            file.close();
            //將數(shù)據(jù)寫入文件當(dāng)中..
            raf.write(buf, 0, len);
            
          }
          in.close();
          raf.close();
          
          
        }  
        
      } catch (Exception e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }finally{
        //如果所有的線程全部下載完畢后..也就是任務(wù)完成..清除掉所有原來的記錄文件..
        runningThread -- ;
        if(runningThread==0){
          for(int i=1;i<threadCount;i++){
            File file = new File(i+".txt");
            file.delete();
          }
        }
      }
    }
  }

這樣就完成了文件的數(shù)據(jù)信息的下載..經(jīng)過測試..一個13M的文件在5個線程共同作用下下載的時間差不多是12秒左右(網(wǎng)速穩(wěn)定在300k的情況下..帶寬越寬..速度就會更快)單個線程下載的時間差不多是15秒左右..這里才縮短了兩秒鐘的時間..但是我們不要忘記..如果文件過大的話呢?因此樓主親測了一下一個90M的文件在5個線程同時作用下時間差不多1分20秒左右..而使用一個線程進行下載差不多2分鐘左右..這里還是縮短了大量的時間..

因此根據(jù)對比，還是使用多個線程來進行下載更加的好一些..雖然Android里的一般應(yīng)用不會超過50M左右..但是游戲的話一般差不多能達(dá)到100-200M左右..因此使用多線程還是能夠提高下載的進度和效率..同樣我們可以通過使用線程池的方式去開啟線程..最后這些線程交給線程池去管理就可以了..

在正常的Java項目中我們書寫好了下載代碼..就可以移植到我們的Android應(yīng)用程序當(dāng)中..但是還是有一些地方需要注意..因此在這里去強調(diào)一下..

package com.example.mutithread;

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.app.Activity;
import android.text.TextUtils;
import android.view.Menu;
import android.view.View;
import android.widget.EditText;
import android.widget.ProgressBar;
import android.widget.TextView;
import android.widget.Toast;

public class MainActivity extends Activity {

  private EditText et;
  private ProgressBar pb;
  public static int threadCount = 5;
  public static int runningThread=5;
  public int currentProgress=0; //當(dāng)前進度值..
  private TextView tv;
  
  
  private Handler handler = new Handler(){
    
    @Override
    public void handleMessage(Message msg){
      switch (msg.what) {
      case 1:
        Toast.makeText(getApplicationContext(), msg.obj.toString(), 0).show();
        break;
      case 2:
        break;
      case 3:
        tv.setText("當(dāng)前進度："+(pb.getProgress()*100)/pb.getMax());
      default:
        break;
      }
    }
  };
  @Override
  protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    et = (EditText) findViewById(R.id.et);
    pb =(ProgressBar) findViewById(R.id.pg);
    tv= (TextView) findViewById(R.id.tv);
  }

  public void downLoad(View v){
    final String path = et.getText().toString().trim();
    if(TextUtils.isEmpty(path)){
      Toast.makeText(this, "下載路徑錯誤", Toast.LENGTH_LONG).show();
      return ;
    }
    
    new Thread(){
//      String path = "http://192.168.199.172:8080/jdk.exe";
      public void run(){
        try {
          URL url = new URL(path);
          HttpURLConnection conn = (HttpURLConnection) url.openConnection();
          conn.setRequestMethod("GET");
          conn.setConnectTimeout(5000);
          int status = conn.getResponseCode();
          
          if(status == 200){
            int length = conn.getContentLength();
            System.out.println("文件總長度"+length);
            pb.setMax(length);
            
            
            RandomAccessFile raf = new RandomAccessFile("/sdcard/setup.exe","rwd");
            raf.setLength(length);
            raf.close();
            
            
            //開啟5個線程來下載當(dāng)前資源..
            int blockSize = length/threadCount ;
            
            for(int threadID=1;threadID<=threadCount;threadID++){
              
              int startIndex = (threadID-1)*blockSize;
              int endIndex = threadID*blockSize -1;
              
              if(threadID == threadCount){
                endIndex = length; 
              }
              System.out.println("線程"+threadID+"下載:---"+startIndex+"--->"+endIndex);
              new Thread(new DownLoadThread(threadID, startIndex, endIndex, path)).start() ;
            }
          }
          
          
        } catch (Exception e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        }
      };
      
    }.start();
  }
  /** 
   * 下載線程..
   * */
  public class DownLoadThread implements Runnable{

    private int ThreadID;
    private int startIndex;
    private int endIndex;
    private String path;
    
    public DownLoadThread(int ThreadID,int startIndex,int endIndex,String path){
      this.ThreadID = ThreadID;
      this.startIndex = startIndex;
      this.endIndex = endIndex;
      this.path = path;
    }
    @Override
    public void run() {
      // TODO Auto-generated method stub
      URL url;
      try {    
        //檢查是否存在還未下載完成的文件...
        File tempfile = new File("/sdcard/"+ThreadID+".txt");
        if(tempfile.exists() && tempfile.length()>0){
          FileInputStream fis = new FileInputStream(tempfile);
          byte temp[] =new byte[1024];
          int leng = fis.read(temp);
          int downlength = Integer.parseInt(new String(temp,0,leng));
          
          int alreadydown = downlength -startIndex;
          
          currentProgress += alreadydown;//發(fā)生斷點之后記錄下載的文件長度..
          
          startIndex = downlength;
          fis.close();
        }
        
        
        url = new URL(path);
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        conn.setRequestMethod("GET");
        conn.setRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);
        conn.setConnectTimeout(5000);
        
        //獲取響應(yīng)碼..
        int status =conn.getResponseCode();
        
        if(status == 206){
          InputStream in = conn.getInputStream();
          RandomAccessFile raf =new RandomAccessFile("/sdcard/jdk.exe", "rwd");
          
          //文件開始寫入..
          raf.seek(startIndex);
          
          int len =0;
          byte[] buffer =new byte[1024];
          
          //已經(jīng)下載的數(shù)據(jù)長度..
          int total = 0;
          
          
          while((len = in.read(buffer))!=-1){
            //記錄當(dāng)前數(shù)據(jù)下載的長度...
            RandomAccessFile file = new RandomAccessFile("/sdcard/"+ThreadID+".txt", "rwd");
            
            raf.write(buffer, 0, len);
            total += len;
            System.out.println("線程"+ThreadID+"total:"+total);
            file.write((total+startIndex+"").getBytes());
            file.close();
            
            synchronized (MainActivity.this) {
              currentProgress += len; //獲取當(dāng)前總進度...
               //progressBar progressDialog可以直接在子線程內(nèi)部更新UI..由于源碼內(nèi)部進行了特殊的處理..
               pb.setProgress(currentProgress); //更改界面上的進度條進度..
               Message msg =Message.obtain(); //復(fù)用以前的消息..避免多次new...
               msg.what = 3;
               handler.sendMessage(msg);
               
            }
          }
          raf.close();
          in.close();
          System.out.println("線程："+ThreadID+"下載完畢");
        }else{
          System.out.println("線程："+ThreadID+"下載失敗");
        }
        
      } catch (Exception e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
        Message msg = new Message();
        msg.what = 1;
        msg.obj = e;
        handler.sendMessage(msg);
      }finally{
        synchronized (MainActivity.this) {
          runningThread--;
          
          if(runningThread == 0){
            for(int i=1;i<=threadCount;i++){
              File file = new File("/sdcard/"+i+".txt");
              file.delete();
            }
            Message msg =new Message();
            msg.what = 2;
            msg.obj ="下載完畢";
            handler.sendMessage(msg);
          }
        }  
        
      }
  
    }
    
  }
  @Override
  public boolean onCreateOptionsMenu(Menu menu) {
    // Inflate the menu; this adds items to the action bar if it is present.
    getMenuInflater().inflate(R.menu.main, menu);
    return true;
  }

}

源代碼如上..優(yōu)化的事情我就不做了..為了方便直接就貼上了..這里定義了一個ProgressBar進度條..一個TextView來同步進度條的下載進度..在Android中我們自然不能夠在主線程中去調(diào)用耗時間的操作..因此這些耗時的操作我們就通過開啟子線程的方式去使用..但是子線程是不能夠更新UI界面的..因此我們需要使用到Handler Message機制來完成主界面UI更新的操作.

但是上面的代碼當(dāng)中我們會發(fā)現(xiàn)一個問題..在子線程內(nèi)部居然更新了ProgressBar操作..其實ProgressBar和ProgressDialog是兩個特例..我們可以在子線程內(nèi)部去更新他們的屬性..我們來看一下源代碼的實現(xiàn)過程..

 private synchronized void refreshProgress(int id, int progress, boolean fromUser) {
    if (mUiThreadId == Thread.currentThread().getId()) { //如果當(dāng)前運行的線程和主線程相同..那么更新進度條..
      doRefreshProgress(id, progress, fromUser, true);
    } else { //如果不滿足上面說的情況..
      if (mRefreshProgressRunnable == null) {
        mRefreshProgressRunnable = new RefreshProgressRunnable();//那么新建立一個線程..然后執(zhí)行下面的過程..
      }

      final RefreshData rd = RefreshData.obtain(id, progress, fromUser); //獲取消息隊列中的消息..
      mRefreshData.add(rd);
      if (mAttached && !mRefreshIsPosted) {
        post(mRefreshProgressRunnable); //主要是這個地方..調(diào)用了post方法..將當(dāng)前運行的線程發(fā)送到消息隊列當(dāng)中..那么這個線程就可以在UI中運行了..因此這一步是決定因素..
        mRefreshIsPosted = true;
      }
    }
  }

正是由于源碼內(nèi)部調(diào)用了post方法..將當(dāng)前的線程放入到消息隊列當(dāng)中..那么UI中的Looper線程就會對這個線程進行處理，那么就表示這個線程是可以被執(zhí)行在UI當(dāng)中的..也正是這個因素導(dǎo)致了我們可以在子線程內(nèi)部更新ProgressBar..但是我們可以看到如果我們想要去更新TextView的時候..我們就需要調(diào)用Handler Message機制來完成UI界面的更新了..因此這一塊需要我們?nèi)プ⒁狻?br /> 移植之后代碼其實并沒有發(fā)生太大的變化，這樣就可以完成一個在Android中的多線程斷點下載器了。

以上就是本文的全部內(nèi)容，希望對大家學(xué)習(xí)Android軟件編程有所幫助。

您可能感興趣的文章: