Socket.SendAsync 需要几秒钟才能完成答案

【问题标题】：Socket.SendAsync taking several seconds to completeSocket.SendAsync 需要几秒钟才能完成
【发布时间】：2010-10-01 16:13:26
【问题描述】：

我正在尝试优化一个 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();
    }

【问题讨论】：

你能发布一些相关的代码吗？很难猜测套接字问题。
你有 SocketAsyncEventArgs 池吗？
Eric - 我目前没有汇集 SocketAysncEventArgs，但计划稍后添加。但是，我在创建 SocketAysncEventArgs 并填充其缓冲区后记录开始时间，并将结束时间记录为回调中的第一个操作，所以虽然我知道它效率低下，但它不应该影响这部分执行？跨度>
Zor - 今天晚些时候我会得到一些代码 sn-ps

标签： c# performance sockets asynchronous

【解决方案1】：

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

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

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

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

包含一些发送端保护也是明智的，因为无限制的发送者可以很快地咀嚼内存。我使用的一种行之有效的方法是有一个队列，可以将出站数据放入其中，并且该队列中的数据实际上是根据先前发送的发送完成发送的（请参阅here）。

【讨论】：

谢谢Len，我会安装wireshark 看看它是否有任何亮点。与此同时，我已经读取了第一次发送完成时传输的数据（在我调用 SendAsync 后 1.2-1.3 秒），这确实是很小的数量，所以我不相信这是问题所在。成功发送的总字节数：40（1 次发送）接收的总字节数：827（10 次接收）尝试发送的总字节数：250（4 次发送）
嗯，这听起来不像是问题所在。这通常在发送大量数据时出现...

【解决方案2】：

尝试使用socket.NoDelay=True;。默认值为No，这意味着底层堆栈会在实际发送之前尝试累积传输。

【讨论】：