C# Socket.Receive 消息长度

我目前正在开发一个 C# Socket 服务器，它可以接受来自多个客户端计算机的多个连接。服务器的目标是允许客户端“订阅”和“取消订阅”服务器事件。

到目前为止，我已经很好地观察了这里：http://msdn.microsoft.com/en-us/library/5w7b7x5f(v=VS.100).aspx and http://msdn.microsoft.com/en-us/library/fx6588te.aspx寻求想法。

我发送的所有消息都是加密的，因此我获取要发送的字符串消息，将其转换为 byte[] 数组，然后在将消息长度添加到数据之前加密数据并通过连接发送出去。

令我印象深刻的一件事是：在接收端，当只收到一半消息时，Socket.EndReceive()（或相关的回调）可能会返回。有没有一种简单的方法可以确保每条消息都被“完整”接收并且一次只能收到一条消息？

EDIT:例如，我认为 .NET / Windows 套接字不会“包装”消息以确保在一次 Socket.Receive() 调用中接收到使用 Socket.Send() 发送的单个消息？或者确实如此？

到目前为止我的实现：

private void StartListening()
{
    IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());
    IPEndPoint localEP = new IPEndPoint(ipHostInfo.AddressList[0], Constants.PortNumber);

    Socket listener = new Socket(localEP.Address.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
    listener.Bind(localEP);
    listener.Listen(10);

    while (true)
    {
        // Reset the event.
        this.listenAllDone.Reset();

        // Begin waiting for a connection
        listener.BeginAccept(new AsyncCallback(this.AcceptCallback), listener);

        // Wait for the event.
        this.listenAllDone.WaitOne();
    }
}

private void AcceptCallback(IAsyncResult ar)
{
    // Get the socket that handles the client request.
    Socket listener = (Socket) ar.AsyncState;
    Socket handler = listener.EndAccept(ar);

    // Signal the main thread to continue.
    this.listenAllDone.Set();

    // Accept the incoming connection and save a reference to the new Socket in the client data.
    CClient client = new CClient();
    client.Socket = handler;

    lock (this.clientList)
    {
        this.clientList.Add(client);
    }

    while (true)
    {
        this.readAllDone.Reset();

        // Begin waiting on data from the client.
        handler.BeginReceive(client.DataBuffer, 0, client.DataBuffer.Length, 0, new AsyncCallback(this.ReadCallback), client);

        this.readAllDone.WaitOne();
    }
}

private void ReadCallback(IAsyncResult asyn)
{
    CClient theClient = (CClient)asyn.AsyncState;

    // End the receive and get the number of bytes read.
    int iRx = theClient.Socket.EndReceive(asyn);
    if (iRx != 0)
    {
        // Data was read from the socket.
        // So save the data 
        byte[] recievedMsg = new byte[iRx];
        Array.Copy(theClient.DataBuffer, recievedMsg, iRx);

        this.readAllDone.Set();

        // Decode the message recieved and act accordingly.
        theClient.DecodeAndProcessMessage(recievedMsg);

        // Go back to waiting for data.
        this.WaitForData(theClient);
    }         
}

是的，您可能只收到部分消息per one接收时，情况可能更糟，在传输过程中仅发送部分消息。通常您可以在网络状况不佳或网络负载过重的情况下看到这一点。

需要明确的是，在网络级别，TCP 保证按指定顺序传输您的数据，但不保证部分数据与您发送的数据相同。该软件的原因有很多（看看内格尔算法例如）、硬件（跟踪中的不同路由器）、操作系统实现，因此一般来说，您永远不应该假设数据的哪一部分已经传输或接收。

抱歉介绍太长，以下是一些建议：

1. Try使用相关的“新”API 来实现高性能套接字服务器，这里是示例.NET v4.0 的网络示例

2. Do not假设您总是发送完整的数据包。Socket.EndSend()返回实际计划发送的字节数，在网络负载较重的情况下甚至可以是 1-2 个字节。那么你have to在需要时重新发送缓冲区的其余部分。

   MSDN上有警告：

   无法保证数据 您发送的内容将出现在网络上 立即地。增加网络 效率，底层系统可能 延迟传输直到显着 收集输出数据量。 圆满完成了 BeginSend方法意味着 底层系统有空间 缓冲网络发送的数据。

3. Do not假设您总是收到完整的数据包。将接收到的数据加入某种缓冲区中，并在有足够数据时对其进行分析。

4. 通常，对于二进制协议，我添加字段来指示传入的数据量、具有消息类型的字段（或者您可以为每个消息类型使用固定长度（通常不好，例如版本控制问题））、版本字段（如果适用）并添加 CRC - 消息末尾的字段。

5. 它实际上并不需要阅读，有点旧并且直接适用于 Winsock，但也许值得研究：Winsock 程序员常见问题解答

6. 看看协议缓冲区，值得学习：http://code.google.com/p/protobuf-csharp-port/, http://code.google.com/p/protobuf-net/

希望能帮助到你。

附：遗憾的是，您在 MSDN 上引用的示例有效地破坏了其他答案中所述的异步范例。