多線程斷點續傳及下載

斷點下載

package com.example.downloaddemo;

import java.io.File;
import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;

import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.util.Log;
import android.view.Menu;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.TextView;

public class MoreThreadDownActivity extends Activity implements OnClickListener{
    private Button start_download1;
     /** 顯示下載進度TextView */  
    private TextView download_info1;
    int fileSize;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_more_thread_down);
        
        start_download1 = (Button) findViewById(R.id.start_download1);
        download_info1 = (TextView) findViewById(R.id.download_info1);
        
        start_download1.setOnClickListener(this);
    }

    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        // Inflate the menu; this adds items to the action bar if it is present.
        getMenuInflater().inflate(R.menu.activity_more_thread_down, menu);
        return true;
    }
    //點擊下載按鈕，開始下載
    @Override
    public void onClick(View v) {
        doDownload();//調用下載的函數
        
    }
    /** 
     * 使用Handler更新UI界面信息 
     */  
    @SuppressLint("HandlerLeak")  
    Handler mHandler = new Handler() {  
        @Override  
        public void handleMessage(Message msg) {  
  
//            mProgressbar.setProgress();  
//  
            float temp = (float) msg.getData().getInt("size")  
                    / (float) fileSize;  
//  
            int progress = (int) (temp * 100);
            Log.i("TAG", "當前進度："+progress);
//            if (progress == 100) {  
//                Toast.makeText(MainApp.this, "下載完成！", Toast.LENGTH_LONG).show();  
//            }  
            download_info1.setText("下載進度:" + progress + "%");  
  
        }  
    };  
    
    /** 
     * 下載準備工做，獲取SD卡路徑、開啓線程 
     */  
    private void doDownload() {  
        download_info1.setText("開始下載");
        // 獲取SD卡路徑  
        String path = "/sdcard/" + System.currentTimeMillis() + "acedownload.mp4";
        String downloadUrl = "http://101.200.142.201:8080/tqyb/ace.mp4";
        File file = new File(path);  
        // 若是SD卡目錄不存在建立  
//        if (!file.exists()) {  
//            file.mkdir();  
//        }  
        // 簡單起見，我先把URL和文件名稱寫死，其實這些均可以經過HttpHeader獲取到  
        int threadNum = 5;  
        Log.d("TAG", "download file  path:" + path);  
        DownloadTask task = new DownloadTask(downloadUrl, threadNum, path);  
        task.start();  
    }  
    private static final String TAG = "TAG";
    /** 
     * 多線程文件下載 
     *  
     * @author yangxiaolong 
     * @2014-8-7 
     */  
    class DownloadTask extends Thread {  
        private String downloadUrl;// 下載連接地址  
        private int threadNum;// 開啓的線程數  
        private String filePath;// 保存文件路徑地址  
        private int blockSize;// 每個線程的下載量  
  
        public DownloadTask(String downloadUrl, int threadNum, String fileptah) {  
            this.downloadUrl = downloadUrl;  
            this.threadNum = threadNum;  
            this.filePath = fileptah;  
        }  
  
        @Override  
        public void run() {  
            //建立下載線程的數組，長度爲5
            FileDownloadThread[] threads = new FileDownloadThread[threadNum];  
            try {  
                URL url = new URL(downloadUrl);  //建立下載須要的網絡請求對象  URL的對象
                Log.d(TAG, "download file http path:" + downloadUrl);  
                URLConnection conn = url.openConnection();//建立  網絡請求的URLConnection
                // 讀取下載文件總大小  
                fileSize = conn.getContentLength();  
                if (fileSize <= 0) {  
                    System.out.println("讀取文件失敗");  
                    return;  
                }  
  
                // 計算每條線程下載的數據長度  
                blockSize = (fileSize % threadNum) == 0 ? fileSize / threadNum : fileSize / threadNum + 1;  
  
                Log.d(TAG, "fileSize:" + fileSize + "  blockSize:");  
              //下載的文件，存放的位置
                File file = new File(filePath); 
                //啓動5條線程，同時下載
                for (int i = 0; i < threads.length; i++) {  
                    // 啓動線程，分別下載每一個線程須要下載的部分  
                    threads[i] = new FileDownloadThread(url, file, blockSize, (i + 1));  
                    threads[i].setName("Thread:" + i);  
                    threads[i].start();  
                }  
                //上面的5條線程，啓動後，本身執行本身的，下面的代碼也同時執行，不受影響
                boolean isfinished = false;  
                int downloadedAllSize = 0;  
                while (!isfinished) {  //循環判斷，5個線程的整體下載進度，已是否每一個都完成了
                    isfinished = true;  
                    // 當前全部線程下載總量  
                    downloadedAllSize = 0;  
                    for (int i = 0; i < threads.length; i++) {  
                        downloadedAllSize += threads[i].getDownloadLength();  
                        if (!threads[i].isCompleted()) {  
                            isfinished = false;  
                        }  
                    }  
                    // 通知handler去更新視圖組件  
                    Message msg = new Message();  
                    msg.getData().putInt("size", downloadedAllSize);  
                    mHandler.sendMessage(msg);  
                    // Log.d(TAG, "current downloadSize:" + downloadedAllSize);  
                    Thread.sleep(1000);// 休息1秒後再讀取下載進度  
                }  
                Log.d(TAG, " all of downloadSize:" + downloadedAllSize);  
  
            } catch (MalformedURLException e) {  
                e.printStackTrace();  
            } catch (IOException e) {  
                e.printStackTrace();  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
  
        }  
    }  

}

package com.example.downloaddemo;

import java.io.BufferedInputStream;  
import java.io.File;  
import java.io.IOException;  
import java.io.RandomAccessFile;  
import java.net.URL;  
import java.net.URLConnection;  
import android.util.Log;  
  
/** 
 * 文件下載類 
 *  
 * @author  
 * @2014-5-6 
 */  
public class FileDownloadThread extends Thread {  
  
    private static final String TAG = FileDownloadThread.class.getSimpleName();  
  
    /** 當前下載是否完成 */  
    private boolean isCompleted = false;  
    /** 當前下載文件長度 */  
    private int downloadLength = 0;  
    /** 文件保存路徑 */  
    private File file;  
    /** 文件下載路徑 */  
    private URL downloadUrl;  
    /** 當前下載線程ID */  
    private int threadId;  
    /** 線程下載數據長度 */  
    private int blockSize;  
  
    /** 
     *  
     * @param url:文件下載地址 
     * @param file:文件保存路徑 
     * @param blocksize:下載數據長度 
     * @param threadId:線程ID 
     */  
    public FileDownloadThread(URL downloadUrl, File file, int blocksize,  int threadId) {  
        this.downloadUrl = downloadUrl;  
        this.file = file;  
        this.threadId = threadId;  
        this.blockSize = blocksize;  
    }  
  
    @Override  
    public void run() {  
  
        BufferedInputStream bis = null;  
        RandomAccessFile raf = null;  
  
        try {  
            URLConnection conn = downloadUrl.openConnection();  
            conn.setAllowUserInteraction(true);  
  
            int startPos = blockSize * (threadId - 1);//開始位置  
            int endPos = blockSize * threadId - 1;//結束位置  
            //設置當前線程下載的起點、終點  bytes=4-7
            conn.setRequestProperty("Range", "bytes=" + startPos + "-" + endPos);  
            System.out.println(Thread.currentThread().getName() + "  bytes="  
                    + startPos + "-" + endPos);  
  
            byte[] buffer = new byte[1024];  
            bis = new BufferedInputStream(conn.getInputStream());  
  
            raf = new RandomAccessFile(file, "rwd");  //建立隨機讀寫流，從本線程下載的位置做爲寫的位置，把下載的數據寫入文件
            raf.seek(startPos);  //設置寫的位置
            int len;  
            while ((len = bis.read(buffer, 0, 1024)) != -1) {  //循環讀取本次線程下載的數據，寫入文件
                raf.write(buffer, 0, len);  
                downloadLength += len;  //記錄讀取的數據的數量，顯示在進度條上
            }  
            isCompleted = true;  //循環走完了，說明本線程下載完了
            Log.d(TAG, "current thread task has finished,all size:"  
                    + downloadLength);  
  
        } catch (IOException e) {  
            e.printStackTrace();  
        } finally {  
            if (bis != null) {  
                try {  
                    bis.close();  
                } catch (IOException e) {  
                    e.printStackTrace();  
                }  
            }  
            if (raf != null) {  
                try {  
                    raf.close();  
                } catch (IOException e) {  
                    e.printStackTrace();  
                }  
            }  
        }  
    }  
  
    /** 
     * 線程文件是否下載完畢 
     */  
    public boolean isCompleted() {  
        return isCompleted;  
    }  
  
    /** 
     * 線程下載文件長度 
     */  
    public int getDownloadLength() {  
        return downloadLength;  
    }  
  
}  

斷點續傳

package com.example.uptoserverdemo;

import java.io.File;
import java.io.IOException;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.*;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.FileEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;

import com.lidroid.xutils.ViewUtils;
import com.lidroid.xutils.view.annotation.event.OnClick;

import android.os.AsyncTask;
import android.os.Bundle;
import android.app.Activity;
import android.util.Log;
import android.view.Menu;
import android.view.View;
import android.widget.TextView;

public class MainActivity extends Activity {
    private TextView tv;
    public static final String UP_URL = "http://169.254.109.73:8080/upserver/UploadFileServlet";
//    private String filePath = "/storage/sdcard0/1461656337024acedownload.mp4";
//    String fileName = "1461656337024acedownload.mp4";
    private String filePath = "/mnt/sdcard/ace.mp4";
    String fileName = "ace.mp4";
    
    
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        tv = (TextView) findViewById(R.id.tv);
        
        
        ViewUtils.inject(this);
    }
    
    @OnClick(R.id.tv)
    public void jump(View view){
        //異步上傳文件
        new MyAsyncTask().execute();
    }
    
    class MyAsyncTask extends AsyncTask<String, Integer, String>{

        @Override
        protected String doInBackground(String... params) {
            String rs = "";
            String httpUrl = UP_URL+"?fileName="+fileName;   
            HttpPost request = new HttpPost(httpUrl);    
            File file = new File(filePath);
            //上傳文件的配置代碼
            FileEntity entity = new FileEntity(file,"binary/octet-stream");  
            entity.setContentEncoding("binary/octet-stream");  
            request.setEntity(entity);  
           
            HttpClient httpClient = new DefaultHttpClient();  
            HttpResponse response;  
                try {
                    response = httpClient.execute(request);
                    //若是返回狀態爲200，得到返回的結果  
                    if(response.getStatusLine().getStatusCode()==HttpStatus.SC_OK){    
                        //圖片上傳成功     
                        Log.i("TAG","上傳成功");
                        HttpEntity rsEntity = response.getEntity();
                        rs = EntityUtils.toString(rsEntity, "utf-8");
                        Log.i("TAG",rs);
                    }  
                } catch (ClientProtocolException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }  
                return rs;
            
        }    
        
        @Override
        protected void onPostExecute(String result) {
            // TODO Auto-generated method stub
            super.onPostExecute(result);
            tv.setText(result);
        }
    }

    

}