序列化异常，在解析完成之前遇到流结束

Question

我有这个学校项目，我正在使用 TCPClient-Server 在 LAN 上制作回合制 RPG。到目前为止，我已经能够通过序列化和反序列化对象将他们选择的类从两个客户端发送到服务器，但是现在我无法将播放器 2 角色发送到播放器 1 客户端（播放器 1 充当主机，并且服务器程序在该计算机上运行）。

客户代码

//part where I send the character to the server
byte[] player;
MemoryStream ms = new MemoryStream();
BinaryFormatter bf = new BinaryFormatter();
bf.Serialize(ms, Player);
player = ms.ToArray();
byte[] DLen = BitConverter.GetBytes((Int32)player.Length);
netstream = Cliente.GetStream();
netstream.Write(DLen, 0, 4);
netstream.Write(player, 0, player.Length);
netstream.Flush();
ms.Flush();

//part where I receive the other client's character from the server
byte[] DataLength = new byte[4];
netstream = Cliente.GetStream();
netstream.Read(DataLength, 0, 4);//<----HOST Client "skips" this line (executes instruction BEFORE Reset Event was notified in server side)
int length = BitConverter.ToInt32(DataLength, 0);
player = new byte[length];
netstream.Read(player, 0, length);
ms = new MemoryStream(player);
bf = new BinaryFormatter();
ms.Position = 0;
object ob = bf.Deserialize(ms);//<----Line where exception appears ONLY on HOST Client
CPU = (ACharacter)ob;
netstream.Flush();

服务器代码

AutoResetEv.WaitOne();//<---Waits until BOTH players have selected their characters
//Begin sending to P2
byte[] player;
MemoryStream ms = new MemoryStream();
BinaryFormatter bf = new BinaryFormatter();
bf.Serialize(ms, Player1);
player = ms.ToArray();
byte[] DataLength = BitConverter.GetBytes((Int32)player.Length);
netstream = Jug2Sock.GetStream();
netstream.Write(DataLength, 0, 4);
netstream.Write(player, 0, player.Length);
netstream.Flush();
//Finished sending to P2

//Begin sending to P1
ms = new MemoryStream();
bf = new BinaryFormatter();
bf.Serialize(ms, Player2);
player = ms.ToArray();
DataLength = BitConverter.GetBytes((Int32)player.Length);
netstream = Jug1Sock.GetStream();
netstream.Write(DataLength, 0, 4);
netstream.Write(player, 0, player.Length);
netstream.Flush();
//Finished sending to P1

我真的不知道这里有什么问题，因为玩家 1 的角色使用相同的代码正确发送到玩家 2，但是我注意到由于某种原因，在 P1 的客户端中，读取数据长度的行被“跳过” ”。我的意思是说客户端 1 只是在服务器发送数据之前执行指令（服务器被 AutoResetEvent 搁置以控制它）。

非常感谢您的帮助。

Answer 1

我认为您需要处理读取操作返回的读取字节数

        netstream = Cliente.GetStream();            
        int numBytesToRead = 4;
        do
        {
            // Read may return anything from 0 to 4. 
            int n = netstream.Read(DataLength, numBytesRead, numBytesToRead);
            numBytesRead += n;
            numBytesToRead -= n;
        } while (numBytesToRead > 0);
        int length = BitConverter.ToInt32(DataLength, 0);

这是一个如何处理前 4 个字节（包含 DataLength）读取的示例。读取玩家数据可以这样完成：

        player = new byte[length];
        numBytesRead = 0;
        numBytesToRead = length;
        do
        {            
            int n = netstream.Read(player, numBytesRead, numBytesToRead);
            numBytesRead += n;
            numBytesToRead -= n;
        } while (numBytesToRead > 0);        
        ms = new MemoryStream(player);