читать определенное количество байтов из NetworkStream

Question

Я пытаюсь прочитать сообщение известной длины из сетевого потока.Я ожидал, что NetworkStream.Read() будет ждать возврата, пока буферный массив, который я ему предоставил, не заполнится.Если нет, то в чем смысл свойства ReadTimeout?

Пример кода, который я использую для проверки моей теории

public static void Main(string[] args)
{
    TcpListener listener = new TcpListener(IPAddress.Any, 10001);
    listener.Start();

    Console.WriteLine("Waiting for connection...");

    ThreadPool.QueueUserWorkItem(WriterThread);

    using (TcpClient client = listener.AcceptTcpClient())
    using (NetworkStream stream = client.GetStream())
    {
        Console.WriteLine("Connected. Waiting for data...");

        client.ReceiveTimeout = (int)new TimeSpan(0, 1, 0).TotalMilliseconds;
        stream.ReadTimeout = (int)new TimeSpan(0, 1, 0).TotalMilliseconds;

        byte[] buffer = new byte[1024];
        int bytesRead = stream.Read(buffer, 0, buffer.Length);

        Console.WriteLine("Got {0} bytes.", bytesRead);
    }

    listener.Stop();

    Console.WriteLine("Press any key to exit...");
    Console.ReadKey(true);
}

private static void WriterThread(object state)
{
    using (TcpClient client = new TcpClient())
    {
        client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 10001));
        using (NetworkStream stream = client.GetStream())
        {
            byte[] bytes = Encoding.UTF8.GetBytes("obviously less than 1024 bytes");
            Console.WriteLine("Sending {0} bytes...", bytes.Length);
            stream.Write(bytes, 0, bytes.Length);
            Thread.Sleep(new TimeSpan(0, 2, 0));
        }
    }
}

В результате этого:

Waiting for connection...
Sending 30 bytes...
Connected. Waiting for data...
Got 30 bytes.
Press any key to exit...

Существует ли стандартный способ чтения синхронизации, который возвращается только при чтении указанного количества байтов?Я уверен, что написать его не так уж сложно, но наличие свойств тайм-аута в TcpClient и NetworkStream вроде указывает на то, что оно уже должно работать таким образом.

Answer 1

Все, что вам гарантировано, это (один из):

• 0 байт (конец потока)
• не менее 1 байта (некоторые данные доступны; не означает, что нет 'больше или уже доступно)
• ошибка (время ожидания и т. д.)

Чтобы прочитать указанное количество байтов ... цикл:

int read = 0, offset = 0, toRead = ...
while(toRead > 0 && (read = stream.Read(buffer, offset, toRead)) > 0) {
    toRead -= read;
    offset += read;
}
if(toRead > 0) throw new EndOfStreamException();

Answer 2

TCP - это протокол потока байтов, который не сохраняет границы сообщений приложения.Он просто не способен «склеивать» байты таким образом.Цель таймаута чтения - указать, как долго вы хотите, чтобы чтение блокировалось.Но если хотя бы один байт данных может быть возвращен, операция чтения не будет блокироваться.

Если вам нужно вызвать чтение в цикле, пока вы не прочитаете полное сообщение, сделайте это.Уровень TCP не заботится о том, что вы считаете полным сообщением, это не его работа.