Форум программистов, компьютерный форум, киберфорум
C++: Сети
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.68/34: Рейтинг темы: голосов - 34, средняя оценка - 4.68
 Аватар для Nikolai2812
0 / 0 / 0
Регистрация: 14.06.2023
Сообщений: 5

Ошибка в чтении пакетов с не блокирующимся сокетом WinSock2

14.06.2023, 16:37. Показов 7326. Ответов 7

Студворк — интернет-сервис помощи студентам
Имеется проблема не знаю как решить уже как только не пребывал. While и в for циклах всё равно выдаёт второе исключение которое делается в проверке if на получение байтов из функции recv. Пробовал и добавлять проверку до самого чтения если SOCKET(клиента) != INVALID_SOCKET и SOCKET_ERROR то начинать читать иначе просто он пропускает этот сокет но цикл всё равно начинает процесс принятия пакета не смотря на проверку.

Вот мелкий прототип сервера накидываю всё в 1 файл для простоты строго не судите только начинающий. Тонкостей с работой с не блокирующимся сокетом не работал, делал до этого такой же но для каждого клиента свой поток. Это мне предоставило много неудобств было много пользователей делал мелкий тест тормазил Xeon. Сделал выбор написать сервер который будет принимать пользователей в отдельном потоке, так же их обрабатывать в отдельном и главный поток для обработки например команды stop и тд

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
#include <winsock2.h>
#include <format>
#include <ws2tcpip.h>
#include <thread>
#include <iostream>
 
WSADATA srvWSADATA;
SOCKET srvSocket, newClient;
 
int GetRuntimeCode() {
    int ex = WSAGetLastError();
    closesocket(srvSocket);
    WSACleanup();
    return ex;
};
 
int main(int argc, char* argv[], char* envp[]) {
    if(WSAStartup(MAKEWORD(2, 2), &srvWSADATA) != 0)
        system(std::format("ECHO \t Server: [WSASTARTUP] failed initalize code: {0} && PAUSE", GetRuntimeCode()).c_str());
 
    SOCKADDR_IN srvADDRESS = { AF_INET, htons(atoi(argv[2])), { .S_un{ .S_addr = inet_addr(argv[1]) } }, 0 };
 
    if((srvSocket = socket(srvADDRESS.sin_family, SOCK_STREAM, IPPROTO_TCP)) == INVALID_SOCKET)
        system(std::format("ECHO \t Server: [SOCKET] failed create socket code: {0} && PAUSE", GetRuntimeCode()).c_str());
 
    unsigned long UnblockSocket = atoi(argv[4]);
    if(ioctlsocket(srvSocket, FIONBIO, (unsigned long*)&UnblockSocket) == SOCKET_ERROR)
        system(std::format("ECHO \t Server: [ASUNC] failed unblock socket code: {0} && PAUSE", GetRuntimeCode()).c_str());
 
    if(bind(srvSocket, (struct sockaddr*)&srvADDRESS, sizeof(srvADDRESS)) == SOCKET_ERROR)
        system(std::format("ECHO \t Server: [BIND] failed binding address code: {0} && PAUSE", GetRuntimeCode()).c_str());
 
    if(listen(srvSocket, SOMAXCONN) == SOCKET_ERROR)
        system(std::format("ECHO \t Server:[LISTEN] failed listen socket code: {0} && PAUSE", GetRuntimeCode()).c_str());
 
    const char* ipADDRESS = inet_ntoa(srvADDRESS.sin_addr), *port = std::to_string(htons(srvADDRESS.sin_port)).c_str();
    system(std::format("ECHO \t Server: [STATUS] Started listening from {0}:{1}", ipADDRESS, port).c_str());
 
    bool ActiveSRV = true;
    SOCKET clrSocket[atoi(argv[3])];
 
    std::thread AcceptIO([&] {
        system(std::format("ECHO \t Accept: [STATUS] Started process accepting new client").c_str());
        while(ActiveSRV) {
            if((newClient = accept(srvSocket, 0, 0)) == INVALID_SOCKET) {
                if(WSAGetLastError() != WSAEWOULDBLOCK) {
                    system(std::format("ECHO \t Accept: [STATUS] Error socket client resources are unavailable").c_str());
                    break;
                };
            } else {
                SOCKADDR_IN clrADDR;
                int clrADDRLen = sizeof(clrADDR);
                getpeername(newClient, (struct sockaddr*)&clrADDR, &clrADDRLen);
                const char* ip = inet_ntoa(clrADDR.sin_addr), *port = std::to_string(htons(clrADDR.sin_port)).c_str();
                for(int index = 0; index <= (int)(sizeof(clrSocket) / sizeof(SOCKET)); index++) {
                    if(clrSocket[index] <= INVALID_SOCKET) {
                        system(std::format("ECHO Accept: [CLIENT {0}] Connected new client {1}:{2}", index, ip, port).c_str());
                        clrSocket[index] = newClient;
                        break;
                    };
                };
            };
        };
        system(std::format("ECHO \t Accept: [STATUS] Stoped is sucessfull status code: {0}", WSAGetLastError()).c_str());
    });
 
    int ReceiveCountBYTE = 0;
    char RecvBufferPacket[1024];
    std::thread HandlerIO([&] {
        system(std::format("ECHO \t Handler: [STATUS] Started process exchange packages with clients").c_str());
        while(ActiveSRV) {
            for(int index = 0; index <= (int)(sizeof(clrSocket) / sizeof(SOCKET)); index++) {
                memset((void*)RecvBufferPacket, 0, sizeof(RecvBufferPacket));
                if((ReceiveCountBYTE = recv(clrSocket[index], RecvBufferPacket, sizeof(RecvBufferPacket), 0)) > 0) {
                    system(std::format("ECHO Handler: [CLIENT {0}]:[{1}] Received packet client", index, ReceiveCountBYTE).c_str());
                } else {
                    if(WSAGetLastError() != WSAEWOULDBLOCK) {
                        system(std::format("ECHO Handler: [CLIENT {0}] Disconnect client", index).c_str());
                        closesocket(clrSocket[index]);
                    };
                };
            };
        };
        system(std::format("ECHO \t Handler: [STATUS] Stoped is sucessfull status code: {0}", WSAGetLastError()).c_str());
    });
 
    std::string CommandString;
    while(std::getline(std::cin, CommandString) && CommandString != "stop" && ActiveSRV) {
        
    };
 
    ActiveSRV = false;
    HandlerIO.join();
    AcceptIO.join();
 
    for(int index = 0; index <= (int)(sizeof(clrSocket) / sizeof(SOCKET)); index++) {
        closesocket(clrSocket[index]);
    };
 
    return system(std::format("ECHO \t Server stoped is sucessfull status code: {0} && PAUSE", GetRuntimeCode()).c_str());
};
Миниатюры
Ошибка в чтении пакетов с не блокирующимся сокетом WinSock2   Ошибка в чтении пакетов с не блокирующимся сокетом WinSock2   Ошибка в чтении пакетов с не блокирующимся сокетом WinSock2  

0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
14.06.2023, 16:37
Ответы с готовыми решениями:

UDP при чтении пакетов виснет форма
Пытаюсь принять пакет, но при выполнении форма виснет. Пробовал ответ запихать в таймер, но тоже самое получилось. В чем проблема то? ...

Совместимость процессора с 478 сокетом и материнской платы с 479 сокетом
Всем привет !! подскажите плизз будет похать проц с 478 сокетом на матке с 479 сокетом ?

Не компилируются WinSock2.h, winsock2.h, ws2def.h
Требуется получить инфу из базы данных MySQL на сервере. Поставил MySQL Сервер, подключил к проекту, однако не компилится из-за огромного...

7
 Аватар для Azathtot
754 / 351 / 90
Регистрация: 07.01.2023
Сообщений: 1,451
14.06.2023, 19:46
собственно, если сокет у вас неблокирующий, то где WSAEventSelect вокруг которого вся "неблокируемость" и крутится ?
0
 Аватар для Nikolai2812
0 / 0 / 0
Регистрация: 14.06.2023
Сообщений: 5
14.06.2023, 19:52  [ТС]
Я пробывал делать по примеру из сайта https://russianblogs.com/article/7605607205/

