我在通过 TCPClient 发送对象时遇到问题。首先，我将它们序列化为字节数组，然后发送它们。 TCPListener 收到一些数据，但解串器抛出异常“流的意外结束”。

接收者代码如下:

    public void start()
    {
        TcpListener listener = new TcpListener(IPAddress.Any, 8090);
        listener.Start();

        while (true)
        {
            TcpClient client = listener.AcceptTcpClient();
            processClient(client);
        }
    }

    public void processClient(TcpClient client)
    {
        NetworkStream net = client.GetStream();


        ReadData(net);

        byte[] response  = Encoding.UTF8.GetBytes("Hello from the server.");
        net.Write(response, 0, response.Length);
        net.Close();
        client.Close();
    }

void ReadData(NetworkStream netstream)
{
    byte[] buffer = new byte[2048];
    System.IO.MemoryStream memStream = new System.IO.MemoryStream();

    netstream.ReadTimeout = 5000;

    int bytes = -1;

    while ((bytes = netstream.ReadByte()) != -1)
    {
        memStream.WriteByte((byte)bytes);
    }

    System.Runtime.Serialization.Formatters.Binary.BinaryFormatter bform = new System.Runtime.Serialization.Formatters.Binary.BinaryFormatter();


    Packet packet = (Packet)bform.Deserialize(memStream);

    OnMessageArrived(this, new MessageEventArgs(packet.From.ToString(), packet.Data.ToString()));

    memStream.Close();
    netstream.Close();

}

这是发件人代码:

    public void sendData(string to, Packet data)
    {
        TcpClient client = new TcpClient();

        MemoryStream mstream = new MemoryStream();

        client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8090));
        if (client.Connected)
        {
            NetworkStream stream = client.GetStream();

            System.Runtime.Serialization.Formatters.Binary.BinaryFormatter bform = new System.Runtime.Serialization.Formatters.Binary.BinaryFormatter();

            bform.Serialize(mstream, data);

            byte[] buffer = new byte[2048];
            mstream.Read(buffer, 0, buffer.Length);

            stream.Write(buffer, 0, buffer.Length);
            stream.Flush();
            stream.Close();
            client.Close();
        }
    }

发送者主要方法:

    static void Main(string[] args)
    {
        SimplestTCPIP.Client client = new SimplestTCPIP.Client();

        Packet packet = new Packet("client", "server", IPAddress.Parse("127.0.0.1"));

        client.sendData("server", packet);

        Console.WriteLine("IP: " + GetIP().ToString());
        Console.Read();
    }

接收端主要方法:

    static void Main(string[] args)
    {
        SimplestTCPIP.Server server = new SimplestTCPIP.Server();

        server.OnMessageArrived += new SimplestTCPIP.Server.MessageArrived(server_OnMessageArrived);

        Thread thread = new Thread(server.start);
        thread.Start();

    }

    static void server_OnMessageArrived(object sender, SimplestTCPIP.Server.MessageEventArgs m)
    {
        Console.WriteLine(m.From + " : " + m.Text);
    }

最佳答案

在您的 sendData 方法中，您将对象序列化为内存流，然后在将其写入网络流之前将其读回到 2048 字节的缓冲区中。如果序列化对象大于 2048 字节，您就会遇到问题。我会尝试直接序列化到网络流，或者至少使用与您逐字节写入的 ReadData 方法中相同类型的代码。

编辑:

数据的大小可能不是问题。您仍然应该避免硬编码缓冲区大小并坚持您在评论中提到的代码更改。鉴于您的评论，问题出在其他地方。 在您的发送者和接收者中，您都写入内存流，然后从中读取。除非您在写入和读取之间将流中的当前位置设置回零，否则您不能这样做。

所以在客户端的 sendData 方法中添加一行

mstream.Seek(0, SeekOrigin.Begin);

紧接着

bform.Serialize(mstream, data);

然后在服务器的 ReadData 方法中添加行

memStream.Seek(0, SeekOrigin.Begin);

就在

Packet packet = (Packet)bform.Deserialize(memStream);

这样，在您尝试读取内存流之前，内存流会被设置为开头。

我认为您可以完全跳过内存流，只读取和写入网络流，但您可能还有其他原因。

关于c# - 反序列化通过 TCP 发送的数据，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/1496861/