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

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

03.11.2022, 10:48. Показов 5964. Ответов 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
Эксперт
94731 / 64177 / 26122
Регистрация: 12.04.2006
Сообщений: 116,782
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‐пропагандист
933 / 782 / 149
Регистрация: 18.12.2014
Сообщений: 2,243
Записей в блоге: 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‐пропагандист
933 / 782 / 149
Регистрация: 18.12.2014
Сообщений: 2,243
Записей в блоге: 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
IT_Exp
Эксперт
87844 / 49110 / 22898
Регистрация: 17.06.2006
Сообщений: 92,604
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
Ответ Создать тему
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2024, CyberForum.ru