二进制格式化程序从内存流冻结中反序列化

由 发布于

我正在尝试做一个通过套接字进行通信的客户端服务器应用程序，并且使用BinaryFormatter将其消息序列化并反序列化。我的代码被冻结，并且在进行反序列化时绝对不执行任何操作，而且我也不例外，因为我也没有例外。我也无法介入调试器，一切都冻结了。这是我的代码：

 public class Serializer
    {
        public static MemoryStream ToStream(object obj)
        {
            var stream = new MemoryStream();
            var formatter = new BinaryFormatter();
            formatter.Serialize(stream, obj);
            return stream;
        }

        public static object FromStream(MemoryStream stream)
        {
            Console.WriteLine("Starting from stream");
            var formatter = new BinaryFormatter();
            stream.Seek(0, SeekOrigin.Begin);
            object rez = formatter.Deserialize(stream); //NEVER GOES OVER THIS
            Console.WriteLine("Starting deserialization" + rez);
            return formatter.Deserialize(stream);
        }
    }

public class Connection
    {
        private Socket socket;
        public Connection(Socket socket)
        {
            this.socket = socket;
            Console.WriteLine($"Connected to client: {socket.RemoteEndPoint}");
            Task.Factory.StartNew(() => Execute(socket));
        }

        private void Execute(Socket socket)
        {
            while (true)
            {
                var buffer = new byte[2048];
                var bytesCount = socket.Receive(buffer);
                if(bytesCount != 0)
                {
                    var msgReceived = (Message)Serializer.FromStream(new MemoryStream(buffer, 0, buffer.Length));
                    Console.WriteLine($"Received msg: {msgReceived.Content}");
                }
               /* var msg = new Message { Content = "Hello World2!" };
                Console.WriteLine($"Sending msg with content: {msg.Content}");
                MemoryStream stream = Serializer.ToStream(msg);
                var bytesSent = socket.Send(stream.GetBuffer());*/

                Console.WriteLine("Trying again");
                Thread.Sleep(500);
            }
        }

客户代码：

  var host = Dns.GetHostEntry("localhost");
            var ipAddress = host.AddressList.First();
            var serverEndpoint = new IPEndPoint(ipAddress, 9000);

            Socket serverSocket = new Socket(ipAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
            serverSocket.Connect(serverEndpoint);

            Console.WriteLine($"Successfully connected to server on: {serverSocket.RemoteEndPoint}");

            while (true)
            {
                var msg = new Message { Content = "Hello World!" };
                Console.WriteLine($"Sending msg with content: {msg.Content}");
                MemoryStream stream = Serializer.ToStream(msg);
                var bytesSent = serverSocket.Send(stream.GetBuffer());
                Console.WriteLine("Waiting to receive");

                var buffer = new byte[2048];
                int bytesReceived = serverSocket.Receive(buffer);
                if (bytesReceived != 0)
                {
                    var receivedMessage = (Message)Serializer.FromStream(new MemoryStream(buffer));
                    Console.WriteLine($"Received message: {receivedMessage.Content}");
                }

                Console.WriteLine("Received done");

            }

服务器代码：

var host = Dns.GetHostEntry("localhost");
            var ipAddress = host.AddressList.First();
            var localEndPoint = new IPEndPoint(ipAddress, 9000);
            var serverSocket = new Socket(ipAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
            serverSocket.Bind(localEndPoint);
            serverSocket.Listen(1);

            while (true)
            {
                Console.WriteLine("Waiting for client");
                Socket clientSocket = serverSocket.Accept();
                var connection = new Connection(clientSocket);
            }

我还检查了byteCount，它们正到达服务器，缓冲区也不为空，我不明白为什么反序列化什么也不做。