[C#]多线程下载

// 变量定义
private Thread thread1 = null;
public string downFolder = @"\\10.164.2.44\software\norton\";
public string webUrl = "http://www.symantec.com/security_response/definitions/download/detail.jsp?gid=savce";
public string regPatten = "http://definitions.symantec.com/([^\"]*)v([^\"]*)32.exe"; // 下载参数初期化
private void btnStart_Click(object sender, EventArgs e)
{
// 多线程下载停止flg
constant.stopDL = false;
// 从画面读取参数
webUrl = txtUrl.Text;
regPatten = txtReg.Text;
downFolder = txtFolder.Text.EndsWith("\\") ? txtFolder.Text : txtFolder.Text+"\\";
gapTime = long.Parse(txtGap.Text); t1.Tick += new EventHandler(t1_Tick);
t1.Interval = ; t.Interval = (int)gapTime;
// 定义线程
thread1 = new Thread(new ThreadStart(doDownLoadThread));
t.Tick += new EventHandler(t_Tick);
t.Start();
t_Tick(null, new EventArgs());
// 可以直接调用 doDownload 方法
} // 下载方法入口
// 使用WebBrowser控件打开页面
private void doDownload()
{
string url = webUrl;
WebBrowser wb = new WebBrowser();
// 忽略js脚本错误
wb.ScriptErrorsSuppressed = true;
// 打开网页
wb.Navigate(url);
setFormValue("正在打开网页", null, null);
// 页面加载完了事件绑定
wb.DocumentCompleted += new WebBrowserDocumentCompletedEventHandler(wb_DocumentCompleted);
} // WebBrowser控件页面加载完了事件
void wb_DocumentCompleted(object sender, WebBrowserDocumentCompletedEventArgs e)
{
constant.innerHtml = ((WebBrowser)sender).Document.Body.InnerHtml;
thread1.Start();
} // 下载主线程
public void doDownLoadThread()
{
setFormValue("打开完成，开始查找文件地址", null, null);
// 正则匹配
MatchCollection mts = Regex.Matches(constant.innerHtml, regPatten, RegexOptions.Multiline | RegexOptions.IgnoreCase);
// 一般一个，可以不用循环，判断一下是否有就行了
foreach (Match item in mts)
{
setFormValue("下载文件：" + item.Value, null, null);
string fileName = item.Value.Split('/')[(item.Value.Split('/').Length - )];
// 开始多线程下载
multiThreadDownLoad MTDL = new multiThreadDownLoad();
MTDL.doDownLoadFile(item.Value, fileName, this);
// 只下载第一个
break;
}
} // 开始多线程下载类
public class multiThreadDownLoad
{
// 文件总大小
public static long showAllBytes = ;
// 线程个数
public static int threadCount = ;
// 线程状态
public static List<bool> threadSts = new List<bool>();
// 线程池
public static List<Thread> threadLst = new List<Thread>();
private List<oneThread> oneThLst = new List<oneThread>();
public static List<long[]> threadStEnLst = new List<long[]>();
// 下载进度
public static long currentDownloaded = ;
// 下载停止flg
public static bool stopDownloadFlg = false;
// 临时文件夹路径
public static string tmpFolder = @"hostcheckTmp\";
// 最终文件路径
public static string finalFile = ""; public static string tempFloder = "";
// winform窗体
public static Form1 frm; // 多线程下载入口
public bool doDownLoadFile(string url, string name, Form1 frm1)
{
// 初期化数据
bool result = true;
frm = frm1;
int thCount = ;
threadCount = int.TryParse(frm.txtThreads.Text, out thCount) ? thCount : ;
finalFile = frm1.downFolder + name;
string mainFolder = frm1.downFolder.EndsWith("\\") ? frm1.downFolder : frm1.downFolder + "\\";
string tmpFolder0 = mainFolder + tmpFolder;
tempFloder = tmpFolder0;
try
{
// 获取文件总大小
System.Net.HttpWebRequest Myrq = (System.Net.HttpWebRequest)System.Net.HttpWebRequest.Create(url);
System.Net.HttpWebResponse myrp = (System.Net.HttpWebResponse)Myrq.GetResponse();
long totalBytes = myrp.ContentLength;
Myrq.Abort();
showAllBytes = totalBytes;
// 判断文件是否存在，并处理
if (File.Exists(frm1.downFolder + name))
{
frm1.setFormValue("已经存在文件", , );
}
else
{
// 文件不存在，创建临时目录
if (!Directory.Exists(tmpFolder0))
{
Directory.CreateDirectory(tmpFolder0);
}
// 计算每个线程的目标下载量与下载开始位置
long eachBytes = totalBytes / threadCount;
long startPos = ;
for (int i = ; i < threadCount; i++)
{
if (threadCount != (i + ))
{
// 普通线程对象
oneThLst.Add(new oneThread(eachBytes * i, eachBytes - , new string[] { tmpFolder0, i.ToString(), url }));
}
else
{
// 最后一个线程对象
oneThLst.Add(new oneThread(eachBytes * i, eachBytes + (int)(totalBytes % threadCount) - , new string[] { tmpFolder0, i.ToString(), url }));
}
// 加入线程列表，并启动下载
threadLst.Add(new Thread(new ThreadStart(oneThLst[i].doDownloadThread)));
threadSts.Add(false);
} for (int i = ; i < threadLst.Count; i++)
{
// 后台运行
threadLst[i].IsBackground = true;
threadLst[i].Start();
}
// 开启合并线程的监控
Thread combThread = new Thread(new ThreadStart(combFiles));
combThread.IsBackground = true;
combThread.Start();
}
}
catch (Exception e)
{
result = false;
}
return result;
} // 合并文件
public void combFiles()
{
// 检查线程状态
bool alive = false;
do
{
alive = false;
foreach (bool sts in threadSts)
{
if (!sts) { alive = true; }
}
if (!alive)
{
// 人为停止时
if (constant.stopDL)
{
try
{
Directory.Delete(tempFloder, false);
}
catch (Exception) { }
frm.setFormValue("已经停止", , );
}
// 下载结束时
else
{
if (!File.Exists(finalFile))
{
frm.setFormValue("开始合并文件", , );
File.Copy(tempFloder + "tmp0", finalFile);
File.Delete(tempFloder + "tmp0");
FileStream AddStream = new FileStream(finalFile, FileMode.Append);
BinaryWriter AddWriter = new BinaryWriter(AddStream);
for (int i = ; i < threadLst.Count; i++)
{
FileStream TempStream = new FileStream(tempFloder + "tmp" + i.ToString(), FileMode.Open);
BinaryReader TempReader = new BinaryReader(TempStream);
AddWriter.Write(TempReader.ReadBytes((int)TempStream.Length));
TempReader.Close();
TempStream.Close();
File.Delete(tempFloder + "tmp" + i.ToString());
}
AddWriter.Close();
AddStream.Close();
Directory.Delete(tempFloder, false); frm.setFormValue("下载完成", , );
// 启动ipmsg发送消息
Thread thIpmsg = new Thread(new ThreadStart(sendIpmsg));
thIpmsg.IsBackground = true;
thIpmsg.Start();
}
}
}
else
{
Thread.Sleep();
}
} while (alive || constant.stopDL);
} // 下载线程类 class oneThread
{
// 需要下载的文件地址，开始位置，数据量，临时目录等
public long startPosP;
public long eachBytesP;
//new string[]{tmpFolder0,i.ToString(),url,threadStEnLst[i][0].ToString(),threadStEnLst[i][1].ToString() public string tmpFolder0;
public string i;
public string url;
public long allByte; // 构造函数，初期化变量
public oneThread(long startPos, long eachBytes, object getList)
{
startPosP = startPos;
allByte = eachBytes;
tmpFolder0 = ((string[])getList)[];
i = ((string[])getList)[];
url = ((string[])getList)[];
} // 下载方法
public void doDownloadThread()
{
try
{
if (!File.Exists(tmpFolder0 + "tmp" + i.ToString()))
{
// 创建文件
System.IO.Stream so = new System.IO.FileStream(tmpFolder0 + "tmp" + i.ToString(), System.IO.FileMode.Create);
// 创建网络链接
System.Net.HttpWebRequest Myrq = (System.Net.HttpWebRequest)System.Net.HttpWebRequest.Create(url);
// 设置数据接收开始位置，结束位置
Myrq.AddRange((int)startPosP, (int)(startPosP + allByte));
// 以1024byte为单位读取下载
System.IO.Stream st = ((System.Net.HttpWebResponse)Myrq.GetResponse()).GetResponseStream();
long totalBytes = ((System.Net.HttpWebResponse)Myrq.GetResponse()).ContentLength;
long totalDownloadedByte = ;
byte[] by = new byte[];
int osize = st.Read(by, , (int)by.Length);
while (osize > && !constant.stopDL)
{
totalDownloadedByte = osize + totalDownloadedByte;
so.Write(by, , osize);
osize = st.Read(by, , (int)by.Length);
// 更新总下载进度
multiThreadDownLoad.currentDownloaded += osize;
multiThreadDownLoad.frm.setFormValue("下载文件：" + multiThreadDownLoad.currentDownloaded / + "/" + multiThreadDownLoad.showAllBytes / , (int)(multiThreadDownLoad.currentDownloaded / ), (int)(multiThreadDownLoad.showAllBytes / ));
}
so.Close();
st.Close();
Myrq.Abort();
if (constant.stopDL) {
File.Delete(tmpFolder0 + "tmp" + i.ToString());
}
multiThreadDownLoad.threadSts[int.Parse(i)] = true;
}
}
catch (Exception e)
{
multiThreadDownLoad.threadSts[int.Parse(i)] = true;
}
}
}

// 发送ipmsg方法入口
public void sendIpmsg() {
// 配置文件读取目标ip
string[] ipList = ConfigurationManager.AppSettings["ipList"].Split(',');
for (int i = ; i < ipList.Length; i++)
{
UdpClient client = new UdpClient();
IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse(ipList[i]), );
byte[] bytes = Encoding.Default.GetBytes(string.Concat(new object[] { "1:", DateTime.Now.Ticks, ":", "HostCheck", ":", "HostCheck", ":", 0x20, ":", "downloadComplete[" + finalFile + "]" }));
client.Send(bytes, bytes.Length, endPoint);
Thread.Sleep();
client.Close();
client = null;
} }

<system.net>
<connectionManagement>
<add address="*" maxconnection="最大连接数"/>
</connectionManagement>
</system.net>