溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要介紹“android原生如何實現多線程斷點續傳功能”，在日常操作中，相信很多人在android原生如何實現多線程斷點續傳功能問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”android原生如何實現多線程斷點續傳功能”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！
需求描述： 輸入一個下載地址，和要啟動的線程數量，點擊下載 利用多線程將文件下載到手機端，支持 斷點續傳。
效果展示
示例代碼：
布局 activity_main.xml
<?xml version="1.0" encoding="utf-8"?> <android.support.constraint.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:layout_height="match_parent" tools:context=".MainActivity"> <EditText android:id="@+id/editText" android:layout_width="0dp" android:layout_height="wrap_content" android:layout_marginStart="8dp" android:layout_marginTop="8dp" android:layout_marginEnd="8dp" android:ems="10" android:hint="下載文件地址" android:inputType="textPersonName" app:layout_constraintEnd_toEndOf="parent" app:layout_constraintStart_toStartOf="parent" app:layout_constraintTop_toTopOf="parent" /> <EditText android:id="@+id/editText2" android:layout_width="0dp" android:layout_height="wrap_content" android:layout_marginStart="8dp" android:layout_marginTop="8dp" android:layout_marginEnd="8dp" android:ems="10" android:hint="開啟的線程數量" android:inputType="textPersonName" app:layout_constraintEnd_toEndOf="parent" app:layout_constraintStart_toStartOf="parent" app:layout_constraintTop_toBottomOf="@+id/editText" /> <Button android:id="@+id/button" android:layout_width="wrap_content" android:layout_height="wrap_content" android:layout_marginStart="8dp" android:layout_marginTop="8dp" android:text="開始下載" app:layout_constraintStart_toStartOf="parent" android:onClick="click" app:layout_constraintTop_toBottomOf="@+id/editText2" /> <LinearLayout android:id="@+id/ll_proBox" android:layout_width="0dp" android:layout_height="0dp" android:layout_marginStart="8dp" android:layout_marginTop="8dp" android:layout_marginEnd="8dp" android:layout_marginBottom="8dp" android:orientation="vertical" app:layout_constraintBottom_toBottomOf="parent" app:layout_constraintEnd_toEndOf="parent" app:layout_constraintStart_toStartOf="parent" app:layout_constraintTop_toBottomOf="@+id/button"> </LinearLayout> </android.support.constraint.ConstraintLayout>
item.xml 文件
<?xml version="1.0" encoding="utf-8"?> <ProgressBar xmlns:android="http://schemas.android.com/apk/res/android" android:layout_height="match_parent" android:layout_width="match_parent" ></ProgressBar>
MainActivity.java
package com.example.www.mutildownload;
import android.Manifest;
import android.os.Environment;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.view.LayoutInflater;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.LinearLayout;
import android.widget.ProgressBar;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.List;
public class MainActivity extends AppCompatActivity {
private EditText mEtUrl;
private EditText mEt_thread;
private Button mBtnDownload;
private LinearLayout mLlProBox;
private String path;
private int runningThread;
private int threadCount;
private List<ProgressBar> mPbList;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
String[] permissions = new String[]{Manifest.permission.READ_EXTERNAL_STORAGE, Manifest.permission.WRITE_EXTERNAL_STORAGE};
requestPermissions(permissions, 200);
mEtUrl = (EditText) findViewById(R.id.editText);
mEt_thread = (EditText) findViewById(R.id.editText2);
mBtnDownload = (Button) findViewById(R.id.button);
mLlProBox = (LinearLayout) findViewById(R.id.ll_proBox);
//添加 一個進度條的引用
mPbList = new ArrayList<>();
for (int i = 0; i < 10; i++) {
String path = Environment.getExternalStorageDirectory() + "/" + i +".txt";
System.out.println(path);
File file = new File(path);
if(file.exists() && file.length() > 0) {
file.delete();
System.out.println(file.getAbsoluteFile() + "刪除成功");
}
}
}
public void click(View v) {
path = mEtUrl.getText().toString().trim();
threadCount = Integer.parseInt(mEt_thread.getText().toString().trim());
LayoutInflater inflater = (LayoutInflater) getSystemService(LAYOUT_INFLATER_SERVICE);
//先移除進度條 再添加
mPbList.clear();
mLlProBox.removeAllViews();
for (int i = 0; i < threadCount; i++) {
ProgressBar pbView = (ProgressBar)inflater.inflate(R.layout.item, null);
mPbList.add(pbView);
mLlProBox.addView(pbView);
}
new Thread() {
@Override
public void run() {
try {
URL url = new URL(path);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);
int responseCode = conn.getResponseCode();
if (responseCode == 200) {
int contentLength = conn.getContentLength();
runningThread = threadCount;
System.out.println("length" + contentLength);
RandomAccessFile rafAccessFile = new RandomAccessFile(Environment.getExternalStorageDirectory() + "/" + getFileName(path), "rw");
rafAccessFile.setLength(contentLength);
int blockSize = contentLength / threadCount;
for (int i = 0; i < threadCount; i++) {
int startIndex = i * blockSize; //每個現成下載的開始位置
int endIndex = (i + 1) * blockSize - 1;// 每個線程的結束位置
if (i == threadCount - 1) {
//最后一個線程
endIndex = contentLength - 1;
}
new DownloadThread(startIndex, endIndex, i).start();
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
}.start();
}
public String getFileName(String path) {
int posi = path.lastIndexOf("/") + 1;
return path.substring(posi);
}
private class DownloadThread extends Thread {
private int startIndex;
private int endIndex;
private int threadId;
private int pbMaxSize; // 當前線程下載的最大值
private int pbLastPosition;
public DownloadThread(int startIndex, int endIndex, int threadId) {
this.startIndex = startIndex;
this.endIndex = endIndex;
this.threadId = threadId;
}
@Override
public void run() {
try {
pbMaxSize = endIndex - startIndex;
URL url = new URL(path);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);
File file = new File(Environment.getExternalStorageDirectory() + "/" + threadId + ".txt");
if (file.exists() && file.length() > 0) {
FileInputStream fis = new FileInputStream(file);
BufferedReader buff = new BufferedReader(new InputStreamReader(fis));
String lastPosition = buff.readLine();// 讀取出來的內容就是上次下載的位置
int lastPos = Integer.parseInt(lastPosition);
System.out.println("線程id：" + threadId + "當前線程下載的位置：-----" + lastPos);
//上次進度條下載的位置
pbLastPosition = lastPos - startIndex;
startIndex = lastPos;
fis.close();
buff.close();
}
conn.setRequestProperty("Range", "bytes=" + startIndex + "-" + endIndex); //固定寫法，請求部分資源
int responseCode = conn.getResponseCode(); // 206表示請求部分資源
if (responseCode == 206) {
RandomAccessFile rafAccessFile = new RandomAccessFile(Environment.getExternalStorageDirectory().getPath() + "/" +getFileName(path), "rw");
Log.v("MainActivity", Environment.getExternalStorageDirectory().getPath() + "/" +getFileName(path));
rafAccessFile.seek(startIndex);
InputStream is = conn.getInputStream();
int len = -1;
byte[] buffer = new byte[1024 * 1024];
int total = 0; // 代表當前線程下載的大小
while ((len = is.read(buffer)) != -1) {
rafAccessFile.write(buffer, 0, len);
total += len;
//斷點續傳， 保存當前線程下載的位置
int currentThreadPosition = startIndex + total; //當前線程下載的位置
// 存儲當線程的下載五位置
RandomAccessFile raff = new RandomAccessFile(Environment.getExternalStorageDirectory() + "/" + threadId + ".txt", "rwd");
raff.write(String.valueOf(currentThreadPosition).getBytes());
raff.close();
mPbList.get(threadId).setMax(pbMaxSize);
mPbList.get(threadId).setProgress(pbLastPosition + total);// 設置當前進度條的當前進度
}
rafAccessFile.close();
System.out.println("線程" + threadId + "下載完成");
//刪除臨時文件
synchronized (MainActivity.DownloadThread.class) {
runningThread--;
if (runningThread == 0) {
for (int i = 0; i < threadCount; i++) {
File deleteFile = new File(Environment.getExternalStorageDirectory() + "/" + i + ".txt");
deleteFile.delete();
}
}
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
}權限配置
<?xml version="1.0" encoding="utf-8"?> <manifest xmlns:android="http://schemas.android.com/apk/res/android" package="com.example.www.mutildownload"> <uses-permission android:name="android.permission.INTERNET" /> <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" /> <uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE" /> <application android:allowBackup="true" android:icon="@mipmap/ic_launcher" android:label="@string/app_name" android:roundIcon="@mipmap/ic_launcher_round" android:supportsRtl="true" android:theme="@style/AppTheme"> <activity android:name=".MainActivity"> <intent-filter> <action android:name="android.intent.action.MAIN" /> <category android:name="android.intent.category.LAUNCHER" /> </intent-filter> </activity> </application> </manifest>
到此，關于“android原生如何實現多線程斷點續傳功能”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注億速云網站，小編會繼續努力為大家帶來更多實用的文章！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
