Windows socket.Send 数据直到socket.Close 才被接收

Question

我正在开发一个异步接受 TCP 连接 (BeginAccept/EndAccept) 和数据 (BeginReceive/EndReceive) 的服务器应用程序。该协议要求在发送下一条消息之前只要找到 EOM 字符就发送 ACK。接受和接收正在工作，但发送应用程序未收到 ACK（同步发送）。

    private void _receiveTransfer(IAsyncResult result)
    {
        SocketState state = result.AsyncState as SocketState;
        int bytesReceived = state.Socket.EndReceive(result);

        if (bytesReceived == 0)
        {
            state.Socket.Close();
            return;
        }

        state.Offset += bytesReceived;
        state.Stream.Write(state.Buffer, 0, bytesReceived);

        if (state.Buffer[bytesReceived - 1] == 13)
        {
            // process message
            Messages.IMessage message = null;
            try
            {
                var value = state.Stream.ToArray();

                // do some work
                var completed = true;

                if (completed)
                {
                    // send positive ACK
                    var ackMessage = string.Format(ack, message.TimeStamp.ToString("yyyyMMddhhmm"), message.MessageType, message.Id, "AA", message.Id);
                    var buffer = ASCIIEncoding.ASCII.GetBytes(ackMessage);
                    int bytesSent = state.Socket.Send(buffer, 0, buffer.Length, SocketFlags.None);
                }
                else
                {
                    // send rejected ACK
                    var ackMessage = string.Format(ack, message.TimeStamp.ToString("yyyyMMddhhmm"), message.MessageType, message.Id, "AR", message.Id);
                    state.Socket.Send(ASCIIEncoding.ASCII.GetBytes(ackMessage));
                }
            }
            catch (Exception e)
            {
                // log exception


                // send error ACK
                if (message != null)
                {
                    var ackMessage = string.Format(ack, DateTime.Now.ToString("yyyyMMddhhmm"), message.MessageType, message.Id, "AE", message.Id);
                    state.Socket.Send(ASCIIEncoding.ASCII.GetBytes(ackMessage));
                }
            }
        }

        state.Socket.BeginReceive(state.Buffer, 0, state.Buffer.Length, SocketFlags.None, new AsyncCallback(_receiveTransfer), state);
    }

state.Socket.Send 返回正确的字节数，但在套接字被释放之前不会收到数据。

欢迎提出建议。

Answer 1

• 您不应该从异步完成例程中同步执行任何操作。在负载下，您最终可能会劫持线程池中的所有 IO 完成线程，并严重损害性能，甚至导致完全 IO 死锁。因此，不要从异步回调同步发送 ACK。
• 使用前导码的协议和格式比使用终止符的协议和格式更容易管理。 IE。将消息的长度写入固定大小的消息头中，而不是检测终止符 \0x13。当然，如果协议一开始就在您的控制之下，则这适用。

至于您的问题，您没有指定您发布的相同代码是否也在客户端。

Answer 2

你要给多久？网络堆栈可以缓冲，这可能会延迟传输。来自 MSDN：

为了提高网络效率，
底层系统可能会延迟
传输直到显着
收集输出数据量。
成功完成发送
方法意味着底层
系统有足够的空间来缓冲你的
网络发送的数据。

您可能想尝试使用 IOControl< /a> 方法。

编辑

实际上，IOControl刷新会杀死缓冲区。您可能需要查看两位将军问题，看看您的协议是否会存在一些问题固有的问题。

Answer 3

尝试设置 TCP_NODELAY 套接字选项

Answer 4

您是否将套接字上的 NoDelay 属性设置为 true ？当设置为 false（默认值）时，数据在发送之前会缓冲最多 200 毫秒。原因是通过限制发送的数据包数量来减少网络流量。将 NoDelay 设置为 true 将强制更快地发送数据。