[C#]多线程下载

发现电脑里以前编写的下载程序。。。

做个记录，那时做的挺匆忙的，没用委托，通过公开出窗体来修改下载进度，做的比较乱... ==!!

程序具体功能（流程）：

1.检测系统托盘图标内的进程名是否符合要求 （xp时可以，win7部分机器可以，该功能无意义）

2.抓取页面，进行正则匹配下载的文件地址（可以改成自己想要的任何情况）

3.开多线程下载（建立多个文件）

4.合并文件

5.下载完毕后，发送ipmsg

---下面是部分代码，个人认为有参考价值---

1.检测系统托盘图标内的进程名

#region P/Invoke

[DllImport("User32.dll", EntryPoint = "FindWindow")]
private static extern IntPtr FindWindow(string lpClassName, string lpWindowName);

[DllImport("User32.dll", EntryPoint = "FindWindowEx")]
private static extern IntPtr FindWindowEx(IntPtr hwndParent, IntPtr hwndChildAfter,
 string lpClassName, string lpWindowName);

//[DllImport("User32.dll", EntryPoint = "GetClientRect")]
//static extern bool GetClientRect(IntPtr hWnd, out RECT lpRect);

[DllImport("user32.dll", EntryPoint = "PostMessageA")]
private static extern int PostMessage(IntPtr hwnd, int wMsg, int wParam, int lParam);

#endregion

private void btnFind_Click(object sender, EventArgs e)
{
    SysTrayWnd.TrayItemData[] trayItems = SysTrayWnd.GetTrayWndDetail();
    this.dataGridView1.Columns.Clear();
    this.dataGridView1.Columns.Add("colTrayItemWinHandle", "窗口句柄");
    this.dataGridView1.Columns.Add("colTrayItemProcHandle", "进程句柄");
    this.dataGridView1.Columns.Add("colTrayItemPID", "进程ID");
    this.dataGridView1.Columns.Add("colTrayItemProcImagePath", "进程映象路径");
    this.dataGridView1.Columns.Add("colTrayItemIconTipText", "托盘图标提示内容");
    this.dataGridView1.Columns.Add("colTrayItemIconHandle", "托盘图标句柄");
    //this.dataGridView1.Columns.Add("colTrayItemIcon", "托盘图标");
    this.dataGridView1.Columns.Add(new DataGridViewImageColumn());
    this.dataGridView1.Columns[6].HeaderText = "托盘图标";
    this.dataGridView1.Columns[6].Name = "colTrayItemIcon";
    this.dataGridView1.Columns.Add("test", "test");

    this.dataGridView1.Rows.Add(trayItems.Length);
    int iRowIndex = 0;
    foreach (SysTrayWnd.TrayItemData trayItem in trayItems)
    {
    //窗口句柄  
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemWinHandle"].Value = trayItem.hWnd.ToString("X").ToUpper();
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemWinHandle"].ToolTipText = trayItem.hWnd.ToString();
    //进程句柄  
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemProcHandle"].Value = trayItem.hProcess.ToString("X").ToUpper();
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemProcHandle"].ToolTipText = trayItem.hProcess.ToString();
    //进程ID  
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemPID"].Value = trayItem.dwProcessID.ToString();
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemPID"].ToolTipText = trayItem.dwProcessID.ToString();
    //进程映象路径  
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemProcImagePath"].Value = trayItem.lpProcImagePath;
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemProcImagePath"].ToolTipText = trayItem.lpProcImagePath;
    //托盘图标提示内容  
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemIconTipText"].Value = trayItem.lpTrayToolTip;
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemIconTipText"].ToolTipText = trayItem.lpTrayToolTip;
    //托盘图标句柄  
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemIconHandle"].Value = trayItem.hIcon.ToString("X").ToUpper();
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemIconHandle"].ToolTipText = trayItem.hIcon.ToString();
    //托盘图标  ;
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemIcon"].ValueType = typeof(byte[]);
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemIcon"].Value = Icon.FromHandle(trayItem.hIcon);
    this.dataGridView1.Rows[iRowIndex].Cells["colTrayItemIconHandle"].ToolTipText = trayItem.hIcon.ToString();
    //test
    System.Diagnostics.Process p = System.Diagnostics.Process.GetProcessById(trayItem.dwProcessID);
    this.dataGridView1.Rows[iRowIndex].Cells["test"].Value = p.ProcessName;

    iRowIndex++;
    }

    doAboutHostCheck(trayItems);
}

private void doAboutHostCheck(SysTrayWnd.TrayItemData[] trayItems)
{

    foreach (SysTrayWnd.TrayItemData trayItem in trayItems)
    {
    System.Diagnostics.Process p = System.Diagnostics.Process.GetProcessById(trayItem.dwProcessID);
    if (hostCheckPName.Equals(p.ProcessName))
    {
        t.Stop();
        setFormValue("hostCheck错误发生，开始联网查找解决方案", null, null);
        doDownload();
        break;
    }
    }
}

2.抓取页面，进行正则匹配下载的文件地址

3.开多线程下载（建立多个文件）

4.合并文件

// 变量定义
private Thread thread1 = null;
public string downFolder = @"\10.164.2.44software
orton";
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 = 10000;

    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 - 1)];
    // 开始多线程下载
    multiThreadDownLoad MTDL = new multiThreadDownLoad();
    MTDL.doDownLoadFile(item.Value, fileName, this);
    // 只下载第一个
    break;
    }
}

