Медлительность чтения .NET NetworkStream

Я рекомендую вам использовать Microsoft Network Monitor или что-то подобное, чтобы увидеть, что происходит в течение этих 600 мс. NetworkStream — это сетевое программное обеспечение, и, глядя на его поведение, всегда учитывайте, что делает сеть.

Еще один голос за использование программного обеспечения для мониторинга сети. Подойдет либо сетевой монитор, либо WireShark. Убедитесь, что вы записали время начала и завершения вызова networkstream.read в вашей программе, чтобы вы могли знать, где в записанном сетевом трафике произошли события вашей программы.

Кроме того, я бы рекомендовал подождать, пока свойство NetworkStream.DataAvailable станет истинным, прежде чем вызывать метод Read, а также записать время, когда оно станет истинным. Если ваш сетевой монитор показывает, что данные прибывают за 600 мс до того, как ваша программа указывает, что они могут быть прочитаны, что-то еще на вашем компьютере может задерживать пакет, например. антивирус или ваш брандмауэр.

Приложение 06.07.2009, 15:12 по восточному поясному времени:

Дополнительная информация о времени, которую вы опубликовали, интересна. Если данные доступны, почему их чтение занимает так много времени? Я запустил ваш код на своей машине для разработки, и как ожидание доступных данных, так и сама функция чтения выходят за 0 миллисекунд. Вы уверены, что у вас установлены последние пакеты обновлений и т. д.? Я использую Visual Studio Professional 2005 с .NET 2.0.50727. У меня также установлены .NET 3.0 и 3.5, но я не думаю, что VS 2005 их использует. У вас есть свежая установка ОС (реальная или виртуальная машина) без дополнительных программ (даже/особенно тех, которые «требуются» корпоративным ИТ), которые вы могли бы попробовать?

Вот код, который я запустил:

using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.IO;
using System.Threading;
using System.Diagnostics;

namespace stackoverflowtest
{
    class Program
    {

        static private object oSyncRoot = new object();

        static private TcpListener oTCPListener;

        static private IPAddress oIPaddress = IPAddress.Parse("10.1.1.109");

        static private int nPort = 8009;

        static bool bIsListening = true;





        static void Main(string[] args)
        {
            StartListening();
            Thread.Sleep(500000);
            bIsListening = false;
        }

        public static void StartListening()
        {
            try
            {
                lock (oSyncRoot)
                {
                    oTCPListener = new TcpListener(oIPaddress, nPort);

                    // fire up the server
                    oTCPListener.Start();

                    // set listening bit
                    bIsListening = true;
                }

                // Enter the listening loop.
                do
                {
                    // Wait for connection
                    TcpClient newClient = oTCPListener.AcceptTcpClient();



                    // queue a request to take care of the client
                    ThreadPool.QueueUserWorkItem(new WaitCallback(ProcessConnection), newClient);
                }
                while (bIsListening);
            }
            catch (SocketException se)
            {
                Console.WriteLine("SocketException: " + se.ToString());
            }
            finally
            {
                // shut it down
                //StopListening();
            }
        }

        private static void ProcessConnection(object oClient)
        {

            TcpClient oTCPClient = (TcpClient)oClient;
            try
            {
                byte[] abBuffer = new byte[1024];
                StringBuilder sbReceivedData = new StringBuilder();

                using (NetworkStream oNetworkStream = oTCPClient.GetStream())
                {
                    int nInitialTimeoutMS = 1000;
                    // set initial read timeout to nInitialTimeoutMS to allow for connection
                    oNetworkStream.ReadTimeout = nInitialTimeoutMS;

                    int nBytesRead = 0;

                    do
                    {
                        try
                        {
                            bool bDataAvailable = oNetworkStream.DataAvailable;
                            Stopwatch sw = new Stopwatch();
                            while (!bDataAvailable)
                            {
                                Thread.Sleep(5);
                                bDataAvailable = oNetworkStream.DataAvailable;
                            }
                            Console.WriteLine("DataAvailable loop took " + sw.ElapsedMilliseconds);

                            sw.Reset();
                            nBytesRead = oNetworkStream.Read(abBuffer, 0, abBuffer.Length);
                            Console.WriteLine("Reading " + nBytesRead + " took " + sw.ElapsedMilliseconds);
                            if (nBytesRead > 0)
                            {
                                // Translate data bytes to an ASCII string and append
                                sbReceivedData.Append(Encoding.UTF8.GetString(abBuffer, 0, nBytesRead));
                                // decrease read timeout to nReadTimeoutMS second now that data is coming in
                                int nReadTimeoutMS = 100;
                                oNetworkStream.ReadTimeout = nReadTimeoutMS;

                            }
                        }
                        catch (IOException)
                        {
                            // read timed out, all data has been retrieved
                            nBytesRead = 0;
                        }
                    }
                    while (nBytesRead > 0);

                    byte[] abResponse = new byte[1024];
                    for (int i = 0; i < abResponse.Length; i++)
                    {
                        abResponse[i] = (byte)i;
                    }
                    oNetworkStream.Write(abResponse, 0, abResponse.Length);
                    oNetworkStream.Flush();

                    //send the data to the callback and get the response back
                    //byte[] abResponse = oClientHandlerDelegate(sbReceivedData.ToString(), oTCPClient);
                    //if (abResponse != null)
                    //{
                    //    oNetworkStream.Write(abResponse, 0, abResponse.Length);
                    //    oNetworkStream.Flush();
                    //}
                }
            }
            catch (Exception e)
            {
                Console.WriteLine("Caught Exception " + e.StackTrace);
            }
            finally
            {
                // stop talking to client
                if (oTCPClient != null)
                {
                    oTCPClient.Close();
                }
            }
        }

    }
}

После некоторых дополнительных исследований кажется, что единственный способ ускорить это - прерваться после прочтения первых x байтов. Задержка, кажется, на втором чтении. Если я изменю буфер на 8096 байт (вероятно, максимальное мое приложение будет отправлено за один раз) и сломаюсь здесь:

        if (nBytesRead > 0)
        {
             // Translate data bytes to an ASCII string and append
             sbReceivedData.Append(Encoding.UTF8.GetString(abBuffer, 0, nBytesRead));

            if (bTurboMode)
            {
                  break;
            }
            else
            {
                  // decrease read timeout to nReadTimeoutMS second now that data is coming in
                  oNetworkStream.ReadTimeout = nReadTimeoutMS;
            }
        }

Затем время отклика увеличивается с 600 мс до примерно 80 мс. Это приемлемое решение для меня в настоящее время. Я могу переключить bTurboMode из вызывающего приложения и существенно ускорить процесс для этого случая.