Сокеты.Сериализация

[Atoris]

Клиент и сервер на синхронных сокетах.
Нужно сериализовать данные(объект) и отправить по сокету и десериализовать на стороне клиента. Использую бинарную сериализацию.

Когда размер сериализованных данных маленький - все гладко проходит. Когда он начинает расти, в некоторый момент времени получается так, что приходят на клиент не все данные и десериализация не удается.
Есть идеи? Помогите, товарищи.

Сервер:

//MailBox => в байты
            byte[] msg = NetworkWorker.Serialize(currentMailBox);
            //размер MailBox
            int mailBoxSize = msg.Length;

            string cmdSize = mailBoxSize.ToString() + NetworkWorker.messageEnd;

            //Отправляем размер
            byte[] msgSize = Encoding.UTF8.GetBytes(cmdSize);
            handler.Send(msgSize);

            //Отправляем Почт ящик
                handler.Send(msg);

byte[] bytes = new byte[NetworkWorker.cmdSize];


            //Ответ от клиента
            int bytesRec = handler.Receive(bytes);
            Console.WriteLine("\nОтвет от клиента: {0}", Encoding.UTF8.GetString(bytes, 0, bytesRec));

Клиент:

//Получить размер ящика(вычленяем его из строки "размер"+"<THE_END>")
            int mailBoxSize = Convert.ToInt32(NetworkWorker.getCommand(sender));

            //Получить ящик
            serializedMailBox = new byte[mailBoxSize];

                MemoryStream stream = new MemoryStream();
                
                //порция по 2048
                byte[] buf = new byte[NetworkWorker.sendDataSize];

                for (int i = 0; i < mailBoxSize; i = i + NetworkWorker.sendDataSize)
                {
                    //получить порцию
                    sender.Receive(buf);

                    //ReceiveExactly(sender,buf,i,
                    stream.Write(buf, 0, buf.Length);

                }

                stream.Seek(0, 0);
                BinaryFormatter bin = new BinaryFormatter();
                try
                {
                    
                receiveMailBox = (MailBox)bin.Deserialize(stream);
                //receiveMailBox = NetworkWorker.DeSerializeMailBox(serializedMailBox);
                //отобразить в dataGridView
                showOnDataGridView(receiveMailBox.Inbox);
                //Ответ серверу
                byte[] serverCommandBytes =
                    Encoding.UTF8.GetBytes("Почтовый ящик получен!");
                //отправка команды на сервер
                sender.Send(serverCommandBytes);
                }

public static byte[] Serialize(object Obj)
        {
            BinaryFormatter bin = new BinaryFormatter();
            MemoryStream mem = new MemoryStream();
            bin.Serialize(mem, Obj);
            return mem.GetBuffer();
        }

GetBuffer() - возвращает данные, кратные 2048 байт

[Luuzuk]

Код ужасен от и до. Предполагаю, что первые грабли выстрелили здесь:

public static byte[] Serialize(object Obj)
        {
            BinaryFormatter bin = new BinaryFormatter();
            MemoryStream mem = new MemoryStream(); // а освобождать поток кто будет?
            bin.Serialize(mem, Obj);
            return mem.GetBuffer(); // Ага. Весь буфер. С мусором вместо данных в конце. Подразумевалось ToArray() ?
        }

Используйте, если можете, WCF. Оно в тысячу раз надежнее, гибче и удобнее, чем ваш велосипед.

[Atoris]

Сообщение от Luuzuk

Код ужасен от и до. Предполагаю, что первые грабли выстрелили здесь:

public static byte[] Serialize(object Obj)
        {
            BinaryFormatter bin = new BinaryFormatter();
            MemoryStream mem = new MemoryStream(); // а освобождать поток кто будет?
            bin.Serialize(mem, Obj);
            return mem.GetBuffer(); // Ага. Весь буфер. С мусором вместо данных в конце. Подразумевалось ToArray() ?
        }

Используйте, если можете, WCF. Оно в тысячу раз надежнее, гибче и удобнее, чем ваш велосипед.

Спасибо! Попробую. А в чем код ужасен? Если можете, по подробней распишите

[Luuzuk]

Пересылка у вас зачем-то ведется в строковом формате (даже числа, см. mailBoxSize ), причем строки потом конвертируются в массив байт. Не лучше ли будет передавать то же самое число сразу? Хорошей практикой будет использовать BinaryReader / BinaryWriter
Потоки следует использовать в конструкции using, чтобы вовремя освобождать ресурсы

На самом деле, попробуйте WCF

[Atoris]

Сообщение от Luuzuk

Не лучше ли будет передавать то же самое число сразу?

Каким образом?

[Luuzuk]

Например через BitConverter

            Int32 size = 42;
            byte[] a = BitConverter.GetBytes(size);
            Int32 b = BitConverter.ToInt32(a, 0);