c# - Web请求突然停止工作

标签 c# multithreading webrequest

HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(baseurl + url);
req.Timeout = 1000 * 10;
HttpWebResponse response = (HttpWebResponse)req.GetResponse();
Stream str = response.GetResponseStream();
HtmlAgilityPack.HtmlDocument doc = new HtmlAgilityPack.HtmlDocument();
doc.Load(str);
response.Close();
string imgurl = doc.DocumentNode.SelectSingleNode("//div[@class='one-page']/a/img[@class='manga-page']").Attributes["src"].Value;
req = (HttpWebRequest)HttpWebRequest.Create(imgurl);
req.Timeout = 1000 * 10;
response = (HttpWebResponse)req.GetResponse();
str = response.GetResponseStream();
Image img = Image.FromStream(str);
response.Close();
return img;

我在一个循环中运行这段代码(使用多个线程)来下载大约 4000 个图像,它在前数百个图像中工作得非常出色,但随后(在每次尝试的不同时间点)它突然停止工作,并且每次调用“req.GetResponse()”都会导致 TimeoutException。我不知道为什么会发生这种情况,也不知道可能出了什么问题或如何处理。任何帮助将不胜感激。

我用来运行此函数的代码(称为 GetPage(int) 并称为 c.GetPage(t))如下:

for (int j = 0; j < 2; j++)
{
    BackgroundWorker bw = new BackgroundWorker();
    num[bw] = j;
    bgs.Add(bw);
    bw.DoWork += (object sender, DoWorkEventArgs doargs) =>
    {
        int t = -1;
        lock (lockObjForQueueOperations)
        {
            if (images.Count != 0)
                t = images.Dequeue();
        }
        if(t < 0)
        {
            doargs.Result = false;
            return;
        }
        currently[sender] = t;
        Image img;
        try { img = c.GetPage(t); }
        catch (Exception e)
        {
            lock (lockObjForQueueOperations)
            {
                images.Enqueue(t);
            }
            lock (Console.Title)
            {
                if (num[sender] == 0) Console.ForegroundColor = ConsoleColor.Cyan;
                else if (num[sender] == 1) Console.ForegroundColor = ConsoleColor.Yellow;
                Console.WriteLine("**ERR: Error fetshing page {0}, errormsg: {1}", t, e.Message);
                Console.ForegroundColor = ConsoleColor.White;
            }
            doargs.Result = true;
            Thread.Sleep(1000*2);
            return;
        }
        lock (Console.Title)
        {
            if (num[sender] == 0) Console.ForegroundColor = ConsoleColor.Cyan;
            else if (num[sender] == 1) Console.ForegroundColor = ConsoleColor.Yellow;
            Console.WriteLine("\t\tLoaded page {0} of {1}.", t + 1, c.PagesCount);
            Console.ForegroundColor = ConsoleColor.White;
        }
        string imgpath = Path.Combine(ndir, "Page " + (t + 1) + ".png");
        img.Save(imgpath, System.Drawing.Imaging.ImageFormat.Png);
        img.Dispose();
        doargs.Result = true;
    };
    bw.RunWorkerCompleted += (object sender, RunWorkerCompletedEventArgs runargs) =>
    {
        if ((bool)runargs.Result) bw.RunWorkerAsync();
        else
        {
            finnishedworkers++;
            if (finnishedworkers == 2) restetter.Set();
            bw.Dispose();
        }
    };
    bw.RunWorkerAsync();
}

最佳答案

HttpWebRequest 中的 Timeout 属性以毫秒为单位。目前将其设置为 10,000 只需 10 秒,根据带宽、提取的数据大小以及正在运行的代码的复杂性,这可能还不够。我说先尝试增加它。

关于c# - Web请求突然停止工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/2292675/

相关文章:

c# - 在 C# 中检查网站可用性

c# - 为什么垃圾收集器只有 3 代,不多也不少?

c# - e.cancel = true 后后台worker不会运行 "RunWorkerCompleted";

java - 执行器服务完整初始化保证

javascript - 事件监听器函数中的 chrome.webrequest

c# - 使用 GetResponseStream 和 SpreadsheetDocument.Open 读取 xls 流

c# - 将 EF CodeFirst 基类转换为继承类(使用 table-per-type)

c# - 如何在 C# 中将用户定义的表类型作为存储过程参数传递

c# - 在 C# 中快速动态模糊搜索 100k+ 字符串

python - Tornado 与 ThreadPoolExecutor