3

我有代码，我试图在通过套接字接收数据时增加字节数组。这是错误的。

    public bool ReceiveObject2(ref Object objRec, ref string sErrMsg)
    {
        try
        {
            byte[] buffer = new byte[1024];
            byte[] byArrAll = new byte[0];
            bool bAllBytesRead = false;

            int iRecLoop = 0;

            // grow the byte array to match the size of the object, so we can put whatever we 
            // like through the socket as long as the object serialises and is binary formatted 
            while (!bAllBytesRead)
            {
                if (m_socClient.Receive(buffer) > 0)
                {
                    byArrAll = Combine(byArrAll, buffer);
                    iRecLoop++;
                }
                else
                {
                    m_socClient.Close();
                    bAllBytesRead = true;
                }
            }

            MemoryStream ms = new MemoryStream(buffer);
            BinaryFormatter bf1 = new BinaryFormatter();
            ms.Position = 0;
            Object obj = bf1.Deserialize(ms);
            objRec = obj;

            return true;
        }
        catch (System.Runtime.Serialization.SerializationException se)
        {
            objRec = null;
            sErrMsg += "SocketClient.ReceiveObject " + "Source " + se.Source + "Error : " + se.Message;
            return false;
        }
        catch (Exception e)
        {
            objRec = null;
            sErrMsg += "SocketClient.ReceiveObject " + "Source " + e.Source + "Error : " + e.Message;
            return false;
        }
    }

    private byte[] Combine(byte[] first, byte[] second)
    {
        byte[] ret = new byte[first.Length + second.Length];
        Buffer.BlockCopy(first, 0, ret, 0, first.Length);
        Buffer.BlockCopy(second, 0, ret, first.Length, second.Length);
        return ret;
    }

错误：mscorlibError：输入流不是有效的二进制格式。起始内容（以字节为单位）为：68-61-73-43-68-61-6E-67-65-73-3D-22-69-6E-73-65-72 ...

然而，当我只是作弊并使用 MASSIVE 缓冲区大小时，它很好。

        public bool ReceiveObject(ref Object objRec, ref string sErrMsg)
    {
        try
        {
            byte[] buffer = new byte[5000000];

            m_socClient.Receive(buffer);
            MemoryStream ms = new MemoryStream(buffer);
            BinaryFormatter bf1 = new BinaryFormatter();

            ms.Position = 0;
            Object obj = bf1.Deserialize(ms);
            objRec = obj;

            return true;
        }
        catch (Exception e)
        {
            objRec = null;
            sErrMsg += "SocketClient.ReceiveObject " + "Source " + e.Source + "Error : " + e.Message;
            return false;
        }
    }

这真是要了我的命。我不知道为什么它不起作用。我也从这里的建议中取消了组合，所以我很确定这没有做错事？

我希望有人能指出我哪里出错了

4

2 回答 2

2

该Combine方法是增长数组的一种非常昂贵的方法，尤其是在MemoryStream旨在解决此问题时；其他答复是正确的：您必须检查读取的字节数：

using(MemoryStream ms = new MemoryStream()) {
    int bytesRead;
    while((bytesRead = m_socClient.Receive(buffer)) > 0) {
        ms.Write(buffer, 0, bytesRead);
    }
    // access ms.ToArray() or ms.GetBuffer() as desired, or
    // set Position to 0 and read
}

当然，您可以直接从流中读取（将其传递给您的阅读器）

另外 - 如果您的序列化太大，您可能会考虑替代编码器，例如 protobuf-net（尽管这会稍微改变代码）。这可能会解决一个巨大物体的问题。

于 2010-01-25T19:30:09.913 回答
1

我对 C# 网络不是很熟悉，但是您不是每次调用时都将完整的 1024 字节附加到缓冲区Combine()并忽略从套接字读取的字节数吗？您可能需要至少一个额外的参数来告诉该函数要复制多少字节second。

于 2010-01-25T18:25:21.700 回答