android原生實現(xiàn)多線程斷點續(xù)傳功能
本文實例為大家分享了android實現(xiàn)多線程斷點續(xù)傳功能的具體代碼,供大家參考,具體內(nèi)容如下
需求描述: 輸入一個下載地址,和要啟動的線程數(shù)量,點擊下載 利用多線程將文件下載到手機端,支持 斷點續(xù)傳。
在前兩章的java 多線程的從基礎上進行
效果展示
示例代碼:
布局 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); ? ? ? ? //添加 一個進度條的引用 ? ? ? ? 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; //每個現(xiàn)成下載的開始位置 ? ? ? ? ? ? ? ? ? ? ? ? ? ? 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();// 讀取出來的內(nèi)容就是上次下載的位置 ? ? ? ? ? ? ? ? ? ? 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; ? ? ? ? ? ? ? ? ? ? ? ? //斷點續(xù)傳, 保存當前線程下載的位置 ? ? ? ? ? ? ? ? ? ? ? ? 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>
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關文章
詳解Android Activity中的幾種監(jiān)聽器和實現(xiàn)方式
這篇文章主要介紹了Activity中的幾種監(jiān)聽器和實現(xiàn)方式的相關資料,幫助大家更好的理解和學習使用Android,感興趣的朋友可以了解下2021-04-04Android實現(xiàn)網(wǎng)易Tab分類排序控件實現(xiàn)
這篇文章主要為大家詳細介紹了Android仿網(wǎng)易Tab分類排序控件的實現(xiàn)代碼,具有一定的參考價值,感興趣的小伙伴們可以參考一下2017-03-03詳解Android:向服務器提供數(shù)據(jù)之get、post方式
本篇文章主要介紹了詳解Android:向服務器提供數(shù)據(jù)之get、post方式,具有一定的參考價值,有興趣的可以了解一下。2017-03-03android教程之把自己的應用加入到系統(tǒng)分享中
在Android系統(tǒng)中打開相冊中的某張圖片, 點擊右上角的分享按鈕會彈出分享列表, 把自己的應用加入到里面來,下面是設置方法2014-02-02Android RecyclerView的Item自定義動畫及DefaultItemAnimator源碼分析
這篇文章主要介紹了Android RecyclerView的Item自定義動畫及DefaultItemAnimator源碼,感興趣的小伙伴們可以參考一下2016-07-07