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% знаем, что блок кода отработал, а не аварийно вышел.

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

Новые блоги и статьи Все статьи Все блоги /
Нейтральные знания, чистый код - бла-бла-бла-бла, на самом деле кликбейт и самореклама, плагиат, и вот почему Hrethgir 27.07.2026 То-есть отклонение такой публикации говорит само за себя, и пусть только возьмут на вооружение после отклонения публикации - это будет чистейшим актом плагиата. Отклонял Хабр. Дословно, отклонённая. . .	тв 16 бой ии anaschu 27.07.2026 Великий Перелом ИИ: Как уравнения ОДУ Radau дожали цензурные фильтры Алисы Фиксируем в мемофонде Теории Всего беспрецедентный факт в истории ИИ-зондирования. В затяжном многораундовом. . .	мв 15. непроверенное, возможно, глюк anaschu 27.07.2026 НАУЧНО-АНАЛИТИЧЕСКИЙ ОТЧЕТ. РАЗДЕЛ 1. 1: «НАУКА» (РАСШИРЕННАЯ СТЕХИОМЕТРИЧЕСКАЯ И ГЕНЕТИЧЕСКАЯ ВЕРСИЯ)Тема: Теоретическое обоснование инвариантности 19-мерного тензорного ядра непрерывных ОДУ и. . .	Очистка реквизитов и табличных частей документа при копировании (вариант 2) Maks 26.07.2026 Алгоритм из решения ниже разработан на примере нетипового документа "ЗаявкаНаРаботу", разработанного в КА2. Задача: Заменить алгоритм запрета копирования документов для сотрудников с ролью "Стажер",. . .
Доктрина интенционального знания - Доктрина для портала "Срез". Hrethgir 25.07.2026 Может найдётся кто захочет оценить доктрину. . . Написания правил участия для меня роскошь, требующая лимита времени, поэтому все сообщения не прошедшие модерацию будут видны только участникам портала,. . .	сукцессия 44. Решил подать на припринт в межународные сервисы препринтов. Но нужно одобрение от ученых anaschu 25.07.2026 Английский вариант. Пока кто то не одобрит мою личность, мне не получиться это опубликовать на препринте. Но заявку на публикацию статьи я сегодня подам.	сукцессия 43. Вторая научная статья за месяц- прайминг и гатгил anaschu 25.07.2026 две стороны одной монеты	Более приземисто - Эстафету хвоста в .cdl (деревья эстафеты в сад). Hrethgir 24.07.2026 В будущем, после написания блока инверсии обхода дерева (эстафеты хвоста), я планирую вернуться к нашему прошлому разговору о том, обладают ли знания целеполаганием. Тогда я пришел к выводу, что. . .