内存流复制到网络流问题

Question

我这里的代码有问题。

using (MemoryStream ms = new MemoryStream())
{
    BinaryFormatter bf = new BinaryFormatter();
    bf.Serialize(ms,SerializableClassOfDoom);
    ms.Position = 0;
    byte[] messsize = BitConverter.GetBytes(ms.Length);
    ms.Write(messsize, 0, messsize.Length);
    NetworkStream ns = Sock.GetStream();
    ms.CopyTo(ns);
    //ms.Close();
}

我不明白这里发生了什么，或者为什么它不起作用。看起来它不复制，或者它关闭网络流，或者其他什么。

抱歉，我已经尝试调试它，但如果有人能在这里看到任何明显的问题，我将不胜感激。

顺便说一句，该类序列化得很好，并且 MemoryStream 包含数据，但由于某种原因，执行 ms.CopyTo(ns) 似乎不起作用？

本质上，我想要做的是将类序列化到网络流，并在其前面添加序列化数据的大小。如果有人有更好的方法来做到这一点，请告诉我！

Answer 1

您在错误的时间重置了流位置。

在您的情况下，您将“长度”写入流的开头。

以下内容应该有效：

using (MemoryStream ms = new MemoryStream())
{
    BinaryFormatter bf = new BinaryFormatter();
    bf.Serialize(ms,SerializableClassOfDoom);
    byte[] messsize = BitConverter.GetBytes(ms.Length);
    ms.Write(messsize, 0, messsize.Length);
    ms.Position = 0;
    NetworkStream ns = Sock.GetStream();
    ms.CopyTo(ns);
}

更新：

要将“length”写入开头，请使用临时流/字节[]。

示例：

using (MemoryStream ms = new MemoryStream())
{
    BinaryFormatter bf = new BinaryFormatter();
    bf.Serialize(ms,SerializableClassOfDoom);
    byte[] data = ms.ToArray();
    byte[] messsize = BitConverter.GetBytes(ms.Length);
    ms.Position = 0;
    ms.Write(messsize, 0, messsize.Length);
    ms.Write(data, 0, data.Length);
    ms.Position = 0; // again!
    NetworkStream ns = Sock.GetStream();
    ms.CopyTo(ns);
}

更新 2：

更有效的方式。

using (MemoryStream ms = new MemoryStream())
{
    BinaryFormatter bf = new BinaryFormatter();
    bf.Serialize(ms,SerializableClassOfDoom);
    byte[] messsize = BitConverter.GetBytes(ms.Length);
    NetworkStream ns = Sock.GetStream();
    ns.Write(messsize, 0, messsize.Length);
    ms.Position = 0; // not sure if needed, doc for CopyTo unclear
    ms.CopyTo(ns); 
}

Answer 2

也许您需要在调用 CopyTo 之前将内存流倒回到开头（使用 ms.Seek(0, SeekOrigin.Start)）

Answer 3

我没有看到真正的问题，但我在这里看到了一个小重构问题。

在完成任何 Stream 之前尝试使用

Stream.Flush()
Stream.Close()

。

还用这样的 try-catch 语句包围它，以确保即使出现异常也会发生关闭和刷新！

Stream s = new Stream();
try{
    s.Write();
}catch(Exception ex){
    //Oh god, we are doomed!
}finally{
    s.Flush();
    s.Close();
}

您的代码看起来像

NetworkStream ns = null;
using (MemoryStream ms = new MemoryStream())
{
    try{
        BinaryFormatter bf = new BinaryFormatter();
        bf.Serialize(ms,SerializableClassOfDoom);
        ms.Position = 0;
        byte[] messsize = BitConverter.GetBytes(ms.Length);
        ms.Write(messsize, 0, messsize.Length);
        ns = Sock.GetStream();
        ms.CopyTo(ns);
        //ms.Close();
    }catch(Exception ex){
        throw;
    }finally{
        ms.Flush();
        if(ns != null)
            ns.Flush();

        ms.Close();
    }
}

这样，之后您应该能够找到您的问题。