多线程系列之学习多线程下载的基本原理和基本用法(1)
多線程下載在我們生活中非常常見,比如迅雷就是我們常用的多線程的下載工具,當然還有斷點續傳,斷點續傳我們在下一節來講,android手機端下載文件時也可以用多線程下載,我們這里是在java中寫一個測試,其實android中的實現和java是一樣的,學會了java就知道怎么在android中實現了,廢話不多說了,怎么實現多線程和多線程的原理是什么樣的,現在我們來學習一下。
<!--more-->
多線程下載原理及步驟:
在本地創建一個大小跟服務器文件相同大小的臨時文件。
計算分配幾個線程去下載服務器上的資源,知道每個線程下載文件的位置。
步驟二的具體方法和操作:
文件的長度/3(線程的個數)=每個線程下載文件的大小
假設文件長度為10,則
線程1:0-2
線程2:3-5
線程3:6-文件末尾
每個線程下載的位置的計算方式:
開始位置:
(線程id - 1)* 每一塊的大小
結束位置:
(線程id * 每一塊大小)-1
開啟多(3)個線程,每一個線程下載對應位置的文件
如果所有的線程都把自己的數據下載完畢了,服務器上的資源就被下載到本地了。
在這里在介紹一個有關多線程下載的java中的相關類RandomAccessFile
RandomAccessFile 隨機文件訪問類
只有RandomAccessFile才有seek搜尋方法,而這個方法也只適用于文件。通過seek()方法指定位置,定位文件,即可以指定隨機寫文件的時候從哪個位置開始寫。利用這個類才能實現文件的多線程下載。
基本原理和相關介紹如上,就這些,現在我們看看代碼:
package net.loonggg.test;import java.io.InputStream; import java.io.RandomAccessFile; import java.net.HttpURLConnection; import java.net.URL;/**** 多線程下載* * @author loonggg* */ public class MutilDownloader {// 開啟的線程的個數public static final int THREAD_COUNT = 3;public static void main(String[] args) throws Exception {String path = "http://down.360safe.com/yunpan/360wangpan_setup.exe";// 連接服務器,獲取一個文件,獲取文件的長度,在本地創建一個大小跟服務器文件大小一樣的臨時文件URL url = new URL(path);HttpURLConnection conn = (HttpURLConnection) url.openConnection();// 設置網絡請求超時時間conn.setConnectTimeout(5000);// 設置請求方式conn.setRequestMethod("GET");int code = conn.getResponseCode();if (code == 200) {// 服務器返回的數據的長度,實際就是文件的長度int length = conn.getContentLength();System.out.println("----文件總長度----" + length);// 在客戶端本地創建出來一個大小跟服務器端文件一樣大小的臨時文件RandomAccessFile raf = new RandomAccessFile("yunpan.exe", "rwd");// 指定創建的這個文件的長度raf.setLength(length);// 關閉rafraf.close();// 假設是3個線程去下載資源// 平均每一個線程下載的文件的大小int blockSize = length / THREAD_COUNT;for (int threadId = 1; threadId <= THREAD_COUNT; threadId++) {// 計算每個線程下載的開始位置和結束位置int startIndex = (threadId - 1) * blockSize;int endIndex = threadId * blockSize - 1;if (threadId == THREAD_COUNT) {endIndex = length;}System.out.println("----threadId---" + threadId+ "--startIndex--" + startIndex + "--endIndex--"+ endIndex);// 開啟每一個線程new DownloadThread(path, threadId, startIndex, endIndex).start();}}}/*** 下載文件的子線程,每一個線程下載對應位置的文件* * @author loonggg* */public static class DownloadThread extends Thread {private int threadId;private int startIndex;private int endIndex;private String path;/*** @param path* 下載文件在服務器上的路徑* @param threadId* 線程id* @param startIndex* 線程下載的開始位置* @param endIndex* 線程下載的結束位置*/public DownloadThread(String path, int threadId, int startIndex,int endIndex) {this.path = path;this.threadId = threadId;this.startIndex = startIndex;this.endIndex = endIndex;}@Overridepublic void run() {try {URL url = new URL(path);HttpURLConnection conn = (HttpURLConnection) url.openConnection();conn.setRequestMethod("GET");// 重要:請求服務器下載部分的文件 指定文件的位置conn.setRequestProperty("Range", "bytes=" + startIndex + "-"+ endIndex);conn.setConnectTimeout(5000);// 從服務器請求全部資源的狀態碼200 ok 如果從服務器請求部分資源的狀態碼206 okint code = conn.getResponseCode();System.out.println("---code---" + code);InputStream is = conn.getInputStream();// 已經設置了請求的位置,返回的是當前位置對應的文件的輸入流RandomAccessFile raf = new RandomAccessFile("yunpan.exe", "rwd");// 隨機寫文件的時候從哪個位置開始寫raf.seek(startIndex);// 定位文件int len = 0;byte[] buffer = new byte[1024];while ((len = is.read(buffer)) != -1) {raf.write(buffer, 0, len);}is.close();raf.close();System.out.println("線程" + threadId + ":下載完畢了!");} catch (Exception e) {e.printStackTrace();}}}}公眾號:非著名程序員(smart_android) 歡迎大家關注,每天一篇原創技術文章。
總結
以上是生活随笔為你收集整理的多线程系列之学习多线程下载的基本原理和基本用法(1)的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Android Widget 中List
- 下一篇: 系统变量file.encoding对Ja