Stream.WriteTo 锁定线程

Question

我有这样的代码：

public static void SerializeRO(Stream stream, ReplicableObject ro) {
    MemoryStream serializedObjectStream = new MemoryStream();
    Formatter.Serialize(serializedObjectStream, ro);

    MemoryStream writeStream = new MemoryStream();
    BinaryWriter bw = new BinaryWriter(writeStream);

    bw.Write(serializedObjectStream.Length);
    serializedObjectStream.Seek(0, SeekOrigin.Begin);
    serializedObjectStream.WriteTo(writeStream);
    serializedObjectStream.Close();

    writeStream.WriteTo(stream);

    bw.Close();
}

writeStream.WriteTo(stream); 行永远不会完成。程序到达那条线并且不会继续进行。

stream 始终是 NetworkStream。我已经检查过，我认为它是一个有效的对象（至少它不是 null 也不是已处置）。

那么到底是怎么回事呢？

Answer 1

我尝试了你的代码 - 写入 FileStream - 并且我总是将零字节写入流。我不知道为什么当没有什么可写时 WriteTo 会在 NextWorkStream 上阻塞，但这可能是一个问题

当我从 MemoryStream< 中提取字节时/code> 并直接编写它们以流式传输所有内容，例如（我正在例程中创建一个二进制格式化程序，看来您已经有了一个格式化程序）。

public static void SerializeRO(Stream stream, object ro)
{
    MemoryStream serializedObjectStream = new MemoryStream();
    var f = new BinaryFormatter();
    f.Serialize(serializedObjectStream, ro);

    MemoryStream writeStream = new MemoryStream();
    BinaryWriter bw = new BinaryWriter(writeStream);

    var bytes = serializedObjectStream.ToArray();
    bw.Write(bytes.Length);
    bw.Write(bytes);

    var bwBytes = writeStream.ToArray();

    stream.Write(bwBytes, 0, bwBytes.Length);

    bw.Close();
}

不过，我会用一个 MemoryStream 这样做，并直接写入 stream，除非有一些我不知道的 NetworkStream （这当然会关闭 stream 这可能不是您想要的）

public static void SerializeRO(Stream stream, object ro)
{
    byte[] allBytes;
    using (var serializedObjectStream = new MemoryStream())
    {
        var f = new BinaryFormatter();
        f.Serialize(serializedObjectStream, ro);
        allBytes = serializedObjectStream.ToArray();
    }
    using (var bw = new BinaryWriter(stream))
    {
        bw.Write(allBytes.Length);
        bw.Write(allBytes);
    }
}

不会关闭 NetworkStream 的版本（只是不要将二进制编写器放在 using 语句或 Close()它）

public static void SerializeRO(Stream stream, object ro)
{
    byte[] allBytes;
    using (var serializedObjectStream = new MemoryStream())
    {
        var f = new BinaryFormatter();
        f.Serialize(serializedObjectStream, ro);
        allBytes = serializedObjectStream.ToArray();
    }
    var bw = new BinaryWriter(stream)
    bw.Write(allBytes.Length);
    bw.Write(allBytes);
}

Answer 2

只是我的想法：在将流写入另一个流之前，尝试关闭您的 BinaryWriter 。当您的写入器打开时，流尚未完成，因此 WriteTo newer 将找到流的末尾。