本文是參照博客園【CAP&船長】的Demo衍生出來的。
主要是C#通過HttpWebRequest類通過Http協議并調用多線程下載Web資源。
思路：
1、獲取文件的總大小
2、設置啟動的線程數目，并分配每個線程的下載的開始位置與下載的字節數大小
3、子線程下載成功后保存到臨時文件中
4、監聽所有文件是否全部下載成功
5、如果所有子線程均下載完成則根據現在Id拼接起來
6、刪除臨時文件
簡單封裝的類：
1、新建一個【CHttpDownload.cs】類
2、聲明必須的公共屬性與私有屬性以及變量
private int nThreadNum = 0; // 線程的個數 private string strUrl = ""; // 下載地址 private string strSavePath = ""; // 文件保存地址 private System.Threading.Thread[] threads = null; // 線程數組 private int[] nStartPosition = null; // 每個線程的開始地址 private int[] nFileSize = null; //每個線程下載的大小 private bool[] bThreadState = null; // 線程下載狀態 public bool bHasMerge { get; private set; } // 是否合并成功 public long lFileSizeAll { get; private set; } // 文件總大小 public int nBufferSize { get; set; } // 下載文件緩沖區大小 private int id = 0; // 標記線程Id、臨時變量 2、構造函數 /// <summary> /// 構造函數 /// </summary> /// <param name="strUrl">文件下載地址Url</param> /// <param name="nThreadNum">所需要的線程數</param> public CHttpDownload(string strUrl, int nThreadNum) {
/* 初始化下載地址、線程數、緩沖流大小 */ this.strUrl = strUrl; this.nThreadNum = nThreadNum; this.nBufferSize = 1024; Init(); } /// <summary> /// 初始化數據、設置每個線程的開始字節位置與字節大小 /// </summary> private void Init() { threads = new System.Threading.Thread[this.nThreadNum]; nStartPosition = new int[this.nThreadNum]; nFileSize = new int[this.nThreadNum]; bThreadState = new bool[this.nThreadNum]; bHasMerge = false;
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(this.strUrl); lFileSizeAll = request.GetResponse().ContentLength; // 獲取文件的總大小 request.Abort(); // 端口本次連接
int nFileNormalSize = (int)lFileSizeAll / nThreadNum; // 前面線程下載的大小，最后一個線程下載全部 int nFileLastSize = nFileNormalSize + (int)lFileSizeAll % nThreadNum; // 最后一個線程下載的大小
for (int i = 0; i < nThreadNum; i++) { bThreadState[i] = false; nStartPosition[i] = nFileNormalSize * i; if (i == nThreadNum - 1) { nFileSize[i] = nFileLastSize - 1; } else { nFileSize[i] = nFileNormalSize - 1; } } }
3、新建StartReceive方法，功能為啟動指定一個線程進行下載，并保存到臨時文件中 /// <summary> /// 多線程開始接收 /// </summary> private void StartReceive() { id++; int nId = id - 1; string strFileName = "C:\\\\" + nId + ".tmp"; byte[] buffer = new byte[nBufferSize]; int nReadSize = 0; // 標記本次讀到多少個數據
FileStream fs = new FileStream(strFileName, System.IO.FileMode.Create); Stream s = null; try { HttpWebRequest request = (HttpWebRequest)WebRequest.Create(this.strUrl); request.AddRange(nStartPosition[nId], nStartPosition[nId] + nFileSize[nId]); // 設置流的開始位置與結束位置 s = request.GetResponse().GetResponseStream(); nReadSize = s.Read(buffer, 0, nBufferSize); while (nReadSize > 0) { fs.Write(buffer, 0, nReadSize); nReadSize = s.Read(buffer, 0, nBufferSize); } fs.Close(); s.Close(); } catch (Exception ex) { } bThreadState[nId] = true; }
4、新建MergeFiles方法，功能為當所有線程完成下載后進行文件合并保存、并刪除臨時文件
/// <summary> /// 合并文件 /// </summary> private void MergeFiles() { while (true) // 驗證所有線程是否全部接收完畢 { bHasMerge = true; for (int i = 0; i < nThreadNum; i++) { if (bThreadState[i] == false) { bHasMerge = false; System.Threading.Thread.Sleep(100); break; } } if (bHasMerge == true) { break; } }
int nReadSize; byte[] bytes = new byte[nBufferSize]; FileStream fs = new FileStream(strSavePath, FileMode.Create); FileStream fsTmp = null; for (int i = 0; i < nThreadNum; i++) { fsTmp = new FileStream("C:\\\\" + i + ".tmp", FileMode.Open); while (true) { nReadSize = fsTmp.Read(bytes, 0, nBufferSize); if (nReadSize > 0) { fs.Write(bytes, 0, nReadSize); } else { break; } } fsTmp.Close(); if (File.Exists("C:\\\\" + i + ".tmp")) // 如果臨時文件存在則刪除 { File.Delete("C:\\\\" + i + ".tmp"); } } fs.Close(); }
5、新建StartDownload方法，為客戶調用多線程下載的方法 /// <summary> /// 開始下載文件 /// </summary> /// <param name="strSaveFile">文件的保存地址</param> public void StartDownload(string strSaveFile) { this.strSavePath = strSaveFile; for (int i = 0; i < nThreadNum; i++) { threads[i] = new System.Threading.Thread(new System.Threading.ThreadStart(StartReceive)); threads[i].Start(); } System.Threading.Thread t = new System.Threading.Thread(new System.Threading.ThreadStart(MergeFiles)); t.Start(); }
下載地址：http://www.msdn.top/documents/asp.net/HttpDownload.zip | 
QQ好友和群
QQ空間
騰訊微博
騰訊朋友
收藏
淘帖
頂
踩
