android原生實(shí)現(xiàn)多線程斷點(diǎn)續(xù)傳功能

更新時(shí)間：2022年07月27日 11:05:16 作者：ITzhongzi

這篇文章主要為大家詳細(xì)介紹了android原生實(shí)現(xiàn)多線程斷點(diǎn)續(xù)傳功能，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文實(shí)例為大家分享了android實(shí)現(xiàn)多線程斷點(diǎn)續(xù)傳功能的具體代碼，供大家參考，具體內(nèi)容如下

需求描述：輸入一個(gè)下載地址，和要啟動(dòng)的線程數(shù)量，點(diǎn)擊下載利用多線程將文件下載到手機(jī)端，支持斷點(diǎn)續(xù)傳。

在前兩章的java 多線程的從基礎(chǔ)上進(jìn)行

效果展示

示例代碼：

布局 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="開啟的線程數(shù)量"
? ? ? ? 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"
? ? style="@style/Widget.AppCompat.ProgressBar.Horizontal"
? ? ></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);

? ? ? ? //添加 一個(gè)進(jìn)度條的引用
? ? ? ? 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);

? ? ? ? //先移除進(jìn)度條 再添加
? ? ? ? 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; //每個(gè)現(xiàn)成下載的開始位置
? ? ? ? ? ? ? ? ? ? ? ? ? ? int endIndex = (i + 1) * blockSize - 1;// 每個(gè)線程的結(jié)束位置
? ? ? ? ? ? ? ? ? ? ? ? ? ? if (i == threadCount - 1) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? //最后一個(gè)線程
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? 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; // 當(dāng)前線程下載的最大值
? ? ? ? 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();// 讀取出來的內(nèi)容就是上次下載的位置
? ? ? ? ? ? ? ? ? ? int lastPos = Integer.parseInt(lastPosition);

? ? ? ? ? ? ? ? ? ? System.out.println("線程id：" + threadId + "當(dāng)前線程下載的位置：-----" + lastPos);
? ? ? ? ? ? ? ? ? ? //上次進(jìn)度條下載的位置
? ? ? ? ? ? ? ? ? ? pbLastPosition = lastPos - startIndex;

? ? ? ? ? ? ? ? ? ? startIndex = lastPos;
? ? ? ? ? ? ? ? ? ? fis.close();
? ? ? ? ? ? ? ? ? ? buff.close();
? ? ? ? ? ? ? ? }

? ? ? ? ? ? ? ? conn.setRequestProperty("Range", "bytes=" + startIndex + "-" + endIndex); //固定寫法，請(qǐng)求部分資源
? ? ? ? ? ? ? ? int responseCode = conn.getResponseCode(); ?// 206表示請(qǐng)求部分資源
? ? ? ? ? ? ? ? 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; // 代表當(dāng)前線程下載的大小
? ? ? ? ? ? ? ? ? ? while ((len = is.read(buffer)) != -1) {
? ? ? ? ? ? ? ? ? ? ? ? rafAccessFile.write(buffer, 0, len);

? ? ? ? ? ? ? ? ? ? ? ? total += len;
? ? ? ? ? ? ? ? ? ? ? ? //斷點(diǎn)續(xù)傳， 保存當(dāng)前線程下載的位置
? ? ? ? ? ? ? ? ? ? ? ? int currentThreadPosition = startIndex + total; //當(dāng)前線程下載的位置
? ? ? ? ? ? ? ? ? ? ? ? // 存儲(chǔ)當(dāng)線程的下載五位置
? ? ? ? ? ? ? ? ? ? ? ? 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);// 設(shè)置當(dāng)前進(jìn)度條的當(dāng)前進(jìn)度

? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? rafAccessFile.close();

? ? ? ? ? ? ? ? ? ? System.out.println("線程" + threadId + "下載完成");
? ? ? ? ? ? ? ? ? ? //刪除臨時(shí)文件
? ? ? ? ? ? ? ? ? ? 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();
? ? ? ? ? ? }
? ? ? ? }
? ? }
}

權(quán)限配置

<?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>

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: