Соединение с клиентом и сервером только отправка не принимается

Question

Это мое дело, у меня есть сервер, который прослушивает подключения, и клиент, который я сейчас программирую. Клиенту нечего получать с сервера, но он должен отправлять обновления статуса каждые 3 минуты.

У меня есть следующие в данный момент:

WSAStartup(0x101,&ws); 
    sock = socket(AF_INET,SOCK_STREAM,0); 
    sa.sin_family = AF_INET; 
    sa.sin_port = htons(PORT_NET); 
    sa.sin_addr.s_addr = inet_addr("127.0.0.1"); 
    connect(sock,(SOCKADDR*)&sa,sizeof(sa)); 
    send(sock,(const char*)buffer,128,NULL); 

Как должен быть мой подход? Могу ли я избежать циклического возврата?

Answer 1

Это зависит от того, какое поведение вы хотите и какая структура программы. По умолчанию сокет будет блокироваться при любых операциях чтения или записи, а это означает, что если ваша попытка и ваш основной поток вашего сервера опросит соединение, вы закончите с ним «замораживание» в течение 3 минут или до тех пор, пока клиент не закроет связь.

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

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

Другой вариант - установить сокет в неблокирующее (в win32 использовать setsockopt, чтобы установить тайм-аут, в * nix передать ему флаг O_NONBLOCK). Таким образом, он вернет управление, если нет данных для чтения. Однако это означает, что вам необходимо опросить сокет через разумные промежутки времени («разумно» полностью зависит от вас и как быстро вам понадобится сервер для работы с новыми данными.)

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

Есть много способов попасть в беспорядок с асинхронными программами, поэтому, вероятно, лучше всего держать его простым и заставить его работать, пока вам не станет удобно управлять потоком.