TCP 消息损坏

Question

我有一个简单的 TCP 服务器，它通过 GPRS 与一些设备进行通信。可以长期正常工作，没有任何问题。如今，设备（发送数据的客户端设备）发生了变化，它们发送的数据比以前多得多，并且 TCP 消息大小可能比以前大 10 倍。早些时候，每条数据消息的最大长度为 1024 字节，现在可以超过 10,000 字节/消息。

正如我所看到的 - 正如 TCP 的本质所预测的 - 有很多消息被“损坏”，因此只有其中一部分到达，而不是完整的消息，稍后可能会出现另一部分等等。

我认为我的服务器 -基于异步模式 - 以错误的方式处理这种情况，我认为错误出在我的 RecieveCallBack 函数中。我找不到处理这种情况的正确方法。我该怎么做？

这是我的 RecieveCallBack 函数：

public void RecieveCallBack(IAsyncResult ar)
    {
        StateObject state = (StateObject)ar.AsyncState;

        try
        {
            Socket handler = state.WorkSocket;

            int read = handler.EndReceive(ar);

            if (read > 0)
            {
                var data = new byte[read];
                Array.Copy(state.Buffer, 0, data, 0, read);
            }
            else
            {
                if ((handler.Connected == false) || (handler.Available == 0))
                {
                    Close(state);
                    return;
                }
            }
        }
        catch (System.Net.Sockets.SocketException)
        {
            Close(state);
        }
        catch (System.Exception exc)
        {
            Debug.Assert(false, exc.Message);
            HandleSocketError(state, exc);
        }
    }

.net4/c#/vs2010

谢谢

更新： 客户端能连接就连接，所以这取决于 GSM 网络。它们甚至可以连接数天，并且每分钟发送数据。客户端设备的协议不同，不同类型的设备具有不同类型的协议。其中一种在消息末尾有定界符和CRC，其他则没有。

Answer 1

您需要消息框架。协议必须指定消息的大小 - 通常是众所周知的恒定大小、长度前缀或使用消息分隔符。

Answer 2

TCP 中没有数据包这样的东西。它是一个面向流的协议。这意味着当您读取套接字时，您可以获得的数据比您预期的要少。您需要检查读取大小，如果读取时间较短，则再次读取其余数据。

以 C 语言为例：

int read_data(int sock, int size, unsigned char *buf) {
   int bytes_read = 0, len = 0;
   while (bytes_read < size && 
         ((len = recv(sock, buf + bytes_read,size-bytes_read, 0)) > 0)) {
       bytes_read += len;
   }
   if (len == 0 || len < 0) doerror();
   return bytes_read;
}

Answer 3

我不确定应用程序的其余部分看起来如何，但我认为问题出在以下行：-

Array.Copy(state.Buffer, 0, data, 0, read);

如果数据包分段，即对同一连接多次调用接收回调，则状态。缓冲区将被最后一次覆盖收到数据包，这是因为您将数据复制到 state.Buffer 中的偏移量 0。

根据您的需求，您可能需要 StateObject 中的更多状态:)，以便您可以附加数据而不是覆盖。

希望这个提示有帮助。