基于java多線程的下載器源碼剖析(編輯修改稿)
2025-07-20 15:46 本頁面
【文章內(nèi)容簡介】 0。()。 } //下載第二個文件 Stringurl2= StringsaveFile2=data/Tmsvm參考文檔().rar。 try{ (newURL(url2))。 (newFile(saveFile2))。 (newInteger(5))。 (newInteger(6))。 //將第二個下載加入到下載列表中 (newDownload(config,()))。 }catch(MalformedURLExceptione){ //TODOAutogeneratedcatchblock ()。 }1. 系統(tǒng)初始化首先來看這一行行：[java]view plainHYPERLINK copy Downloaderdownloader=()。Downloader是這個下載器的總調(diào)度師，一山不容二虎，當(dāng)然在系統(tǒng)運行過程中，只能有一個Downloader的實例，因此我們需要用單例模式來保證這一點。首先要取得downloader實例，即系統(tǒng)的初始化。我們看系統(tǒng)初始化需要做什么？[java]view plainHYPERLINK copy publicstaticDownloadergetInstance(){ if(downloader==null) downloader=newDownloader(newDownloaderConfig())。 returndownloader。 } privateDownloader(DownloaderConfigconfig){ super()。 =config。 start()。 }上面的代碼中的start()函數(shù)中到底做了什么呢？ 初始化blockCache緩存，其中blockCache為ConcurrentLinkedQueueDownloadBlock類型。 啟動守護(hù)進(jìn)程DownloadDeamon具體代碼如下：[java]view plainHYPERLINK copy privatevoidstart(){ blockCache=newConcurrentLinkedQueueDownloadBlock()。//初始化緩存 downloads=newDownloadList()。 deamon=newThread(newDownloadDeamon(downloads))。//初始化守護(hù)進(jìn)程 (true)。 ()。 timer=newTimer(,true)。 }上面代碼中啟動了一個守護(hù)進(jìn)程。那么這個守護(hù)進(jìn)程在啟動的時候在做什么事情呢？我們來看一下他的run()函數(shù)[java]view plainHYPERLINK copy publicvoidrun(){ (Createthreadpool)。 threadPool=()。//初始化線程池 DownloadBlockblock。 while(true){ block=getDownloadBlock()。//不斷從當(dāng)前系統(tǒng)中獲取待下載的DownloadBlock if(block!=null){ (Createnewdownloadthreadfor+block)。 //啟動線程執(zhí)行下載 (newDownloadThread(block))。 //將當(dāng)前Block從其所在的Download中移除 ().removeDownloadBlock(block)。 } try{ spanstyle=whitespace:pre/span(1000)。 }catch(InterruptedExceptione){ spanstyle=whitespace:pre/span//TODOAutogeneratedcatchblock spanstyle=whitespace:pre/span(Downloaddeamonstopedbyuser)。 spanstyle=whitespace:pre/spanbreak。 } } }守護(hù)進(jìn)程所做的事情就是不斷獲取將要進(jìn)行下載的Block，然后啟動線程去進(jìn)行下載。來看一下獲取Block的策略：這里不斷的從當(dāng)前下載列表中獲取所有的Download，然后從里面選取最需要下載的文件，“最需要下載”定義為剩余的待下載量最多。其具體的代碼看下方：[java]view plainHYPERLINK copy privateDownloadBlockgetDownloadBlock(){ downs=()。 if(downs==null||==0) returnnull。 Downloaddownload=downs[0]。 for(Downloaddown:downs){//找最需要下載的Download進(jìn)行下載if(()()) download=down。 } ()。 ()。 }2. 新建下載上面講解的是系統(tǒng)初始化所做的事情。那么當(dāng)我們把開始下載一個文件時系統(tǒng)是怎么運行的呢？[java]view plainHYPERLINK copy //下載第一個文件 Stringurl1= StringsaveFile1=data/。 DownloadConfigconfig=newDownloadConfig()。 try{ (newURL(url1))。 (newFile(saveFile1))。 (newInteger(5))。 (newInteger(6))。 //將第一個下載加入到下載列表中 (newDownload(config,()))。 }catch(MalformedURLExceptione){ //TODOAutogeneratedcatchblock ()。 }我們重點來看這一句：[java]view plainHYPERLINK copy //將第一個下載加入到下載列表中 (newDownload(config,()))。addDownload的定義如下[java]view plainHYPERLINK copy publicbooleanaddDownload(Downloaddownload){ newThread(download).start()。 return(download)。 }這段代碼做了兩件事情： 為Download啟動一下線程。Download線程所做的事情就是把當(dāng)前的文件根據(jù)線程數(shù)目進(jìn)行切分。 把當(dāng)前Download加入到DownloadList中。OK，我們看看，Download是切分文件時是如何與整個系統(tǒng)聯(lián)系在一起。[java]view plainHYPERLINK copy publicvoidrun(){ try{ begin=()。1
范文總結(jié)相關(guān)推薦
鄂ICP備17016276號-1