Клиент Серверное приложение

[tipabot]

Есть у меня клиент серверное приложение.
Есть клиент который посылает  сообщения в цикле с помощью метода Write (кстати клиент подключен синхронно к серверу с помощью метода tcpClient.Connect (ipEndPoint).  Есть сервер вот реализация

Код:

//ЭТО КОНСТРУКТОР
public Server(int port)
          {
            this.tcpListener = new TcpListener(IPAddress.Any, port);
            this.listenThread = new Thread(new ThreadStart(ListenForClients));
            this.listenThread.Start();
           }

private void ListenForClients()

        {
            this.tcpListener.Start();

            while (true)
            {
                //blocks until a client has connected to the server
                TcpClient client = this.tcpListener.AcceptTcpClient();
                //create a thread to handle communication with connected client
                Thread clientThread = new Thread(new ParameterizedThreadStart(HandleClientComm));
                clientThread.Start(client);
            }
        }

        

        private void HandleClientComm(object client)
        {
            TcpClient tcpClient = (TcpClient)client;

            //Обеспечивает основной поток данных для доступа к сети.
            //Чтобы отправлять и получать данные, используйте метод GetStream для получения объекта NetworkStream
            NetworkStream clientStream = tcpClient.GetStream();

            byte[] message = new byte[999999];
            int bytesRead;

            while (true)
            {
                bytesRead = 0;

                try
                {
                    //blocks until a client sends a message
                    bytesRead = clientStream.Read(message, 0, message.Length);
                }
                catch
                {
                    //a socket error has occured
                    break;
                }

                if (bytesRead == 0)
                {
                    //the client has disconnected from the server
                    break;
                }

                Console.WriteLine("bytesRead=" + bytesRead);

                ASCIIEncoding encoder = new ASCIIEncoding();
                String codingStr = encoder.GetString(message, 0, bytesRead);


                  //ЗДЕСЬ ИДЕТ ОБРАБОТКА ДАННЫХ
                 //ЗДЕСЬ ИДЕТ ОБРАБОТКА ДАННЫХ
                //ЗДЕСЬ ИДЕТ ОБРАБОТКА ДАННЫХ
               //ЗДЕСЬ ИДЕТ ОБРАБОТКА ДАННЫХ
            }
                 


            tcpClient.Close();
        }

Проблема в том что сервер не успевает обрабатывать приходящие данные и происходит искажение данных. В результате ексепшены. Ну например выход за пределы массива и т.д. Как сделать так чтоб перед тем как послать новую порцую инфы от клиента, сервер успевал обрабатывать поступившую до этого информацию. Может ответ и очевиден но у меня каша в башке по этой теме  

[RXL]

Проблема в том что сервер не успевает обрабатывать приходящие данные и происходит искажение данных. В результате ексепшены. Ну например выход за пределы массива и т.д. Как сделать так чтоб перед тем как послать новую порцую инфы от клиента, сервер успевал обрабатывать поступившую до этого информацию. Может ответ и очевиден но у меня каша в башке по этой теме 

Вероятно сервер тут не при чем, а проблема в обработчике данных. Например, несинхронизированный доступ потоков к общим данным.

[lapulya]

ну пусть сервер после обработки очередной порции данных сообщит клиенту, что он готов к следующей порции. Это бессорно поможет отцу русской демократии, если конечно проблема была в том, что обработчик сервера не успевает обрабатывать данные.

[Dale]

Проблема в том что сервер не успевает обрабатывать приходящие данные и происходит искажение данных. В результате ексепшены. Ну например выход за пределы массива и т.д.

Каким образом определили, что причина именно в этом? Протокол TCP умеет управлять потоком данных, поэтому никаких искажений данных из-за переполнения буфера на приемной стороне не должно быть.

[tipabot]

lapulya хотелось бы обойтись малой кровью
Dale

Каким образом определили, что причина именно в этом? Протокол TCP умеет управлять потоком данных, поэтому никаких искажений данных из-за переполнения буфера на приемной стороне не должно быть.

По идее вы правы. Но как объяснить следующее. Я поэкспериментировал на простом пример допустим я посылаю серверу информацию в ЦИКЛЕ от ОДНОГО клиента

Код:

int n = 0;
 while (n<5)
{
            clientStream.Write(Encoding.ASCII.GetBytes("1"));
            clientStream.Flush();
            clientStream.Write(Encoding.ASCII.GetBytes("2"));
            clientStream.Flush();
            clientStream.Write(Encoding.ASCII.GetBytes("3"));
            clientStream.Flush();
            clientStream.Write(Encoding.ASCII.GetBytes("4"));
            clientStream.Flush();
            n++;
}

В результате на сервер приходит
то
1 потом 234

то
1234 сразу
ну и т.д. По идее данные должны приходить отдельно т.е. сначала 1 потом 2 и т.д.

Со своими данными я не могу проверить так как у меня передаются куски файла, но похоже ситуация такая же.
Хотя есть еще непонятки с тем что например у меня  файл размером  406 байт. Я его передаю серваку.
Передача данных идет в цикле
1.передаю сначало 210 байт сервер принимает 210 байт; (Пишу и читаю с помощью методов Read и Write)
2.далее передаю остаток 196 бай, а на сервет приходит 199 откуда берутся эти 3 байта вообще не пойму  
Ошибок в коде не может быть т.к. я перед передачей и на приеме поставил вывод в лог размер байтовых массивов, короче бред.
Хотя ошибка может быть вызвана тем что я писал выше в этом посте.

[Dimka]

В результате на сервер приходит
то
1 потом 234

то
1234 сразу
ну и т.д. По идее данные должны приходить отдельно т.е. сначала 1 потом 2 и т.д.

По какой идее? Flush принудительно выталкивает буфер потока на прикладном уровне. Но Flush не означает "послать пакет" на сетевом уровне. И даже если сервер пакеты посылает, хотя не обязан, клиент не обязан на прикладном уровне запускать обработку каждого байта - он накапливает свой буфер.

[tipabot]

Dimka
Все пасиб разобрался, короче буду делать обработку данных когда они полностью передадутся на сервер, а не по частям, как я хотел. Я думал что если я посылаю определенное количество байт, то сервер должен это количество сразу принять (у меня в обработке на сервере массив должен быть всегда кратным 7 по этому если не кратный при итерации по нему вылетал ексепшен выхода за пределы массива)

[Dimka]

tipabot, можно передавать и по частям. Для этого тебе нужно придумать свой протокол прикладного уровня, в котором ты внутрь потока помещаешь разделительные метки частей. И в стек протоколов добавить свой протокол - т.е. поверх библиотечных Stream написать собственный, который умеет записывать и читать данные не байтовыми массивами, а твоими объектами/структурами.