memorystream 复制到网络流问题

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);
}

更新：

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

例子：

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.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();
    }
}

在这之后你应该能够找到你的问题。