TCP (Клиент-сервер) - потеря данных

@SnakeLight · Регистрация: 23.09.2008

Студворк — интернет-сервис помощи студентам

Добрый день, меня интересует такой вопрос, я имею два приложения клиент-сервер написанные на TCP с использованием асинхронной передачи данных. Так вот, при запуске большого количества клиентов, данные начинают теряться.
Не могу понять почему.
Ниже прилагаю код

Клиент

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
using System;
using System.Threading;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
using System.Collections.Generic;
 
namespace сlient
{
 
    class Program
    {
        const int startCount = 10000;
        static int countClient = 0;
        static int countServer = 0;
        Guid guid = Guid.NewGuid();
 
        void Connect(object obj)
        {
            try
            {
 
                IPEndPoint ep = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8080);
                TcpClient client = new TcpClient();
                client.Connect(ep);
                string request;
                StringBuilder sb = new StringBuilder();
                using (NetworkStream stream = client.GetStream())
                {
                    request = obj.ToString() + '\0';
                    Console.WriteLine("Client: " + request);
 
                    stream.Write(Encoding.UTF8.GetBytes(request), 0, request.Length);
                    countServer = countServer + 1;
                    int i;
                    while ((i = stream.ReadByte()) != 0)
                    {
                        sb.Append((char)i);
                    }
                }
                client.Close();
 
                if (!request.Contains(guid.ToString()))
                {
                    Logfile.LogFile("Вернулось другое значение" + sb.ToString());
                }
 
                Console.WriteLine(sb.ToString());
 
 
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
 
        }
 
        void start()
        {
            using (var threadCount = new CountdownEvent(startCount))
            {
                for (int i = startCount; i > 0; i--)
                {
                    ThreadPool.QueueUserWorkItem(
                        x
                        =>
                        {
                            countClient = countClient + 1;
                            Connect((object)string.Format("Send iteration:{0}  --- " + guid + "", countClient));
                            threadCount.Signal();
 
                        });
                }
 
                /*        while (true)
                        {
 
                            string str = Console.ReadLine();
                            ThreadPool.QueueUserWorkItem(Connect, (object)str);
               }*/
                threadCount.Wait();
            }
            if (countClient == startCount)
            {
                Logfile.LogFile("Client[" + guid + "] - отправлено: [" + countClient.ToString() + "] - " + "пришло: [" + countServer.ToString() + "]");
            }
            else
            {
                Logfile.LogFile("Client[" + guid + "] - отправлено: [" + countClient.ToString() + "] - " + "пришло: [" + countServer.ToString() + "]");
            }
        }
 
 
        static void Main(string[] args)
        {
            Program p = new Program();
            p.start();
 
            Console.ReadKey();
        }
    }
}

Сервер

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
using System;
using System.Threading;
using System.Net;
using System.Net.Sockets;
using System.Text;
 
namespace server
{
    public class server
    {
        ManualResetEvent tcpClientConnected = new ManualResetEvent(false);
 
        void ProcessIncomingData(object obj)
        {
            try
            {
                TcpClient client = (TcpClient)obj;
                StringBuilder sb = new StringBuilder();
 
                using (NetworkStream stream = client.GetStream())
                {
                    int i;
                    while ((i = stream.ReadByte()) != 0)
                    {
                        sb.Append((char)i);
                    }
 
                    string reply = "Server: " + sb.ToString() + '\0';
                    //  stream.Write(Encoding.ASCII.GetBytes(reply), 0, reply.Length);
                    stream.Write(System.Text.Encoding.UTF8.GetBytes(reply), 0, reply.Length);
                }
                Console.WriteLine(sb.ToString());
            }
            catch(Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }
 
        void ProcessIncomingConnection(IAsyncResult ar)
        {
            //Thread.Sleep(10000);
            TcpListener listener = (TcpListener)ar.AsyncState;
            TcpClient client = listener.EndAcceptTcpClient(ar);
 
            ThreadPool.QueueUserWorkItem(ProcessIncomingData, client);
            tcpClientConnected.Set();
        }
 
        public void start()
        {
            IPEndPoint endpoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8080);
            TcpListener listener = new TcpListener(endpoint);
            listener.Start();
 
            while (true)
            {
                tcpClientConnected.Reset();
                listener.BeginAcceptTcpClient(new AsyncCallback(ProcessIncomingConnection), listener);
                tcpClientConnected.WaitOne();
            }
        }
    }
 
    class Program
    {
        static void Main(string[] args)
        {
            server s = new server();
            s.start();
        }
    }
}

@SnakeLight · 20.04.2017, 11:35 **[ТС]**

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

не понял в чем различия от моего варианта. И да, Console.WriteLine("Попытка отправить сообщение заново..."); только выводит сообщение, заново ничего не отправляется.

А вы цикл while(true) видели? )

@Wolfdp · 20.04.2017, 11:45

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

цикл while(true) видели?

нет, проглядел. Да, в таком случае будет переотправлять. На будущее -- вместо статического while(true) c последующим break; лучше делать так

C#
1
2
3
4
5
6
7
8
9
10
11
var noCompleted = true;
do
{
 
try{
// action
noCompleted = false;
}
catch{}
 
}while(noCompleted);

принцип работы в текущей задачи это особо не меняет, но позволяет выполнить еще какие-то действия после установки флага, в отличии от break и дальше по коду мы 100% знаем, что блок кода отработал, а не аварийно вышел.

@SnakeLight · 20.04.2017, 11:48 **[ТС]**

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

нет, проглядел. Да, в таком случае будет переотправлять. На будущее -- вместо статического while(true) c последующим break; лучше делать так

C#
1
2
3
4
5
6
7
8
9
10
11
var noCompleted = true;
do
{
 
try{
// action
noCompleted = false;
}
catch{}
 
}while(noCompleted);

принцип работы в текущей задачи это особо не меняет, но позволяет выполнить еще какие-то действия после установки флага, в отличии от break и дальше по коду мы 100% знаем, что блок кода отработал, а не аварийно вышел.

Да я видел как то на одном форуме такую реализацию, довольно интересная и правильная постановка входа и выхода из цикла.
Ну можно сказать проблема решена. Всем спасибо

Новые блоги и статьи Все статьи Все блоги /
Мобильное приложение ColorStep pavlinmavlin 17.09.2026 Реализовал приложение Красный, Зеленый, Синий в Unity3d + c#. Название изменил на ColorStep. Приложение прошло модерацию и теперь доступно для скачивания. Делал его сам, шаг за шагом — и вот,. . .	Запрет дублирования строк в табличной части Maks 13.09.2026 Реализация из решения ниже выполнена на нетиповом справочнике "Нормы ТО" с табличной часть "Виды ТО", разработанного в КА2, со следующими реквизитами: - ВидТО (СправочникСсылка. ВидыТО); - ВидГСМ. . .	Скрипты Tampermonkey для CyberForum, ChatGPT, Claude и пр. Jin X 06.09.2026 Скрипты Tampermonkey для CyberForum, ChatGPT, Claude и пр. Работая с форумом и нейросетями в браузере часто хочется что-то подкорректировать или добавить какого-то функционала. Ниже прикреплён. . .	Программа опроса у.з. расходомера SLS-720F Argus19 02.09.2026 Программа опроса у. з. расходомера SLS-720F Программа опрашивает один раз в минуту три ультразвуковых расходомера SLS-720F через интерфейс RS-485 по протоколу Modbus RTU. Опрашиваются регистры. . .
Hyper-V: Компьютер должен поддерживать доверенный платформенный модуль 2.0. Maks 31.08.2026 При установке Windows 11 на виртуальную машину Hyper-V 2-го поколения вылезла такая ошибка: Решение: в параметрах виртуальной машины, в разделе "Безопасность" (Security) активировать флаг. . .	Архитектура биовида Стива в Майнкрафте: Зачем бонобо кубический каннибализм anaschu 30.08.2026 Кубический Вагинокапитализм в Minecraft: Математический инвариант ОДУ и рок Стивов-бонобо Главная задача разработанной «Модели Всего» — наглядно продемонстрировать наличие системной «судьбы». . .	Оттачиваю умение писать js программы. russiannick 30.08.2026 Проектом выходного дня стало написание Книги шифров Виженера. Итогом стала версия 200, синий туман. Синий туман назван так, потому что замораживает текст под собой. Нажатие синих кнопок управляют. . .	мат медиц модель 30. презентация проекта anaschu 27.08.2026 хоп хоп хоп хидахоп, а я кладую))