Отправка больших объектов по TCP: «Конец потока обнаружен до завершения анализа» - PullRequest
Новая
       15

Отправка больших объектов по TCP: «Конец потока обнаружен до завершения анализа»

2 голосов
/ 31 августа 2010

Я получаю SerializationException всякий раз, когда пытаюсь десериализовать список двойников из NetworkStream:

Конец потока, обнаруженный до завершения анализа

У меня простая клиент-серверная архитектура: мой TcpTransportClient упаковывает функциональность TcpClient, и я использую два основных метода: Send (отправляет сообщение) и Receive (блокирует до получения сообщения).

Функция Send принимает Message, сериализует его с помощью BinaryFormatter и отправляет байты через NetworkStream. 

public void Send(Message message)
{
    if (message == null)
    {
        throw new TransportException("Invalidate Parameter In Send Call");
    }

    if (_tcpClient == null || !_tcpClient.Connected)
    {
        throw new TransportException("Client Not Connected");
    }

    lock (_sync)
    {
        // Serialzie the message
        MemoryStream memStream = new MemoryStream();
        _serializer.Serialize(memStream, message);

        // Get the bytes of of the memory stream
        byte[] buffer = memStream.GetBuffer();

        // Write the message to the network stream
        NetworkStream networkStream = _tcpClient.GetStream();
        networkStream.Write(buffer, 0, buffer.Length);
        networkStream.Flush();
    }
}

Функция приема считывает байты в буфериз NetworkStream, затем десериализует сообщение, используя BinaryFormatter: 

public Message Receive()
{
    if (_tcpClient == null || !_tcpClient.Connected)
    {
        throw new TransportException("Client Not Connected");
    }

    byte[] buffer;
    MemoryStream memStream = new MemoryStream();
    NetworkStream netStream = _tcpClient.GetStream();
    try
    {
        do
        {
            // Allocate a new buffer
            buffer = new byte[_tcpClient.ReceiveBufferSize];

            // Read the message buffer
            int sizeRead = netStream.Read(buffer, 0, buffer.Length);

            // Write the buffer to the memory stream
            memStream.Write(buffer, 0, sizeRead);

        } while (netStream.DataAvailable);

        // Reset the memory stream position
        memStream.Position = 0;

        // Deserialize the message
        object tmp = _deserializer.Deserialize(memStream); // <-- The exception is here!

        // Cast the object to a message
        return (Message)tmp;
    }
    catch (System.Exception e)
    {
        if (_tcpClient == null || !_tcpClient.Connected)
        {
            throw new TransportException("Client Not Connected");
        }
        else
        {
            throw e;
        }
    }
}

У меня есть базовый поток отправки: 

TcpTransportClient client = new TcpTransportClient(GetLocalAddress(), servicePort);
client.Connect();

Thread sendThread = new Thread(() =>
{
    List<double> dataSet = new List<double>();
    for (double d = 0.0; d < 500.0; d++)
    {
        dataSet.Add(d);
    }

    while (true)
    {
        try
        {
            // Serialize the data set
            MemoryStream memStream = new MemoryStream();
            BinaryFormatter binFormat = new BinaryFormatter();
            binFormat.Serialize(memStream, (object)dataSet);

            // Create a message
            Message msg = new Message();

            // Hold the object bytes in an opaque field
            msg.SetFieldValue(1000, memStream.GetBuffer());

            // Set the message topic
            msg.SetTopic("client.dataSet");

            // Send the message
            client.Send(msg);

            // Sleep
            Thread.Sleep(3000);
        }
        catch (TransportException)
        {
            break;
        }
        catch(Exception)
        {
            //ignore it
        }
    }
});
sendThread.IsBackground = true;
sendThread.Start();

И поток приема, который запускается всякий раз, когдаTcpClient принято: 

public void HandleAcceptedClient(TcpTransportClient client)
{
    Thread receiveThread = new Thread(() =>
    {
        while (true)
        {
            try
            {
                Message msg = client.Receive();
                Trace.WriteLine("Server Received: " + msg.GetTopic());
                byte[] buffer = msg.GetFieldOpaqueValue(1000);
                MemoryStream memStream = new MemoryStream(buffer);
                BinaryFormatter binFormat = new BinaryFormatter();

                List<double> dataSet = (List<double>)binFormat.Deserialize(memStream);
                if (dataSet.Count == 500)
                {
                    Trace.WriteLine(DateTime.Now + ": OK");
                }
                else
                {
                    Trace.WriteLine(DateTime.Now + ": FAIL");
                }
            }
            catch (TransportException)
            {
                break;
            }
            catch(Exception)
            {
                // ignore it
            }

        }

    });
    receiveThread.IsBackground = true;
    receiveThread.Start();
}

Исключение всегда возникает, когда я пытаюсь десериализовать сообщение в методе Receive моего TcpTransportClient, но проблема возникает, только если я помещаю некоторые данные внабор данных.Как правильно отправить список значений по сети и успешно десериализовать их на принимающей стороне?

PS Я попробовал решение в почти идентичном вопросе , но это не такработа: я все еще получаю то же исключение.

Ответы [ 2 ]

4 голосов
/ 31 августа 2010
4 голосов
/ 31 августа 2010

while (netStream.DataAvailable);

Это не правильно.Вам следует прекратить чтение, когда вызов Read () вернет 0. Свойство DataAvailable просто сообщает вам, будет ли заблокирован вызов Read (), ожидая, когда сервер сможет его догнать.

...