// 开始多线程下载类
public class multiThreadDownLoad
{
// 文件总大小
public static long showAllBytes = 0;
// 线程个数
public static int threadCount = 10;
// 线程状态
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 = 0;
// 下载停止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 = 1;
    threadCount = int.TryParse(frm.txtThreads.Text, out thCount) ? thCount : 1;
    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("已经存在文件", 100, 100);
    }
    else
    {
        // 文件不存在，创建临时目录
        if (!Directory.Exists(tmpFolder0))
        {
        Directory.CreateDirectory(tmpFolder0);
        }
        // 计算每个线程的目标下载量与下载开始位置
        long eachBytes = totalBytes / threadCount;
        long startPos = 0;
        for (int i = 0; i < threadCount; i++)
        {
        if (threadCount != (i + 1))
        {
            // 普通线程对象
            oneThLst.Add(new oneThread(eachBytes * i, eachBytes - 1, new string[] { tmpFolder0, i.ToString(), url }));
        }
        else
        {
            // 最后一个线程对象
            oneThLst.Add(new oneThread(eachBytes * i, eachBytes + (int)(totalBytes % threadCount) - 1, new string[] { tmpFolder0, i.ToString(), url }));
        }
        // 加入线程列表，并启动下载
        threadLst.Add(new Thread(new ThreadStart(oneThLst[i].doDownloadThread)));
        threadSts.Add(false);
        }

        for (int i = 0; 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("已经停止", 100, 100);
        }
        // 下载结束时
        else
        {
        if (!File.Exists(finalFile))
        {
            frm.setFormValue("开始合并文件", 100, 100);
            File.Copy(tempFloder + "tmp0", finalFile);
            File.Delete(tempFloder + "tmp0");
            FileStream AddStream = new FileStream(finalFile, FileMode.Append);
            BinaryWriter AddWriter = new BinaryWriter(AddStream);
            for (int i = 1; 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("下载完成", 100, 100);
            // 启动ipmsg发送消息
            Thread thIpmsg = new Thread(new ThreadStart(sendIpmsg));
            thIpmsg.IsBackground = true;
            thIpmsg.Start();
        }
        }
    }
    else
    {
        Thread.Sleep(1000);
    }
    } 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)[0];
        i = ((string[])getList)[1];
        url = ((string[])getList)[2];
    }

    // 下载方法
    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 = 0;
            byte[] by = new byte[1024];
            int osize = st.Read(by, 0, (int)by.Length);
            while (osize > 0 && !constant.stopDL)
            {
            totalDownloadedByte = osize + totalDownloadedByte;
            so.Write(by, 0, osize);
            osize = st.Read(by, 0, (int)by.Length);
            // 更新总下载进度
            multiThreadDownLoad.currentDownloaded += osize;
            multiThreadDownLoad.frm.setFormValue("下载文件：" + multiThreadDownLoad.currentDownloaded / 1024 + "/" + multiThreadDownLoad.showAllBytes / 1024, (int)(multiThreadDownLoad.currentDownloaded / 1024), (int)(multiThreadDownLoad.showAllBytes / 1024));
            }
            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;
        }
    }
}

5.下载完毕后，发送ipmsg

// 发送ipmsg方法入口
public void sendIpmsg() {
    // 配置文件读取目标ip
    string[] ipList = ConfigurationManager.AppSettings["ipList"].Split(',');
    for (int i = 0; i < ipList.Length; i++)
    {
    UdpClient client = new UdpClient(1988);
    IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse(ipList[i]), 2425);
    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(1000);
    client.Close();
    client = null;
    }

}

6.一般服务器只允许开启2个线程进行下载

需在配置文件里使用下面配置

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

 ----

CSND参考代码下载：

http://download.csdn.net/detail/wangxsh42/8346859