там для не блокирующегося сокета используют ioctlsocket() и проверкой

это приём самого клиента но такая фишка не прокатывает с получение сообщения он пользователя.
так же в том посту есть аналогичная проверка и с приёмом сообщения if(RecvCountByte < 0) и тут такой же метод через if но он не работает не знаю как реализовать данный сервер что бы он принимал клиента и переходил на приём от них сообщения.

C++
1
2
3
4
if(err!=WSAEWOULDBLOCK) {
    cout << "принять вызов функции не удалось! \ n";
    break;
}
0
 Аватар для Azathtot
754 / 351 / 90
Регистрация: 07.01.2023
Сообщений: 1,451
14.06.2023, 20:12
Вы сначала почитайте как работает неблокирующий сокет.
Для него в цикле через select (POSIX-системы) или WSASelectEvent/WSAAsyncSelect получается "интерес". И далее, для этого интереса выполняются какие-либо действия. Пример есть в MSDN если что
0
 Аватар для Nikolai2812
0 / 0 / 0
Регистрация: 14.06.2023
Сообщений: 5
14.06.2023, 20:16  [ТС]
я уже прочитал про функцию WSASelectEvent() она выполняется в роли проверки доступности сокета на приём,чтение,запись буду побывать её использовать спасибо за быстрый ответ. я раньше побывал использовать FD_ACCEPT и FD_READ но до ума не смог довести примеров мало которые были бы расписаны немного только натыкался на такие же вопросы ошибка при чтении и тд.
0
 Аватар для Azathtot
754 / 351 / 90
Регистрация: 07.01.2023
Сообщений: 1,451
14.06.2023, 20:18
Цитата Сообщение от Nikolai2812 Посмотреть сообщение
она выполняется в роли проверки доступности сокета на приём
Да? Обратите внимание на параметр
[in] long lNetworkEvents
Это и сть интерес, на который она будет реагировать. Там же ниже расписан (русским языком) пример ее использования.
0
 Аватар для Nikolai2812
0 / 0 / 0
Регистрация: 14.06.2023
Сообщений: 5
14.06.2023, 20:21  [ТС]
ну там как я понял если пришло событие на сервер то происходит либо приём если событие FD_ACCEPT либо если FD_READ то читать из сокета и тд
0
COM‐пропагандист
 Аватар для Замабувараев
936 / 785 / 149
Регистрация: 18.12.2014
Сообщений: 2,256
Записей в блоге: 4
15.06.2023, 07:18
Забудьте про неблокирующий сокет и сразу делайте нормально: берите порт завершения ввода‐вывода.
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
15.06.2023, 07:18
Помогаю со студенческими работами здесь

Ошибка C4996 и WinSock2
Вот такая беда: не могу собрать проект написанный с использованный с использованием WinSock2. Пробовал самостоятельно написать сервер, но...

Ошибка с сокетом случай не стандартный
Доброго времени суток. Прошу помочь разобраться с проблемкой. Сижу бодаюсь с косяком, сайт отказывается конектится к базе выдавая ошибку: ...

Winsock2: ошибка при отправке UDP сообщения
Пытаюсь отправить сообщение. Почему-то всегда пишет ошибку.. Что не так с кодом? Использую UDP Переменные: int sd; int...

При использовании WinSock2 ошибка 10061 (connection refused)
Решил поизучать WinSock. Возможно, этот вопрос глупый, но очевидно, что ошибка в сетевом адресе. Код сервера, принимающего запросы: ...

Проц с сокетом am3+ на мать с сокетом am3
Должен ли стартонуть биос материнки в таком случае не зависимо от прошивки оного? Нужно знать для проверки камня fx. В моем случае он даже...


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

Или воспользуйтесь поиском по форуму:
8
Ответ Создать тему
Новые блоги и статьи
PhpStorm 2025.3: WSL Terminal всегда стартует в ~
and_y87 14.12.2025
PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .
Access
VikBal 11.12.2025
Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
Мысли в слух
kumehtar 18.11.2025
Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .
Создание Single Page Application на фреймах
krapotkin 16.11.2025
Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru