С Новым годом! Форум программистов, компьютерный форум, киберфорум
C/C++: WinAPI
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.60/5: Рейтинг темы: голосов - 5, средняя оценка - 4.60
1 / 1 / 0
Регистрация: 21.02.2018
Сообщений: 10

Не так работает многопоточность сервера и клиента

19.04.2018, 20:25. Показов 1092. Ответов 2
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Здравствуйте! Мне дана следующая задача. Сервер создаёт n процессов, указывая для каждого время его жизни в секундах. Должно быть предусмотрено специальное значение под бесконечное время. Клиент должен запуститься, просуществовать без учёта воздействия на него пользователя заданное ему время и завершиться. Все это реализуется на сокетах

Сервер у меня запускает n клиентов путем вызова экзе-файла клиента. Проблема в том, что время я могу ввести только для последнего клиента, а мне нужно для каждого. Помогите пожалуйста, бьюсь уже целый день над этой проблемой. Ниже код клиента и сервера, и скриншот результата:
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
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
// Пример простого TCP – эхо сервера
#define _CRT_SECURE_NO_WARNINGS
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#pragma comment(lib,"Ws2_32.lib")
#include <stdio.h>
#include <winsock2.h>  // Wincosk2.h должен быть 
// подключен раньше windows.h!
#include <windows.h>
#include <iostream>
#include <ctime>
#define MY_PORT    743
// Порт, который слушает сервер
 
// макрос для печати количества активных
// пользователей 
#define PRINTNUSERS if (nclients)\
  printf("%d user on-line\n",nclients);\
  else printf("No User on line\n");
 
// прототип функции, обслуживающий
// подключившихся пользователей
DWORD WINAPI SexToClient(LPVOID client_socket);
 
// глобальная переменная – количество
// активных пользователей 
int nclients = 0;
int client;
using namespace std;
int main(int argc, char* argv[])
{
    setlocale(LC_ALL, "Russian");
    char buff[1024];    // Буфер для различных нужд
 
    printf("TCP SERVER DEMO\n");
 
    // Шаг 1 - Инициализация Библиотеки Сокетов
    // Т.к. возвращенная функцией информация
    // не используется ей передается указатель на
    // рабочий буфер, преобразуемый
    // к указателю  на структуру WSADATA.
    // Такой прием позволяет сэкономить одну
    // переменную, однако, буфер должен быть не менее
    // полкилобайта размером (структура WSADATA
    // занимает 400 байт)
    /*if (WSAStartup(0x0202, (WSADATA *)&buff[0]))
    {
        // Ошибка!
        printf("Error WSAStartup %d\n",
            WSAGetLastError());
        return -1;
    }*/
    TCHAR szPath[] = TEXT("C:\\Users\\Никита\\Documents\\Visual Studio 2015\\Projects\\КЛИЕНТ\\Debug\\КЛИЕНТ.exe"); // Путь к файлу
                                                                                                                    // Необходимые для запуска процесса структуры
    STARTUPINFO si;
    PROCESS_INFORMATION pi;
    memset(&si, 0, sizeof(si));
    si.cb = sizeof(si);
    memset(&pi, 0, sizeof(pi));
    printf("Ожидание подключений\n");
    cout << "Введите количество клиентов:" << endl;
    cin >> client;
    for (int i = 0; i < client; i++) {
        Sleep(5);
        CreateProcess(NULL, szPath, NULL, NULL, FALSE, 0, NULL, NULL, &si, &pi);
        //TerminateProcess(pi.hProcess, 0);
        //CloseHandle(pi.hProcess);
        //CloseHandle(pi.hThread);
    }
 
 
        if (WSAStartup(0x0202, (WSADATA *)&buff[0]))
        {
            // Ошибка!
            printf("Error WSAStartup %d\n",
                WSAGetLastError());
            return -1;
        }
        // Шаг 2 - создание сокета
        SOCKET mysocket;
        // AF_INET     - сокет Интернета
        // SOCK_STREAM  - потоковый сокет (с
        //      установкой соединения)
        // 0      - по умолчанию выбирается TCP протокол
        if ((mysocket = socket(AF_INET, SOCK_STREAM, 0)) < 0)
        {
            // Ошибка!
            printf("Error socket %d\n", WSAGetLastError());
            WSACleanup();
            // Деиницилизация библиотеки Winsock
            return -1;
        }
 
        // Шаг 3 связывание сокета с локальным адресом
        sockaddr_in local_addr;
        local_addr.sin_family = AF_INET;
        local_addr.sin_port = htons(MY_PORT);
        // не забываем о сетевом порядке!!!
        local_addr.sin_addr.s_addr = 0;
        // сервер принимает подключения
        // на все IP-адреса
 
        // вызываем bind для связывания
        if (bind(mysocket, (sockaddr *)&local_addr,
            sizeof(local_addr)))
        {
            // Ошибка
            printf("Error bind %d\n", WSAGetLastError());
            closesocket(mysocket);  // закрываем сокет!
            WSACleanup();
            return -1;
        }
 
        // Шаг 4 ожидание подключений
        // размер очереди – 0x100
        if (listen(mysocket, 0x10000))
        {
            // Ошибка
            printf("Error listen %d\n", WSAGetLastError());
            closesocket(mysocket);
            WSACleanup();
            return -1;
        }
 
 
 
        // Шаг 5 извлекаем сообщение из очереди
        SOCKET client_socket;    // сокет для клиента
        sockaddr_in client_addr;    // адрес клиента
                                    // (заполняется системой)
 
                                    // функции accept необходимо передать размер
                                    // структуры
        int client_addr_size = sizeof(client_addr);
 
        // цикл извлечения запросов на подключение из
        // очереди
        while ((client_socket = accept(mysocket, (sockaddr *)
            &client_addr, &client_addr_size)))
        {
            nclients++;      // увеличиваем счетчик
                             // подключившихся клиентов
 
                             // пытаемся получить имя хоста
            HOSTENT *hst;
            hst = gethostbyaddr((char *)
                &client_addr.sin_addr.s_addr, 4, AF_INET);
 
            // вывод сведений о клиенте
            printf("+%s [%s] new connect!\n",
                (hst) ? hst->h_name : "",
                inet_ntoa(client_addr.sin_addr));
            PRINTNUSERS
 
                // Вызов нового потока для обслужвания клиента
                // Да, для этого рекомендуется использовать
                // _beginthreadex но, поскольку никаких вызов
                // функций стандартной Си библиотеки поток не
                // делает, можно обойтись и CreateThread
                DWORD thID;
            CreateThread(NULL, NULL, SexToClient,
                &client_socket, NULL, &thID);
        }
        client--;
 
 
    
    return 0;
}
 
// Эта функция создается в отдельном потоке и
// обсуживает очередного подключившегося клиента
// независимо от остальных
DWORD WINAPI SexToClient(LPVOID client_socket)
{
    cout << "время: "<<endl;
    int n;
    cin >> n;
    SOCKET my_sock;
    my_sock = ((SOCKET *)client_socket)[0];
    char buff[1024];
    sprintf(buff, "%d", n);
 
    // отправляем клиенту число
    send(my_sock, buff, sizeof(buff), 0);
 
    // цикл эхо-сервера: прием строки от клиента и
    // возвращение ее клиенту
    int bytes_recv;
    while ((bytes_recv = recv(my_sock, &buff[0], sizeof(buff), 0)) && bytes_recv != SOCKET_ERROR)
        send(my_sock, &buff[0], bytes_recv, 0);
 
    // если мы здесь, то произошел выход из цикла по
    // причине возращения функцией recv ошибки –
    // соединение клиентом разорвано
    nclients--; // уменьшаем счетчик активных клиентов
    printf("-disconnect\n"); PRINTNUSERS
 
    // закрываем сокет
    closesocket(my_sock);
    //system("pause");
    return 0;
}
void Sleep(int time)
{
    return Sleep((DWORD)time * 1000);
}
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
// Пример простого TCP клиента
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#pragma comment(lib,"Ws2_32.lib")
#include <stdio.h>
#include <string.h>
#include <winsock2.h>
#include <windows.h>
 
 
#define PORT 743
#define SERVERADDR "127.0.0.1"
#include<iostream>
 
void Sleep(int time)
{
    return Sleep((DWORD)time * 1000);
}
 
int main(int argc, char* argv[])
{
    setlocale(LC_ALL, "Russian");
    char buff[1024];
    printf("TCP DEMO CLIENT\n");
 
    // Шаг 1 - инициализация библиотеки Winsock
    if (WSAStartup(0x202, (WSADATA *)&buff[0]))
    {
        printf("WSAStart error %d\n", WSAGetLastError());
        return -1;
    }
 
    // Шаг 2 - создание сокета
    SOCKET my_sock;
    my_sock = socket(AF_INET, SOCK_STREAM, 0);
    if (my_sock < 0)
    {
        printf("Socket() error %d\n", WSAGetLastError());
        return -1;
    }
 
    // Шаг 3 - установка соединения
 
    // заполнение структуры sockaddr_in
    // указание адреса и порта сервера
    sockaddr_in dest_addr;
    dest_addr.sin_family = AF_INET;
    dest_addr.sin_port = htons(PORT);
    HOSTENT *hst;
 
    // преобразование IP адреса из символьного в
    // сетевой формат
    if (inet_addr(SERVERADDR) != INADDR_NONE)
        dest_addr.sin_addr.s_addr = inet_addr(SERVERADDR);
    else
        // попытка получить IP адрес по доменному
        // имени сервера
        if (hst = gethostbyname(SERVERADDR))
            // hst->h_addr_list содержит не массив адресов,
            // а массив указателей на адреса
            ((unsigned long *)&dest_addr.sin_addr)[0] =
            ((unsigned long **)hst->h_addr_list)[0][0];
        else
        {
            printf("Invalid address %s\n", SERVERADDR);
            closesocket(my_sock);
            WSACleanup();
            return -1;
        }
 
    // адрес сервера получен – пытаемся установить
    // соединение 
    if (connect(my_sock, (sockaddr *)&dest_addr,
        sizeof(dest_addr)))
    {
        printf("Connect error %d\n", WSAGetLastError());
        return -1;
    }
 
    //printf("Соединение с %s успешно установлено\n\
    Type quit for quit\n\n", SERVERADDR);
 
    // Шаг 4 - чтение и передача сообщений
    int nsize = recv(my_sock, &buff[0], sizeof(buff) - 1, 0);
    // ставим завершающий ноль в конце строки 
    buff[nsize] = 0;
 
    // выводим на экран 
    std::cout << "Время работы: " << buff << " сек" << std::endl;
    int value = atoi(buff);
    if (value == -1) {
        std::cout << "Клиент существует бесконечно" << std::endl;
        Sleep(100);
    }
    else {
        Sleep(1);
        for (int i = 1; i < value + 1; i++) {
            std::cout << i << " second" << std::endl;
            Sleep(1);
        }
        closesocket(my_sock);
        WSACleanup();
        return 0;
    }
 
}
Миниатюры
Не так работает многопоточность сервера и клиента  
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
19.04.2018, 20:25
Ответы с готовыми решениями:

