Форум программистов, компьютерный форум, киберфорум
C++: Сети
Войти
Регистрация
Восстановить пароль
Карта форума Темы раздела Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.90/29: Рейтинг темы: голосов - 29, средняя оценка - 4.90
5 / 5 / 2
Регистрация: 03.05.2016
Сообщений: 221
1

WINSOCK_API в блокирующем режиме зависает на функции recv

03.11.2022, 10:48. Показов 5999. Ответов 6

Author24 — интернет-сервис помощи студентам
Всем привет! Пишу приложение для управления автосемплером по 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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
int CGAutosampler::LanPortConnectionAutosampler(CStringA* request, CStringA* response)
{
    //Ключевые константы
    const char SERVER_IP[] = "192.168.0.207";   // IPv4-адрес сервера
    const short SERVER_PORT_NUM = 20101;        // Порт прослушивания на стороне сервера
    const short BUFF_SIZE = 1024;               // Максимальный размер буфера для обмена информацией между сервером и клиентом    
    int erStat = -1;    // Для проверки ошибок в функциях сокетов
    int len = sizeof(int);
    timeval tm; // Максимальное время ожидания select, представленное в виде структуры TIMEVAL. Установите для параметра тайм-аута значение null для блокировки операций
    fd_set set; //указатель на набор сокетов, которые нужно проверить на возможность записи
    unsigned long ul = 1;
    bool ret = false;
 
    // Инициализация WinSock
    WSADATA wsData;
    erStat = WSAStartup(MAKEWORD(2, 2), &wsData);
 
    // IP в строковом формате в числовой формат для функций сокета. Данные находятся в "ip_to_num"
    in_addr ip_to_num;
    inet_pton(AF_INET, SERVER_IP, &ip_to_num); // При соответствующей версии windows, указанной в "targetver.h" можно использовать стандартную функцию, а не писать свою реализацию
 
    // Если есть  ошибка WinSock
    if (erStat != 0)
        return WSAGetLastError();
 
    // Инициализация сокета
    SOCKET ClientSock = socket(AF_INET, SOCK_STREAM, 0);
 
    // Если есть  ошибка иницилизации сокета 
    if (ClientSock == INVALID_SOCKET)
    {
        closesocket(ClientSock);
        WSACleanup();
        return WSAGetLastError();
    }
 
    // Установка соединения с сервером
    sockaddr_in servInfo;
 
    ZeroMemory(&servInfo, sizeof(servInfo));
 
    servInfo.sin_family = AF_INET;
    servInfo.sin_addr = ip_to_num;
    servInfo.sin_port = htons(SERVER_PORT_NUM);
 
    // При отсутствии соединения, время задержки при вызове connect может быть значительным,
    //поэтому соединяемся сперва в небллокирующем режиме. 
    //В случае успеха изменяем режим на блокирующий
    ioctlsocket(ClientSock, FIONBIO, &ul); // установка не блокирующего режима
    if (connect(ClientSock, (sockaddr*)&servInfo, sizeof(servInfo)) == -1)
    {
        // ожидание соединения
        tm.tv_sec = 2;  // установка таймаута 2s
        tm.tv_usec = 0;
        FD_ZERO(&set);
        FD_SET(ClientSock, &set);
 
        //Функция select определяет состояние одного или нескольких сокетов, ожидая, если необходимо, выполнения синхронного ввода-вывода
        if (select(ClientSock + 1, NULL, &set, NULL, &tm) > 0)
        {
            getsockopt(ClientSock, SOL_SOCKET, SO_ERROR, (char*)&erStat, /*(socklen_t *)*/&len);
            if (erStat == 0)
                ret = true;
            else
                ret = false;
        }
        else
            ret = false;
    }
    else
        ret = true;
 
    // Если обнаружена ошибка соединения
    if (!ret)
    {
        closesocket(ClientSock);
        WSACleanup();
        if (WSAGetLastError() == 0)
            return -1;
        else
            return WSAGetLastError();
    }
 
    ul = 0;
    ioctlsocket(ClientSock, FIONBIO, &ul); //установка блокирующего режима
 
    //Обмен текстовыми данными между сервером и клиентом
    vector <char> servBuff(BUFF_SIZE);  // Буферы для отправки и получения данных
    short packet_size = 0;              // Размер отправляемого/получаемого пакета в байтах
 
    DWORD dwsise = strlen(*request);
 
 
    packet_size = send(ClientSock, *request, dwsise, 0); // Отправляем запрос
    //packet_size = send(ClientSock, clientBuff.data(), clientBuff.size(), 0);
 
    //Если не могу отправить сообщение на сервер
    if (packet_size == SOCKET_ERROR)
    {
        closesocket(ClientSock);
        WSACleanup();
        return WSAGetLastError();
    }
 
    packet_size = recv(ClientSock, servBuff.data(), servBuff.size(), 0);
 
    // Если не могу получить сообщение от сервера
    if (packet_size == SOCKET_ERROR)
    {
        closesocket(ClientSock);
        WSACleanup();
        return WSAGetLastError();
    }
 
    *response = servBuff.data();
 
    closesocket(ClientSock);
    WSACleanup();
 
    return 0;
}
Собственно проблема заключается в том, что в течении дня (приложение запущенно не постоянно) в какой то момент при запуске приложения возникает зависание в момент вызова функции recv. При использовании неблокирующего режима появляется ошибка 10035 (получена из функции WSAGetLastError()) при вызове той же функции recv практически сразу. Саму функцию LanPortConnectionAutosampler я вызываю один раз при подключении прибора и далее вызываю её 10 раз в секунду для проверки состояния прибора. Может ли кто дать совет (просветить) касательно того, что я не так делаю?
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
03.11.2022, 10:48
Ответы с готовыми решениями:

TServerSocket в блокирующем режиме.
Здравствуйте, уважаемые. Не могли бы Вы подсказать хорошую и правильную литературу по работе с...

Прием по pcap_next в блокирующем режиме
Добрый день Вопрос - есть ли в pcap блокирующий режим как с сокетами? Гугление не помогло, ищу...

Сокеты: после вызова send программа зависает на функции recv
Извеняюсь за такое назание темы, но уже перепробовал 100 вариантов и постоянно выкидывает данное...

TServerSocket и TClientSocket в блокирующем режиме (stThreadBlocking) Как закрыть сокет?
Использую TServerSocket и TClientSocket, в Delphi XE таких компонентов нету, поэтому приходится...

6
4 / 5 / 0
Регистрация: 17.12.2022
Сообщений: 40
17.12.2022, 19:47 2
Если функция recv зависает, это обычно означает, что нет данных для получения из сокета, или что произошла ошибка сетевого соединения.Чтобы решить эту проблему, необходимо исследовать причину отсутствия данных или ошибки сетевого соединения. Это может быть связано с проблемами с сетью, например, отсутствием соединения с интернетом, недоступностью удаленного хоста или проблемами с конфигурацией сети. В этом случае необходимо проверить сетевое оборудование и настройки сети, а также проверить удаленный хост на доступность. Возможно, будет необходимо использовать инструменты диагностики сети или обратиться к специалисту для решения проблемы.
0
0 / 0 / 0
Регистрация: 05.06.2022
Сообщений: 39
09.01.2023, 23:02 3
а как можно при помощи recv() получать сообщения одно за другим? Точнее получить сообщение, обработать, далее получить новое и тд? Попробовал вот так:
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
  server_socket = socket(AF_INET, SOCK_STREAM, 0);
 
    // define the server address
    struct sockaddr_in server_address;
    server_address.sin_family = AF_INET;
    server_address.sin_port = htons(9002);
    server_address.sin_addr.s_addr = INADDR_ANY;
 
    // bind the socket to our specified IP and port
    bind(server_socket, (struct sockaddr*) &server_address, sizeof(server_address));
 
    // second agrument is a backlog - how many connections can be waiting for this socket simultaneously
    listen(server_socket, 5);
 
    int client_socket;
 
    client_socket = accept(server_socket, NULL, NULL);
 
    while(1)
        {
        recv(client_socket, &client_message, 256, 0);
        
        //что-то делаю с полученным текстом
        
        }
 
    // close the socket
    close(server_socket);
   return 0;
}
но читается только в первую итерацию, далее recv() как буд-то пропускает

Добавлено через 53 минуты
нашел частично ответ на stackoverflow
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
char buffer[8192]; // or whatever you like, but best to keep it large
int count = 0;
int total = 0;
 
while ((count = recv(socket, &buffer[total], sizeof buffer - total, 0)) > 0)
{
    total += count;
    // At this point the buffer is valid from 0..total-1, if that's enough then process it and break, otherwise continue
}
if (count == -1)
{
    perror("recv");
}
else if (count == 0)
{
    // EOS on the socket: close it, exit the thread, etc.
}
получается, что для циклического опроса надо буфер раздуть до приличных размеров и запрашивать кусочками... А потом видимо что-то инициализировать заново. Можно ли как-то не раздувая буфер зациклить прием данных, чтобы буфер каждый раз перезаписывался?
0
COM‐пропагандист
 Аватар для Замабувараев
936 / 785 / 149
Регистрация: 18.12.2014
Сообщений: 2,253
Записей в блоге: 4
10.01.2023, 11:16 4
Цитата Сообщение от banan123 Посмотреть сообщение
Можно ли как-то не раздувая буфер зациклить прием данных
Не понял. Зациклить — это что такое? Поместить вызов внутрь while(){};? Так это у вас уже есть в коде.

Функция recv записывает данные туда, куда вы ей скажете (второй параметр). Хотите чтобы она записывала байты в начало буфера — передайте ей указатель на начало буфера.
1
0 / 0 / 0
Регистрация: 05.06.2022
Сообщений: 39
10.01.2023, 11:22 5
Цитата Сообщение от Замабувараев Посмотреть сообщение
Так это у вас уже есть в коде
это как бы я мечтал, но так не работает, точнее только в первую итерацию цикла работает, потом recv() остается "незамеченной", ход выполнения программы продолжается бесконечно, но уже как будто recv там нет
0
COM‐пропагандист
 Аватар для Замабувараев
936 / 785 / 149
Регистрация: 18.12.2014
Сообщений: 2,253
Записей в блоге: 4
10.01.2023, 11:28 6
Цитата Сообщение от banan123 Посмотреть сообщение
int client_socket;
В виндоуз сокет имеет тип данных SOCKET, убирайте int отсюда.

Цитата Сообщение от banan123 Посмотреть сообщение
ход выполнения программы продолжается бесконечно, но уже как будто recv там нет
Вам точно данные отправляют? Что возвращает recv? Что в буфере после этого?
1
0 / 0 / 0
Регистрация: 05.06.2022
Сообщений: 39
10.01.2023, 12:13 7
Пока писал ответ про то, что клиент завершает работу после отправки сообщения, сразу дошло, почему recv не принимает далее, видимо общение между сервером и клиентом продолжается непрерывно на каком-то уровне, и после закрытия клиента сервер закрывает сокет...) В клиенте поставил паузу после первого сообщения и потом последующую отправку очередного сообщения и recv работает как и предполагалось.
Цитата Сообщение от Замабувараев Посмотреть сообщение
В виндоуз сокет имеет тип данных SOCKET, убирайте int отсюда.
сервер на raspberry, возможно это имеет значение? Я еще не разобрался до конца.
0
10.01.2023, 12:13
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
10.01.2023, 12:13
Помогаю со студенческими работами здесь

