c# NetworkStream BeginRead 看似覆盖字节

Question

对于某些程序，我想将数据从 python 程序发送到 c# 程序。我将所有数据放入 python 中的列表中，并在转换为字节后发送（将它们打包为双精度，所以我发送的每个数字有 8 个字节）。了解了套接字和 TCP 流的工作原理后，列表中的第一个数字是列表其余部分占用的字节数。因此，流的前 8 个字节告诉我需要读取多少字节才能获取所有其他数据。

但是，当我调用 BeginRead 并调用回调时，它读取的内容比我要求它读取的少 8 个字节。例如，前 8 个字节告诉我有 116432 个字节要读取，但是当我调用 EndRead 时它返回 116424。

好吧，那又怎样？缺少八个字节，这相当于丢失了一个双倍。这本身就是一个问题，但我什至弄清楚了这个替身去了哪里。

在 python 中，在我的数据中的特定点（虽然它仍然是两倍），我看到我正在发送："...,1961.0, 0.0128, 2033.0, 0.0442, 2034.0,..." 当我在 c# 中检查同一点时（将我的字节转换回双精度后），我看到："..,1961.0, 2033.0002, 0.0442,2034.0,..."。

对我来说，很明显这 8 个字节不知何故被混为一个，以某种方式将两个数字（可能是按位？）融合在一起。我还注意到，字节数据中出现这种情况的索引大致在 64k-65k 标记处。所以我怀疑 64kbytes 是 TCP 数据包的最大数据包大小，流有某种打嗝并覆盖我的缓冲区的一部分而不清除它，导致一些文字混淆？有谁知道我该如何解决这个问题，或者我犯了什么错误导致这种情况发生？

我将两个相关的函数贴在这里。

private void Listen(int port)
{
    try
    {
        // Perform a blocking call to accept requests.
        // You could also user server.AcceptSocket() here.
        var client = _server.AcceptTcpClient();

        // Get a stream object for reading and writing
        var stream = client.GetStream();

        var pLength = new byte[8];          

        // Loop to receive all the data sent by the client.
        while(_running)
        {
            if(!stream.DataAvailable && stream.Read(pLength, 0, 8) <= 0)
                continue;            
            var nOfBytes = (int) BitConverter.ToDouble(pLength, 0);
            pLength = new byte[8];

            if (nOfBytes <= 0) 
            {
                continue;
            }

            var localBytes = new byte[nOfBytes];

            var scriptData = new ScriptData(stream, localBytes);
            stream.BeginRead(localBytes, 0, nOfBytes, new AsyncCallback(GotAllBytes), scriptData);
        }

        // Shutdown and end connection
        client.Close();
    }
    catch (SocketException e)
    {
        _errorBool = true;
        _errorString = "Port: " + port + "\n" + e.Message + e.StackTrace;
    }
    finally
    {
        // Stop listening for new clients.
        _server.Stop();
    }
}

private void GotAllBytes(IAsyncResult result)
{
    var scriptData = (ScriptData)result.AsyncState;
    if (OnlinePaused)
    {
        scriptData.Stream.EndRead(result);
        return;
    }
    var bytesRead = scriptData.Stream.EndRead(result);
    _rawDataQueue.Enqueue(scriptData.Buffer.ToList());
}

感谢阅读，希望对你有所帮助。

Answer 1

感谢原始问题的 cmets 中的 Jeroen Mostert，这个问题已经通过不工作异步解决，而是实现了 BinaryReader。

private void Listen(int port)
{
    try
    {
        // Perform a blocking call to accept requests.
        // You could also user server.AcceptSocket() here.
        var client = _server.AcceptTcpClient();

        // Get a stream object for reading and writing
        var stream = client.GetStream();

        var pLength = new byte[8];          

        // Loop to receive all the data sent by the client.
        while(_running)
        {
            if(!stream.DataAvailable && stream.Read(pLength, 0, 8) <= 0)
                continue;            
            var nOfBytes = (int) BitConverter.ToDouble(pLength, 0);
            pLength = new byte[8];

            if (nOfBytes <= 0) 
            {
                continue;
            }

            var localBytes = new byte[nOfBytes];

            var reader = new BinaryReader(stream);
            ProcessData(reader);
        }

        // Shutdown and end connection
        client.Close();
    }
    catch (SocketException e)
    {
        _errorBool = true;
        _errorString = "Port: " + port + "\n" + e.Message + e.StackTrace;
    }
    finally
    {
        // Stop listening for new clients.
        _server.Stop();
    }
}

感谢所有试图提供帮助的人。