c# - Socket.SendAsync 需要几秒钟才能完成

Question

我正在尝试优化一个 tcp 套接字包装器，它在处理大量入站连接时遇到了困难。我正在一个基本的聊天服务器和一个小型客户端应用程序中测试它以将客户端发送给它。这两个应用程序都位于通过千兆交换机连接的单独 W2k3 服务器上。

通过反复试验，我将我的测试细化为 10 个客户端以 100 毫秒的间隔连接，然后一旦所有 10 个客户端都连接后，它们各自向服务器发送一个“进入房间”消息，再次以 100 毫秒的间隔。当服务器收到一条消息时，它会用房间中每个人的列表回复发件人，并向房间中的其他人发送一条消息，说有新来者。

每次发送都需要超过 1 秒的时间才能完成(对于 100 多个客户端，这会达到 3-4 秒)，并且通过日志记录我已经确定延迟在 Socket.SendAync 和引发的相应事件之间。 CPU 使用率始终很低。

我已经尝试了所有我能想到的方法，并花了几天时间在网上寻找线索，但我完全不知所措。这不可能是正常的吧？

编辑:按要求编写代码。我已经整理了一下，删除了不相关的计数器和日志记录等，它目前在我尝试缩小问题范围时在 kludge 之上进行了 hack。

    private void DoSend(AsyncUserToken token, String msg)
    {
        SocketAsyncEventArgs writeEventArgs = new SocketAsyncEventArgs();
        writeEventArgs.Completed += ProcessSend;
        writeEventArgs.UserToken = token;
        Byte[] sendBuffer = Encoding.UTF8.GetBytes(msg + LineTerminator);
        writeEventArgs.SetBuffer(sendBuffer, 0, sendBuffer.Length);

        Interlocked.Add(ref m_totalBytesAttemptedSend, sendBuffer.Length);
        Logger2.log(Logger2.Debug5, token.ConnectionId, "Total Bytes attempted: " + m_totalBytesAttemptedSend);

        bool willRaiseEvent = true;
        try
        {
            willRaiseEvent = token.Socket.SendAsync(writeEventArgs);
        }
        catch (Exception e)
        {
            Logger2.log(Logger2.Debug2, token.ConnectionId, e.Message);
            writeEventArgs.Dispose();
        }
        if (!willRaiseEvent)
        {
            ProcessSend(null, writeEventArgs);
        }
    }


    private void ProcessSend(Object sender, SocketAsyncEventArgs e)
    {
        AsyncUserToken token = (AsyncUserToken)e.UserToken;
        Logger2.log(Logger2.Debug5, token.ConnectionId, "Send Complete");
        if (e.SocketError == SocketError.Success)
        {
            Interlocked.Add(ref m_totalBytesSent, e.BytesTransferred);
            Logger2.log(Logger2.Debug5, ((AsyncUserToken)e.UserToken).ConnectionId, "Total Bytes sent: " + m_totalBytesSent);

        }
        else
        {
            if (token.Connected)
            {
                CloseClientSocket(token);
            }
        }
        e.Dispose();
    }

Answer 1

您在每个连接上发送多少数据，发送速度有多快？

通常，异步发送需要很长时间才能完成的原因是您已经填满了 TCP 窗口(有关详细信息，请参阅 here)并且本地 TCP 堆栈无法发送更多数据，直到它从同行。如果您继续发送数据，那么您只是在网络子系统中将其本地排队，因为不允许堆栈发送它。拥塞和数据包丢失会使情况变得更糟，因为传输中的数据需要更长的时间才能到达对等方，而 ACK 需要更长的时间才能返回……

如果是这种情况(并且诸如 WireShark 之类的工具应该能让您看到窗口大小更新和零窗口情况等)，那么增加连接的窗口大小可能会有所帮助(请参阅 here)。

如果你的协议(protocol)没有明确的流量控制，那么上述情况就更有可能发生。最好在您的协议(protocol)设计中包含某种形式的显式流量控制，恕我直言，以避免这种情况。

包含一些发送端保护也是明智的，因为无限制的发送者可以非常快速地咀嚼内存。我使用过的一种行之有效的方法是拥有一个可以放置出站数据的队列，并且来自该队列的数据实际上是根据早期发送的发送完成情况发送的(请参阅 here )。