MPI зависает на Recv
Вот код: int _tmain(int argc, char* argv ) { int myrank, ranksize, i; MPI_Status status;...

Recv зависает СОКЕТЫ с++
Всем привет, Я создал 2 приложения на Win32 API(клиент/сервер), клиент отправляет текст, а сервер...

Поток останавливается на функции recv
Создаю поток. в нем делаю сокет. и все бы ничего - да вот на функции recv все останавливается......

Как организовать таймаут из функции recv
Народ кто сталкивался с сокетами под линуксом, TCP, функция приема recv блокирует программу до...

Странности работы функции recv (winsock2)
Здравствуйте. Поисковик мне не помог, ничего похожего на форуме найти не удалось, поэтому - создам...

Изменить тайм-аут функции recv()
Всем привет! Как можно установить свой тайм-аут на функции recv()? Хочу ждать данные 10 секунд и...

Обработка функции recv структуры SOCKET
Прошу помощи как обработать полученную информацию из функции recv структуры SOCKET. к примеру: ...


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

Или воспользуйтесь поиском по форуму:
7
Ответ Создать тему
Новые блоги и статьи
Как узнать какой процесс блокирует файл или каталог в Windows
bt_guru 23.01.2025
При работе с операционной системой Windows пользователи нередко сталкиваются с ситуацией, когда система отказывается выполнять определенные действия с файлами или каталогами, сообщая, что они. . .
Как в curl узнать код статуса HTTP запроса. Коды состояния HTTP
bt_guru 23.01.2025
Коды состояния HTTP играют значимую роль в обеспечении эффективного взаимодействия между клиентами и серверами. При работе с веб-сервисами важно не только отправлять запросы, но и правильно. . .
Как сортировать вывод команды ls в Linux
bt_guru 23.01.2025
В операционной системе Linux команда ls является одним из наиболее часто используемых инструментов для просмотра содержимого директорий. При работе с файловой системой пользователи регулярно. . .
Как сделать POST запрос с помощью curl
bt_guru 23.01.2025
curl - это мощный инструмент командной строки позволяет отправлять и получать данные через различные протоколы, включая HTTP, HTTPS, FTP и множество других. Особенно полезным curl становится при. . .
Прокрутка в tmux с помощью мыши и клавиатуры
bt_guru 23.01.2025
Tmux представляет собой мощный терминальный мультиплексор, который позволяет пользователям создавать и управлять несколькими терминальными сессиями внутри одного окна. Одной из важнейших функций tmux. . .
Как проверить, содержит ли массив значение в JavaScript. Поиск в массиве
bytestream 23.01.2025
Эффективный поиск значений в массивах становится критически важным навыком для разработчиков, использующих JavaScript. Процесс поиска элементов в массиве может показаться простым на первый взгляд,. . .
Как удалить тег Git в удалённом репозитории (remote)
bytestream 23.01.2025
Одним из важнейших механизмов организации версий в Git являются теги, которые позволяют помечать определенные точки в истории проекта как значимые. Теги часто используются для маркировки релизов,. . .
Чем отличаются URL, URI и URN
bytestream 23.01.2025
Системы идентификации представляют собой фундаментальный механизм, позволяющий однозначно определять местоположение и характеристики различных информационных объектов в глобальной сети. Эти системы. . .
Как центрировать div внутри другого div с помощью CSS. Управление расположением элементов в CSS
bytestream 23.01.2025
Позиционирование элементов играет ключевую роль в создании качественных и профессиональных интерфейсов. Одной из наиболее часто встречающихся задач является центрирование элементов на веб-странице,. . .
Что означают различные символы в синтаксисе PHP
bytestream 23.01.2025
PHP (Hypertext Preprocessor) представляет собой один из наиболее широко используемых языков программирования для веб-разработки, который обладает богатой и интересной историей развития. Изначально. . .
Способы клонирования объектов в JavaScript
bytestream 23.01.2025
В современной разработке на JavaScript работа с объектами является фундаментальной частью создания любого приложения. При манипуляции объектами часто возникает необходимость создавать их копии для. . .
Как проверить состояние чекбокса в jQuery. Как работать с чекбоксами
bytestream 23.01.2025
При разработке интерактивных веб-форм часто возникает необходимость программно определять состояние чекбоксов с помощью jQuery. Чекбоксы являются важными элементами пользовательского интерфейса,. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru