Android實(shí)現(xiàn)網(wǎng)絡(luò)多線程文件下載
實(shí)現(xiàn)原理
(1)首先獲得下載文件的長(zhǎng)度,然后設(shè)置本地文件的長(zhǎng)度。
(2)根據(jù)文件長(zhǎng)度和線程數(shù)計(jì)算每條線程下載的數(shù)據(jù)長(zhǎng)度和下載位置。
如:文件的長(zhǎng)度為6M,線程數(shù)為3,那么,每條線程下載的數(shù)據(jù)長(zhǎng)度為2M,每條線程開(kāi)始下載的位置如下圖所示:

(網(wǎng)上找的圖)
例如10M大小,使用3個(gè)線程來(lái)下載,
線程下載的數(shù)據(jù)長(zhǎng)度 (10%3 == 0 ? 10/3:10/3+1) ,第1,2個(gè)線程下載長(zhǎng)度是4M,第三個(gè)線程下載長(zhǎng)度為2M
下載開(kāi)始位置:線程id*每條線程下載的數(shù)據(jù)長(zhǎng)度 = ?
下載結(jié)束位置:(線程id+1)*每條線程下載的數(shù)據(jù)長(zhǎng)度-1=?
之前練習(xí)時(shí)的一個(gè)demo,不多說(shuō)了,直接上代碼吧,有關(guān)斷點(diǎn)續(xù)傳,需要使用數(shù)據(jù)庫(kù),不再加了,網(wǎng)上有很多成熟的項(xiàng)目可以直接用。
實(shí)例
MainApp:
package com.amos.app;
import java.io.File;
import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import com.amos.download.R;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.os.Bundle;
import android.os.Environment;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.ProgressBar;
import android.widget.TextView;
import android.widget.Toast;
/**
* @author yangxiaolong
* @2014-5-6
*/
public class MainApp extends Activity implements OnClickListener {
private static final String TAG = MainApp.class.getSimpleName();
/** 顯示下載進(jìn)度TextView */
private TextView mMessageView;
/** 顯示下載進(jìn)度ProgressBar */
private ProgressBar mProgressbar;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.progress_activity);
findViewById(R.id.download_btn).setOnClickListener(this);
mMessageView = (TextView) findViewById(R.id.download_message);
mProgressbar = (ProgressBar) findViewById(R.id.download_progress);
}
@Override
public void onClick(View v) {
if (v.getId() == R.id.download_btn) {
doDownload();
}
}
/**
* 使用Handler更新UI界面信息
*/
@SuppressLint("HandlerLeak")
Handler mHandler = new Handler() {
@Override
public void handleMessage(Message msg) {
mProgressbar.setProgress(msg.getData().getInt("size"));
float temp = (float) mProgressbar.getProgress()
/ (float) mProgressbar.getMax();
int progress = (int) (temp * 100);
if (progress == 100) {
Toast.makeText(MainApp.this, "下載完成!", Toast.LENGTH_LONG).show();
}
mMessageView.setText("下載進(jìn)度:" + progress + " %");
}
};
/**
* 下載準(zhǔn)備工作,獲取SD卡路徑、開(kāi)啟線程
*/
private void doDownload() {
// 獲取SD卡路徑
String path = Environment.getExternalStorageDirectory()
+ "/amosdownload/";
File file = new File(path);
// 如果SD卡目錄不存在創(chuàng)建
if (!file.exists()) {
file.mkdir();
}
// 設(shè)置progressBar初始化
mProgressbar.setProgress(0);
// 簡(jiǎn)單起見(jiàn),我先把URL和文件名稱寫死,其實(shí)這些都可以通過(guò)HttpHeader獲取到
String downloadUrl = "http://gdown.baidu.com/data/wisegame/91319a5a1dfae322/baidu_16785426.apk";
String fileName = "baidu_16785426.apk";
int threadNum = 5;
String filepath = path + fileName;
Log.d(TAG, "download file path:" + filepath);
downloadTask task = new downloadTask(downloadUrl, threadNum, filepath);
task.start();
}
/**
* 多線程文件下載
*
* @author yangxiaolong
* @2014-8-7
*/
class downloadTask extends Thread {
private String downloadUrl;// 下載鏈接地址
private int threadNum;// 開(kāi)啟的線程數(shù)
private String filePath;// 保存文件路徑地址
private int blockSize;// 每一個(gè)線程的下載量
public downloadTask(String downloadUrl, int threadNum, String fileptah) {
this.downloadUrl = downloadUrl;
this.threadNum = threadNum;
this.filePath = fileptah;
}
@Override
public void run() {
FileDownloadThread[] threads = new FileDownloadThread[threadNum];
try {
URL url = new URL(downloadUrl);
Log.d(TAG, "download file http path:" + downloadUrl);
URLConnection conn = url.openConnection();
// 讀取下載文件總大小
int fileSize = conn.getContentLength();
if (fileSize <= 0) {
System.out.println("讀取文件失敗");
return;
}
// 設(shè)置ProgressBar最大的長(zhǎng)度為文件Size
mProgressbar.setMax(fileSize);
// 計(jì)算每條線程下載的數(shù)據(jù)長(zhǎng)度
blockSize = (fileSize % threadNum) == 0 ? fileSize / threadNum
: fileSize / threadNum + 1;
Log.d(TAG, "fileSize:" + fileSize + " blockSize:");
File file = new File(filePath);
for (int i = 0; i < threads.length; i++) {
// 啟動(dòng)線程,分別下載每個(gè)線程需要下載的部分
threads[i] = new FileDownloadThread(url, file, blockSize,
(i + 1));
threads[i].setName("Thread:" + i);
threads[i].start();
}
boolean isfinished = false;
int downloadedAllSize = 0;
while (!isfinished) {
isfinished = true;
// 當(dāng)前所有線程下載總量
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秒后再讀取下載進(jìn)度
}
Log.d(TAG, " all of downloadSize:" + downloadedAllSize);
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
FileDownloadThread:
package com.amos.app;
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 yangxiaolong
* @2014-5-6
*/
public class FileDownloadThread extends Thread {
private static final String TAG = FileDownloadThread.class.getSimpleName();
/** 當(dāng)前下載是否完成 */
private boolean isCompleted = false;
/** 當(dāng)前下載文件長(zhǎng)度 */
private int downloadLength = 0;
/** 文件保存路徑 */
private File file;
/** 文件下載路徑 */
private URL downloadUrl;
/** 當(dāng)前下載線程ID */
private int threadId;
/** 線程下載數(shù)據(jù)長(zhǎng)度 */
private int blockSize;
/**
*
* @param url:文件下載地址
* @param file:文件保存路徑
* @param blocksize:下載數(shù)據(jù)長(zhǎng)度
* @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);//開(kāi)始位置
int endPos = blockSize * threadId - 1;//結(jié)束位置
//設(shè)置當(dāng)前線程下載的起點(diǎn)、終點(diǎn)
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;
}
/**
* 線程下載文件長(zhǎng)度
*/
public int getDownloadLength() {
return downloadLength;
}
}
效果圖:

Log控制臺(tái):

可以看到文件總大小、我們創(chuàng)建的5個(gè)線程每個(gè)負(fù)責(zé)下載的區(qū)間
SD卡:

關(guān)于Android實(shí)現(xiàn)網(wǎng)絡(luò)多線程文件下載小編就給大家介紹這么多,希望對(duì)大家有所幫助!同時(shí)也非常感謝大家一直以來(lái)對(duì)腳本之家網(wǎng)站的支持!
- android中webview控件和javascript交互實(shí)例
- Android WebView使用方法詳解 附j(luò)s交互調(diào)用方法
- Android開(kāi)發(fā)之WebView組件的使用解析
- Android使用WebView播放flash的方法
- Android實(shí)現(xiàn)WebView刪除緩存的方法
- Android中WebView圖片實(shí)現(xiàn)自適應(yīng)的方法
- Android zip文件下載和解壓實(shí)例
- Android實(shí)現(xiàn)文件下載進(jìn)度顯示功能
- Android 文件下載三種基本方式
- Android 將文件下載到指定目錄的實(shí)現(xiàn)代碼
- android實(shí)現(xiàn)文件下載功能
- Android編程使用WebView實(shí)現(xiàn)文件下載功能的兩種方法
相關(guān)文章
Android開(kāi)發(fā)ImageView圖片無(wú)法顯示解決過(guò)程
在Android中ImageView無(wú)法顯示加載的本地SDCard圖片:過(guò)程為先調(diào)用本地照相機(jī)程序攝像,然后將拍攝的圖片加載在ImageView中顯示,具體解決方法如下,感興趣的朋友可以參考下哈2013-06-06
Android中RecyclerView上拉下拉,分割線,多條目的實(shí)例代碼
這篇文章主要介紹了Android中RecyclerView上拉下拉,分割線,多條目的實(shí)例代碼,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友參考下吧2017-01-01
android viewpager實(shí)現(xiàn)豎直滑動(dòng)效果
這篇文章主要為大家詳細(xì)介紹了android viewpager實(shí)現(xiàn)豎直滑動(dòng)效果,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-07-07
Android 實(shí)現(xiàn)廣告歡迎界面(倒計(jì)時(shí))
前些時(shí)候就是別人問(wèn)我他的android APP怎么做一個(gè)廣告的歡迎界面,就是過(guò)幾秒后自動(dòng)跳轉(zhuǎn)到主界面的實(shí)現(xiàn)。下面通過(guò)本文給大家介紹Android 實(shí)現(xiàn)廣告歡迎界面(倒計(jì)時(shí))的方法,需要的朋友參考下吧2017-12-12
Android性能優(yōu)化之RecyclerView分頁(yè)加載組件功能詳解
這篇文章主要為大家介紹了Android性能優(yōu)化之RecyclerView分頁(yè)加載組件功能詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-09-09
Android二級(jí)緩存加載圖片實(shí)現(xiàn)照片墻功能
這篇文章主要為大家詳細(xì)介紹了Android二級(jí)緩存加載圖片實(shí)現(xiàn)照片墻功能,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-07-07
詳解Android app自動(dòng)更新總結(jié)(已適配9.0)
這篇文章主要介紹了詳解Android app自動(dòng)更新總結(jié)(已適配9.0),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04
Windows下快速搭建安卓開(kāi)發(fā)環(huán)境Android studio
這篇文章主要介紹了Windows下快速搭建安卓開(kāi)發(fā)環(huán)境Android studio的相關(guān)資料,感興趣的小伙伴們可以參考一下2016-07-07
Android開(kāi)發(fā)EditText禁止輸入監(jiān)聽(tīng)及InputFilter字符過(guò)濾
這篇文章主要為大家介紹了Android開(kāi)發(fā)EditText禁止輸入監(jiān)聽(tīng)及InputFilter字符過(guò)濾示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-06-06

