TcpListener排队连接的速度比我清除连接的速度快

据我所知, TcpListener 调用后将对连接进行排队 Start() . 每次你打电话 AcceptTcpClient (或) BeginAcceptTcpClient ,它将从队列中取出一个项目。

如果我们加载测试 TCplistener公司 应用程序通过一次发送1000个连接,队列的生成速度远远快于我们清除它的速度,导致(最终)客户端超时,因为它没有得到响应,因为它的连接仍在队列中。然而,服务器似乎没有承受太大的压力,我们的应用程序没有消耗太多的CPU时间,机器上的其他监控资源也没有出一点差错。感觉我们现在的效率不够。

我们在打电话 BeginAcceptTcpListener 然后马上交给 ThreadPool 线程来实际执行工作,然后调用 beginacepttcpclient开始 再一次。所涉及的工作似乎没有给机器带来任何压力,基本上只是3秒钟的睡眠,然后是字典查找,然后是100字节的写入 TcpClient 的流。

这是 TCplistener公司 我们使用的代码:

    // Thread signal.
    private static ManualResetEvent tcpClientConnected = new ManualResetEvent(false);

    public void DoBeginAcceptTcpClient(TcpListener listener)
    {
        // Set the event to nonsignaled state.
        tcpClientConnected.Reset();

        listener.BeginAcceptTcpClient(
            new AsyncCallback(DoAcceptTcpClientCallback),
            listener);

        // Wait for signal
        tcpClientConnected.WaitOne();
    }

    public void DoAcceptTcpClientCallback(IAsyncResult ar)
    {
        // Get the listener that handles the client request, and the TcpClient
        TcpListener listener = (TcpListener)ar.AsyncState;
        TcpClient client = listener.EndAcceptTcpClient(ar);

        if (inProduction)
            ThreadPool.QueueUserWorkItem(state => HandleTcpRequest(client, serverCertificate));  // With SSL
        else
            ThreadPool.QueueUserWorkItem(state => HandleTcpRequest(client));  // Without SSL

        // Signal the calling thread to continue.
        tcpClientConnected.Set();
    }

    public void Start()
    {
        currentHandledRequests = 0;
        tcpListener = new TcpListener(IPAddress.Any, 10000);
        try
        {
            tcpListener.Start();

            while (true)
                DoBeginAcceptTcpClient(tcpListener);
        }
        catch (SocketException)
        {
            // The TcpListener is shutting down, exit gracefully
            CheckBuffer();
            return;
        }
    }

我想答案与使用 Sockets 而不是 TCplistener公司 ,或至少使用 TcpListener.AcceptSocket ,但我想知道我们该怎么做?

我们的一个想法是打电话 接受客户 立即 Enqueue 这个 TCP客户端 成倍数之一 Queue<TcpClient> 物体。这样,我们就可以在不同的线程(每个线程一个队列)上轮询这些队列,而不必在等待其他线程时遇到可能阻塞线程的监视器 Dequeue 操作。然后,每个队列线程都可以使用 ThreadPool.QueueUserWorkItem 在一个 线程池 线程,然后进入下一个出列 TCP客户端 在队伍里。你是推荐这种方法,还是我们使用的问题 TCplistener公司 再多的快速排队也不能解决这个问题?