Многопоточность сервера
Привет всем. Как можно сделать сервер многопоточным? То есть у меня есть сервер и клиент, когда клиент1 конектиться к серверу данные к...

Многопоточность сервера не реализуется
Подскажите в чем ошибка в создании многопоточности для сервера. Я думал в main методе при создании экземпляра класса Server...

Клиента Сервера
Всем привет. В общем я с другом создаю проект, в котором друг пишет сайт на php, а я создаю клиент на Delphi. Вот скриншоты моего клиенты....

2
1 / 1 / 0
Регистрация: 21.02.2018
Сообщений: 10
24.04.2018, 14:56  [ТС]
Проблема решена. Тема закрыта
0
5 / 5 / 1
Регистрация: 05.06.2018
Сообщений: 31
14.06.2018, 10:26
Ничосе закрыта! Получилось? А что сделал? Мне тоже пригодится, плиииз))
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
14.06.2018, 10:26
Помогаю со студенческими работами здесь

Ошибки сервера и клиента
Здравствуйте. У меня ситуация такая. Есть сервис развернутый на ASP.NET, есть клиент, написанный на WinForms. Когда запускаю сервис на...

Настройка сервера и клиента
подскажи, как настроить клиента этого сервака, никак не выходит, то сервер не доступен, то нет доступа к папке сервака (неужели ее надо...

Взаимодействие клиента и сервера
клиент-серверные приложения пишу впервые. собсно на данный момент планирую общать клиент и сервер примерно так: клиент посылает серверу...

Синхронизация клиента и сервера
1. Сервер генерирует число double. Например 3.25. 2. Сервер посылает клиенту сообщение о старте. 3. Как только клиент получает...

Настройка клиента - сервера
Приветствую форумчане,помогите,пожалуйста,решить проблемку.. Имеется сервер: import java.io.DataInputStream; import...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
3
Ответ Создать тему
Новые блоги и статьи
Изучаю kubernetes
lagorue 13.01.2026
А пригодятся-ли мне знания kubernetes в России?
Сукцессия микоризы: основная теория в виде двух уравнений.
anaschu 11.01.2026
https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/
WordPad для Windows 11
Jel 10.01.2026
WordPad для Windows 11 — это приложение, которое восстанавливает классический текстовый редактор WordPad в операционной системе Windows 11. После того как Microsoft исключила WordPad из. . .
Classic Notepad for Windows 11
Jel 10.01.2026
Old Classic Notepad for Windows 11 Приложение для Windows 11, позволяющее пользователям вернуть классическую версию текстового редактора «Блокнот» из Windows 10. Программа предоставляет более. . .
Почему дизайн решает?
Neotwalker 09.01.2026
В современном мире, где конкуренция за внимание потребителя достигла пика, дизайн становится мощным инструментом для успеха бренда. Это не просто красивый внешний вид продукта или сайта — это. . .
Модель микоризы: классовый агентный подход 3
anaschu 06.01.2026
aa0a7f55b50dd51c5ec569d2d10c54f6/ O1rJuneU_ls https:/ / vkvideo. ru/ video-115721503_456239114
Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR
ФедосеевПавел 06.01.2026
Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ВВЕДЕНИЕ Введу сокращения: аналоговый ПИД — ПИД регулятор с управляющим выходом в виде числа в диапазоне от 0% до. . .
Модель микоризы: классовый агентный подход 2
anaschu 06.01.2026
репозиторий https:/ / github. com/ shumilovas/ fungi ветка по-частям. коммит Create переделка под биомассу. txt вход sc, но sm считается внутри мицелия. кстати, обьем тоже должен там считаться. . . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru