Параллельное подключение к нескольким устройствам (+ обработка json)

@rushaks · Регистрация: 18.02.2016

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

Приветствую форумчан!

Помогите пожалуйста разобраться в реализации следующей идеи:

Есть устройства (видеодетекторы), которые при подключении на порт выплевывают json с информацией.

json вида

C#
1
2
3
4
5
6
7
8
9
{
  "CounterEvent": {
    "AreaID": 0,
    "Class": 0,
    "CounterID": 1,
    "Speed": 19.81940460205078,
    "Time": "2020-10-22T08:55:33"
  }
}

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
{
  "Statistics": {
    "AreaID": 0,
    "CarsBackward": [
      1,
      4,
      11,
      7,
      3,
      1
    ],
    "CarsForward": [
      2,
      4,
      2,
      2,
      0,
      1
    ],
    "CounterID": 1,
    "Density": 4.664276123046875,
    "DistanceAvg": 94.03314971923828,
    "DistanceDev": 1946351.625,
    "FullnessAvg": 0,
    "FullnessDev": 0,
    "GapAvg": 2.2727277278900146,
    "GapDev": 12.31408405303955,
    "Intensity": 0.19298245012760162,
    "SpeedAvg": 148.94847106933594,
    "SpeedDev": 95721.7109375
  }
}

Что я пытаюсь сделать: у меня есть база с перечнем этих устройств (детекторов), которые я хочу одновременно опрашивать. Получилось пока что одно устройство опросить (не могу понять как мне сделать: цикл, создать несколько потоков или что то другое?).

Вот мой код как я это сделал :

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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
using Newtonsoft.Json;
 
namespace JsonTest2
{
    class Program
    {
        public static int count = 0;
        public static List<string> select_ip_device = new List<string>();
        static void Main(string[] args)
        {
            Thread thread1 = new Thread(() => GetData("172.22.8.11"));
            thread1.Start();
        }
 
        static void GetIp()
        {
            SqlConnection conn = new SqlConnection(@"Data source=localhost,16252; Initial Catalog =BASE; Integrated Security = false; User ID =ID; Password=PW");
            conn.Open();
            SqlDataReader dataReader;
            SqlCommand myCommand = conn.CreateCommand();
            myCommand.CommandText = "SELECT ip FROM base_detect where active = 1";
            dataReader = myCommand.ExecuteReader();
            while (dataReader.Read())
            {
                select_ip_device.Add(dataReader.GetString(0));
            }
        }
 
 
        static void GetData(string ip)
        {
            int count;
            for (count = 1; ; count++)
            {
                GetVdt(ip);
            }
        }
 
        static void GetVdt(string ip)
        {
            // Инициализация
            string address = ip;
            int port = 41358;
            TcpClient client = new TcpClient(address, port);
            NetworkStream stream = client.GetStream();
            try
            {
                byte[] readingData = new byte[2048];
                String responseData = String.Empty;
                StringBuilder completeMessage = new StringBuilder();
                int numberOfBytesRead = 0;
                SqlConnection conn = new SqlConnection(@"Data source=localhost,16252; Initial Catalog =BASE; Integrated Security = false; User ID =USER; Password=PW");
                conn.Open();
                
                while (true)
                {
                    count++;
                    numberOfBytesRead = stream.Read(readingData, 0, readingData.Length);
                    completeMessage.AppendFormat("{0}", Encoding.UTF8.GetString(readingData, 0, numberOfBytesRead));
                    string data = completeMessage.ToString();
                    var obj = JsonConvert.DeserializeObject<Root>(data);
                    string str1 = "CounterEvent";
                    string str2 = "Statistics";
                    SqlCommand myCommand = conn.CreateCommand();
                    if (data.Contains(str1))
                    {
 
                        Console.ForegroundColor = ConsoleColor.Green;
                        Console.WriteLine("*****Событие*****");
                        Console.WriteLine("ID устройства: " + address);
                        Console.WriteLine("Время: " + obj.CounterEvent.Time.ToString());
                        Console.WriteLine("Скорость: " + obj.CounterEvent.Speed.ToString());
                        Console.WriteLine("Класс ТС: " + obj.CounterEvent.Class.ToString());
                        Console.WriteLine("Номер рамки: " + obj.CounterEvent.AreaID.ToString());
                        Console.ResetColor();
                        Console.WriteLine("Номер записи(count) = " + count);
 
                        string id = Convert.ToString(address);
                        string time = Convert.ToString(obj.CounterEvent.Time.ToString());
                        string speed = Convert.ToString(obj.CounterEvent.Speed.ToString());
                        string classTs = Convert.ToString(obj.CounterEvent.Class.ToString());
                        string numArea = Convert.ToString(obj.CounterEvent.AreaID.ToString());
                        string CounterID = Convert.ToString(obj.CounterEvent.CounterID.ToString());
 
                        myCommand.CommandText = "INSERT INTO CounterEvent (AreaID, Class, CounterID, Speed, device, Time) VALUES (@AreaID, @Class, @CounterID, @Speed, @device, @Time)";
                        myCommand.Parameters.Add("@AreaID", SqlDbType.Int, 10);
                        myCommand.Parameters["@AreaID"].Value = numArea;
                        myCommand.Parameters.Add("@Class", SqlDbType.NVarChar, 10);
                        myCommand.Parameters["@Class"].Value = classTs;
                        myCommand.Parameters.Add("@CounterID", SqlDbType.NVarChar, 10);
                        myCommand.Parameters["@CounterID"].Value = CounterID;
                        myCommand.Parameters.Add("@Speed", SqlDbType.NVarChar, 20);
                        myCommand.Parameters["@Speed"].Value = speed;
                        myCommand.Parameters.Add("@Time", SqlDbType.DateTime, 50);
                        myCommand.Parameters["@Time"].Value = time;
                        myCommand.Parameters.Add("@device", SqlDbType.NVarChar, 50);
                        myCommand.Parameters["@device"].Value = id;
                        int Uspeh = myCommand.ExecuteNonQuery();
                        conn.Close();
                    }
                    else
                        if (data.Contains(str2))
                    {
                        Console.ForegroundColor = ConsoleColor.Red;
                        Console.WriteLine("****Статистика****");
                        Console.WriteLine("ID устройства: " + address);
                        Console.ResetColor();
                        Console.WriteLine("Номер записи(count) = " + count);
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }
        }
    }
 
    public class CounterEvent
    {
        public int AreaID { get; set; }
        public int Class { get; set; }
        public int CounterID { get; set; }
        public double Speed { get; set; }
        public DateTime Time { get; set; }
    }
 
    public class Statistics
    {
        public int AreaID { get; set; }
        public List<int> CarsBackward { get; set; }
        public List<int> CarsForward { get; set; }
        public int CounterID { get; set; }
        public double Density { get; set; }
        public double DistanceAvg { get; set; }
        public double DistanceDev { get; set; }
        public int FullnessAvg { get; set; }
        public int FullnessDev { get; set; }
        public double GapAvg { get; set; }
        public double GapDev { get; set; }
        public double Intensity { get; set; }
        public double SpeedAvg { get; set; }
        public double SpeedDev { get; set; }
    }
 
    public class Root
    {
        public CounterEvent CounterEvent { get; set; }
        public Statistics Statistics { get; set; }
    }
}

Что я хочу в итоге сделать: автоматически подгружать из базы список устройств и параллельно к ним подключаться, и соответственно обрабатывать json с каждого устройства параллельно. Помогите пожалуйста разобраться с этим. Так же хочу сделать функционал, при котором при "зависании устройства", "невозможности подключения" автоматически отправлялась команда не перезагрузку по такой ссылке http://ip:6738/reload

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами 8Observer8 20.02.2026 Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .	Конвертировать закладки radiotray-ng в m3u-плейлист damix 19.02.2026 Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .	Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI Eddy_Em 18.02.2026 Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .	Камера Toupcam IUA500KMA Eddy_Em 12.02.2026 Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу zbw 12.02.2026 И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.	«Знание-Сила» zbw 12.02.2026 «Знание-Сила» «Время-Деньги» «Деньги -Пуля»	SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров 8Observer8 12.02.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .	SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 11.02.2026 Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .