TCP服务器没有接收到发送的所有数据

本文关键字：数据 服务器 TCP | 更新日期: 2023-09-27 17:49:33

试图设置TCP服务器从流中获取数据。似乎起作用了，但只有在水流很小的时候。一旦我开始发送大量数据，这就失败了，只返回一部分字符。有人能帮我一下吗?为什么我只收到我发送的数据的一部分?

服务器的流程应该是，接收所有数据，存储到数据库(RouteInboundXml())，并开始侦听更多的传入数据。

private void ReceivePortMessages()
{
    string debug = string.Empty;
    try
    {
        Debug.Print(" >> Starting Server");
        IPAddress ipAddress = Dns.GetHostEntry(Dns.GetHostName()).AddressList.FirstOrDefault(ip => ip.AddressFamily == AddressFamily.InterNetwork);
        _TcpListener = new TcpListener(ipAddress, TcpPort); ;
        Debug.Print(string.Format("{0}:{1}", ipAddress.ToString(), TcpPort.ToString()));
        _TcpListener.Start();
        Stopwatch sw = new Stopwatch();
        do
        {
            try
            {
                _TcpClient = _TcpListener.AcceptTcpClient();
                Debug.Print(" >> Accept connection from client");
                NetworkStream networkStream = _TcpClient.GetStream();
                int receivingBufferSize = (int)_TcpClient.ReceiveBufferSize;
                byte[] bytesFrom = new byte[receivingBufferSize];
                int Read = 0;
                string dataFromClient = string.Empty;
                if (!sw.IsRunning)
                {
                    sw.Start();
                }
                Read = networkStream.Read(bytesFrom, 0, receivingBufferSize);
                dataFromClient = System.Text.Encoding.ASCII.GetString(bytesFrom);
                dataFromClient = dataFromClient.Substring(0, dataFromClient.IndexOf("'0"));
                if (dataFromClient != string.Empty)
                {
                    XmlDocument xm = new XmlDocument();
                    debug = dataFromClient;
                    xm.LoadXml(string.Format("<root>{0}</root>", dataFromClient));
                    XmlElement root = xm.DocumentElement;
                    string rootName = root.FirstChild.Name;
                    RouteInboundXML(rootName, dataFromClient, sw);
                    sw.Restart();
                }
            }
            catch (Exception ex)
            {
                Debug.Print("ReceivePortMessages: " + ex.ToString());
                _TcpClient.Close();
                _TcpListener.Stop();
                ErrorLog.Write("XmlProcessing", ex.ToString() + "'r'n" + "DataFromClient: " + debug, "ReceivePortMessages()");
                return;
            }
        } while (true);
    }
    catch (Exception ex)
    {
        Debug.Print("ReceivePortMessages: " + ex.ToString());
        ErrorLog.Write("XmlProcessing", ex.ToString(), "ReceivePortMessages()");
    }
}

TCP服务器没有接收到发送的所有数据

每次调用Stream.Read时，您似乎都希望接收到一个完整的XML文档—并且恰好是 XML文档。这是一个非常非常危险的假设。

流是一个数据流-当它被分割成数据包进行传输时，你不应该期望在Read呼叫中接收到与Write呼叫相同数量的数据。

每个连接的单个文档的详细信息

如果每个流只有一个文档，您可能可以大大简化代码和使其正常工作。只要使用XmlDocument.Load的过载，它接受一个流:

using (var tcpClient = tcpListener.AcceptTcpClient())
{
    XmlDocument doc = new XmlDocument();
    using (var stream = tcpClient.GetStream())
    {
        doc.Load(stream);
    }
    // Use doc here
}

(如果可以的话，我个人会开始使用LINQ to XML，但这是另一回事。)

多个文档的详细信息

如果你想在一个TCP流上有多个消息，你应该实现某种"分块"协议。这样做的一个好方法是将每条消息分成"header"answers"body"，其中header可以像"body中的字节数"一样简单，这样您就知道要读多少。(或者，您可以为报头设计包含其他元数据的协议。)

读取报头后，从流中读取主体，直到读取到报头中所指示的字节数，或者到达流的末尾(这通常表示错误)。这可能需要多个Read调用。然后您就处于将数据解析为XML文档的合适位置了—理想情况下不需要首先强加自己的二进制/文本解码，因为并非所有XML都是ASCII…

你可以以这样一种方式设计你的协议，你只是在消息之间有一个分隔符，但这通常更难实现，因为它混合了"读取数据"answers"理解数据"。如果您可以使用上面描述的长度前缀方案，则会简单得多。

这是我过去使用过的一些代码。

using (TcpClient client = new TcpClient(ip, port))
{
    var stm = client.GetStream();
    stm.Write(data, 0, data.Length); //Write some data to the stream
    byte[] resp = new byte[1024];
    var memStream = new MemoryStream();
    var bytes = 0;
    client.Client.ReceiveTimeout = 200;
    do
    {
        try
        {
            bytes = stm.Read(resp, 0, resp.Length);
            memStream.Write(resp, 0, bytes);
        }
        catch (IOException ex)
        {
            // if the ReceiveTimeout is reached an IOException will be raised...
            // with an InnerException of type SocketException and ErrorCode 10060
            var socketExept = ex.InnerException as SocketException;
            if (socketExept == null || socketExept.ErrorCode != 10060)
            // if it's not the "expected" exception, let's not hide the error
            throw ex;
            // if it is the receive timeout, then reading ended
            bytes = 0;
        }
    } while (bytes > 0);
    return memStream.ToArray();
}
相关文章：