带有webrequests c的多线程程序

本文关键字：多线程 程序 webrequests 带有 | 更新日期: 2023-09-27 18:24:42

我想制作多线程异步下载管理器。但是我在多线程方面有问题。一个线程可以正常工作，但当我创建第二个线程时，什么也不工作。我认为这是网络请求同步的问题。我在c#中读到了这个答案——多线程处理了大量的web请求，但我并没有完全理解。现在的问题是：如何修改代码以使用多线程（Thread，Threadpool）。

类别DownloadableContent:

{
    private string url { get; set; }
    private string path { get; set; }
    private Stream streamResponse { get; set; }
    private Stream streamLocal { get; set; }
    private HttpWebRequest webRequest { get; set; }
    private HttpWebResponse webResponse { get; set; }
    public DownloadableContent(string url, string path)
    {
        this.url = url;
        this.path = path;
    }
    public void Download()
    {
        using (WebClient wcDownload = new WebClient())
        {
            try
            {
                webRequest = (HttpWebRequest)WebRequest.Create(url);                 
                webRequest.Credentials = CredentialCache.DefaultCredentials;
                webResponse = (HttpWebResponse)webRequest.GetResponse();
                Int64 fileSize = webResponse.ContentLength;
                streamResponse = wcDownload.OpenRead(url);
                streamLocal = new FileStream(path, FileMode.Create, FileAccess.Write, FileShare.None);
                byte[] downBuffer = new byte[2048];     
                int bytesSize = 0;
                while ((bytesSize = streamResponse.Read(downBuffer, 0, downBuffer.Length)) > 0)
                {
                    streamLocal.Write(downBuffer, 0, bytesSize);
                }
            }
            finally
            {
                streamResponse.Close();
                streamLocal.Close();
            }
        }
    }       
}

和类别main:

DownloadableContent file = new DownloadableContent("url", @"path");  
Thread thread = new Thread(file.Download);
thread.Start();

带有webrequests c的多线程程序

我能给你的最好建议是使用TPL。这是一个从微软到管理线程的好库。我在代码中也用过这个来解决类似的问题，基本上我必须下载8000个url，一开始正常的过程需要30分钟。在我使用这个库之后，同样的过程在30秒内完成。

TPL链接

任务并行库

请看一下示例：

BookStore-GitHub

阅读异步编程是值得的那就看看这个http://msdn.microsoft.com/en-us/library/System.Net.WebClient_methods（v=vs.110）.aspx你们有异步下载东西的方法。还要看一下TPL并避免线程http://msdn.microsoft.com/en-us/library/dd460717（v=vs.110）.aspx

也许多读一点书可以帮助你避免很多头痛。

这是一个简单的示例

private static void Main(string[] args)
{
    var urlsAndPaths = new Dictionary<string, string>();
    urlsAndPaths.Add("http://i.forbesimg.com/media/lists/people/lionel-messi_416x416.jpg","messi.jpg");
    urlsAndPaths.Add("http://sizzlingsuperstars.com/wp-content/uploads/2014/07/Cristiano-Ronaldo-2-480x309.jpg", "cristiano.jpg");            
    foreach (var kvp in urlsAndPaths)
    {
        var wc = new WebClient();
        wc.DownloadFileAsync(new Uri(kvp.Key),kvp.Value);
    }
    Console.ReadKey();
}

根据您使用的.NET框架的版本，您可以利用Task类。你可以做一些类似的事情

    foreach (var uri in myCollection)
    {
        Task.Factory.StartNew(() =>
        {
            try
            {
                using (System.Net.WebClient client = new System.Net.WebClient())
                {
                    client.DownloadFileCompleted += (o, args) =>
                    {
                        //Do something with the download
                    };
                    client.DownloadFileAsync(uri);
                }
            }
            catch (Exception ex)
            {
                //Do something
            }
        });
    }

您使用.NET 4.5吗？实现这一点的"新方法"是使用Task.WhenAll，它可以异步和并行地进行下载，但允许框架决定是否/何时将工作调度到线程池。

var client = new System.Net.WebClient();
await Task.WhenAll(urls.Select(url => {
    var path = ?? // build local path based on url?
    return client.DownloadFileAsync(url, path);
});
相关文章：