在单独的线程上重用连接答案

【问题标题】：reuse connection on separate threads在单独的线程上重用连接
【发布时间】：2013-11-14 02:56:00
【问题描述】：

我需要收听一个开放的 API，根据正确的数据我需要下载一些文件并进行处理。我使用计时器每隔 x 秒自动发出一个下载请求，以保持连接处于活动状态，因此可以重复使用。

一共有3个组件：

父类
监听类
定时器

父类在一个单独的线程上产生监听器，并且还启动定时器。计时器和侦听器都调用父级的委托。

问题在于，每次从计时器下载时，连接都会被重用（从下载时间可以看出），但是当侦听器调用相同的连接时，它不是。

基本代码：

using Timer = System.Timers.Timer;

namespace Hallelujah
{
    public delegate void downloadData(bool process, string url);
    public delegate void downloadDataInvoker(bool process, string url);

class Listener2
{
    downloadData _downloadData;
    public void start(string storeID, string shoes)
    {
        ServicePointManager.DefaultConnectionLimit = 500;
        ServicePointManager.Expect100Continue = false;
        ServicePointManager.MaxServicePoints = 0;

        _downloadData += new downloadData(downloadDataCb);

        Timer timer = new Timer(10000);
        timer.Elapsed += timer_Elapsed;
        timer.Enabled = true;

        Listen listenTool = new Listen();
        listenTool._downloadData += new downloadDataInvoker(invoker);

        Thread thread = new Thread(new ParameterizedThreadStart(listenTool.init));
        string[] str = { params };
        thread.Start(str);

        F1.updateStatus(System.Threading.Thread.CurrentThread.ManagedThreadId.ToString());
    }

    void timer_Elapsed(object sender, ElapsedEventArgs e)
    {
        _downloadData.Invoke(false, "example.com");
    }

    public void invoker(bool process, string url)
    {
        _downloadData.Invoke(process, url);
    }
    public void downloadDataCb(bool process, string url)
    {
        F1.updateStatus(System.Threading.Thread.CurrentThread.ManagedThreadId.ToString());
        HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
        req.KeepAlive = true;
        req.ProtocolVersion = HttpVersion.Version10;
        req.UnsafeAuthenticatedConnectionSharing = true;
        req.Pipelined = true;
        WebResponse res = req.GetResponse();
        Stream sr = res.GetResponseStream();
        //Reading response
        if (process)
        {
            F1.updateStatus("Downloaded  in " + t1.Seconds + " s " + t1.Milliseconds + "ms ");
        }
        else
            F1.updateStatus("Downloaded NULL(from timer) in " + t1.Seconds + " s " + t1.Milliseconds + "ms ");
    }

    public void updateStatusCB(string status)
    {
        F1.updateStatus(status);
    }

}
internal class Listen
{
    public downloadDataInvoker _downloadDataInvoker;
    public updateStatus _updateStatus;
    public bool ToListen = true;

    public void init(object objpass)
    {
        _updateStatus.Invoke(System.Threading.Thread.CurrentThread.ManagedThreadId.ToString());

         while(ToListen){
            //When a match is found
            _downloadDataInvoker.Invoke(true, media_url);
        }


    }
}

知道为什么会这样吗？

【问题讨论】：

我已经编辑了你的标题。请参阅“Should questions include “tags” in their titles?”，其中的共识是“不，他们不应该”。
谢谢！向成为更好的网民迈进！

标签： c# multithreading http timer keep-alive

【解决方案1】：

您在调用计时器事件时创建一个新的保活请求。

根据您的需要，有很多下载任务（通过user_id？），您可以为每个任务创建一个keep-alive请求，并开始异步请求，在回调事件中调用更新委托。

【讨论】：