StreamReader 不会停止读取 C#

Question

我在两台使用 Windows 窗体的计算机之间建立了 TCP 连接。我有一个整数数组，我使用 XmlSerializer 类对其进行序列化，并使用 StreamWriter 发送它并使用 StreamReader 接收。
发送：

NetworkStream stream = m_client.GetStream();   //m_client is a TCPclient
StreamWriter m_writer = new StreamWriter(stream);
int[] a = new int[3] { 10,20,30 };
XmlSerializer serializer = new XmlSerializer(typeof(int[]));
serializer.Serialize(m_writer, a);
//m_writer.Flush();       //Doesn't help
//m_writer.Close();

在接收端：

TcpClient client = (TcpClient)p_client;
NetworkStream stream = client.GetStream();
StreamReader reader = new StreamReader(stream);
if (stream.CanRead)
{
    XmlSerializer serializer = new XmlSerializer(typeof(int[]));
    int[] numbers = (int[])serializer.Deserialize(reader);
    MessageBox.Show(numbers[0].ToString());    //Is not reached
    MessageBox.Show(numbers[1].ToString());
    MessageBox.Show(numbers[2].ToString());
}

问题是接收器上的阅读器不会停止阅读，除非我终止连接或关闭发送者端的 m_writer（在这种情况下，我不能使用它再次发送）。如果它不停止读取，则下一行（即 MessageBox.Show(numbers[0].ToString())）将不起作用。

我需要关于如何通知接收者在 30 岁后停止阅读或它如何理解何时停止阅读的建议？

编辑：
我从How to send integer array over a TCP connection in c# 获得了 XMLserializer 的想法
我找到了一个需要终止连接的答案，除非这是唯一可能的方法，否则我宁愿不这样做。 XmlSerializer Won't Deserialize over NetworkStream

Answer 1

通过 TCP 发送数据时，如果字节流中有任何边界，则由您来定义和实现它们。

在您的特定示例中，您可以在 XML 数据之前加上一个字节数，这似乎是合理的。使用空字节来终止数据也是合理的（因为 XML 本身不应该有空字节）。无论哪种方式都可以，但恕我直言，基于长度的方法稍微简单一些（不需要缓冲额外的未处理数据）。

这可能看起来像这样：

NetworkStream stream = m_client.GetStream();   //m_client is a TCPclient
using (MemoryStream buffer = new MemoryStream())
using (StreamWriter writer = new StreamWriter(buffer))
{
    int[] a = new int[3] { 10,20,30 };
    XmlSerializer serializer = new XmlSerializer(typeof(int[]));
    serializer.Serialize(writer, a);

    // This code assumes you aren't sending more than 2GB of XML.
    // This allows the other end to use int instead of long for the
    // length to receive.
    byte[] lengthBytes = BitConverter.GetBytes((int)buffer.Length);

    stream.Write(lengthBytes, 0, lengthBytes.Length);
    buffer.Position = 0;
    buffer.CopyTo(stream);
}

然后接收：

TcpClient client = (TcpClient)p_client;
NetworkStream stream = client.GetStream();

// Using BinaryReader is easier than implementing a correct, blocking read
// of fixed numbers of bytes -- TCP can return as little as a single byte for
// any given receive operation, but BinaryReader insulates us from that.
// Leave the stream open so that we can read more later.
using (BinaryReader binary = new BinaryReader(stream, Encoding.UTF8, true))
{
    int length = binary.ReadInt32();
    byte[] buffer = binary.ReadBytes(length);

    using (MemoryStream streamBuffer = new MemoryStream(buffer))
    using (StreamReader reader = new StreamReader(streamBuffer))
    {
        XmlSerializer serializer = new XmlSerializer(typeof(int[]));
        int[] numbers = (int[])serializer.Deserialize(reader);
        MessageBox.Show(numbers[0].ToString());    //Is not reached
        MessageBox.Show(numbers[1].ToString());
        MessageBox.Show(numbers[2].ToString());
    }
}

（顺便说一句：从技术上讲，MemoryStream 不需要using，或者根本不需要处理MemoryStream 对象。但我还是使用using；它给代码增加的开销很小，这让我养成了总是处理我创建的流的习惯。

Answer 2

NetworkStream 只会在底层套接字关闭时结束。

所以你需要尽可能多地读取数据；从中创建一个 MemoryStream 并使用它进行反序列化，如链接帖子中所示。