用過迅雷的同學都知道。迅雷有個功能叫做多線程。另一個叫離線下載,我們這里重點介紹一下多線程下載。多線程,顧名思義就是非常多歌線程同一時候在執行,為什么要提出多線程這個概念呢?由於有時候一個線程下載太慢了。舉個樣例,比方小時候常做的數學題,一個人挖溝須要15天,那么兩個人對着挖呢?
當然數學題上面兩個人的效率是不一樣的,我們這里把這個問題簡化了一下。僅僅是想大家明確,什么是多線程,為什么有多線程。在多線程上出現過一個問題,為什么有要提出多線程?事實上提出多線程是為了充分利用CPU的硬件資源,解決應用程序等待的問題。多線程是為了同步完畢多項任務,不是為了提高執行效率,而是為了提高資源使用效率來提高系統的效率。線程是在同一時間須要完畢多項任務的時候實現的。
2、思路
(1)獲取網絡連接
(2)初始化多線程下載信息,開始下載
(3)開辟硬盤空間,用於存放數據資源
(4)把從網絡獲取的數據放入申請的空間中
(5)完成下載,關閉資源鏈接
給出一個下載400M電影的示意圖,例如以下所看到的:

RandomAccessFile支持隨機的訪問
HTTP的Range頭字段指定每一個線程從文件的什么位置開始下載。
3、代碼解析
3.1 設置須要下載文件的信息
RandomAccessFile randOut = new RandomAccessFile(this.saveFile, "rwd");
if(this.fileSize>0){
randOut.setLength(this.fileSize);//設置文件的大小
}
randOut.close(); //關閉該文件,使設置生效
3.2 設置下載鏈接,而且開始划分下載部分
URL url = new URL(this.downloadUrl);
if(this.data.size() != this.threads.length){ //假設原先未曾下載或者原先的下載線程數與如今的線程數不一致
this.data.clear(); //將數據置空
for (int i = 0; i < this.threads.length; i++) { //遍歷線程池
this.data.put(i+1, 0);//初始化每條線程已經下載的數據長度為0
}
this.downloadedSize = 0; //設置已經下載的長度為0
}
3.3 開始下載文件
for (int i = 0; i < this.threads.length; i++) {
//通過特定的線程ID獲取該線程已經下載的數據長度
int downloadedLength = this.data.get(i+1);
//推斷線程是否已經完畢下載,否則繼續下載
if(downloadedLength < this.block && this.downloadedSize < this.fileSize){
//初始化特定id的線程
this.threads[i] = new DownloadThread(this, url, this.saveFile, this.block, this.data.get(i+1), i+1);
//設置線程的優先級,Thread.NORM_PRIORITY = 5 Thread.MIN_PRIORITY = 1 Thread.MAX_PRIORITY = 10
this.threads[i].setPriority(7);
//啟動線程
this.threads[i].start();
}else{
this.threads[i] = null; //表明在線程已經完畢下載任務
}
}
fileService.delete(this.downloadUrl); //假設存在下載記錄,刪除它們。然后又一次加入 fileService.save(this.downloadUrl, this.data); //把已經下載的實時數據寫入數據庫
boolean notFinished = true;//下載未完畢
// 循環推斷所有線程是否完畢下載
while (notFinished) {
notFinished = false;//假定所有線程下載完畢
for (int i = 0; i < this.threads.length; i++){
if (this.threads[i] != null && !this.threads[i].isFinished()) {//假設發現線程未完畢下載
notFinished = true;//設置標志為下載沒有完畢
//假設下載失敗,再又一次在已經下載的數據長度的基礎上下載
if(this.threads[i].getDownloadedLength() == -1){
//又一次開辟下載線程。代碼與上面一致
}
}
}
if(listener!=null){
listener.onDownloadSize(this.downloadedSize);
}//通知眼下已經下載完畢的數據長度
}
//下載完畢刪除記錄
if(downloadedSize == this.fileSize){
fileService.delete(this.downloadUrl);
}
4、斷點續傳
斷點續傳是說在下載的時候,我們由於某些原因,導致了下載的暫停。比方在電腦上,我們的電腦突然斷電了,手機上的網絡中斷了,都會導致當前的下載任務終止,那么當我們再次回來的時候。程序應該是能夠繼續下載的,不然前面下載的資源就都浪費了。
依據上面的描寫敘述。我們應該能夠知道。實現斷點續傳,關鍵是實現下載的數據存儲在數據庫中,等到之后我們程序再次進入的時候,會到數據庫中去查詢一下數據。然后接着繼續下載。
而存儲數據到數據庫並非太復雜,難的是怎樣識別程序的哪些數據被下載了。哪些數據是沒有下載的。這里,我們在下載的時候使用了下載的線程id做識別。
假設該線程id的數據沒有被完整下載。應該是不會存儲到數據庫的,那么這一部分的數據就要又一次下載,在下載完畢之后,數據拼接起來就是一個完整的文件了。
