Как клиенту подключаться к серверу, после того, как работа сервера была остановлена

@_Pasha228 · Регистрация: 30.12.2019

Author24 — интернет-сервис помощи студентам

Всем добрый день. Есть сервер и клиент. Клиент вводит в консоль какие-то данные, после обработки эти данные отправляются на сервер. Надо сделать так, чтобы работа клиента была максимально независима от работы сервера. Таким образом, внезапный останов работы сервера не должен сказаться на работе клиента. После перезапуска сервера надо, чтобы клиент произвел переподключение. Для этого у меня есть класс клиента. Отсоединение от сервера проверяю посредством того, что сервер отправляет в ответ сообщение, после того, как принял его. Если не отправил в ответ, надо переподключаться. Я это делаю методом connectToServer, однако получаю в окне вот такую ошибку: connect: Transport endpoint is already connected
Как мне надо переподключаться?

client.h

C++

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
 
#include <iostream>
#include <chrono>
 
#ifndef CLIENT_HPP
#define CLIENT_HPP
 
 
 
class Client
{
private:
    int                sock;
    struct sockaddr_in addr;
 
public:
    Client();
    bool connectToServer();
    bool sendMessage(char*, size_t size);
    char* getMessage();
};
 
#endif

client.cpp

C++

#include "client.hpp"
 
Client::Client()
{
    sock = socket(AF_INET, SOCK_STREAM, 0);
    if(sock < 0)
    {
        perror("socket");
        exit(EXIT_FAILURE);
    }
 
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
    addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
}
 
bool Client::connectToServer()
{
    if(connect(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("connect");
        return false;
    }
    return true;
}
 
 
bool Client::sendMessage(char* cstr, size_t size)
{
    send(sock, cstr, size, 0);
    if (!recv(sock, cstr, 1, 0)) return false;
    return true;
}
 
char* Client::getMessage()
{
    char cstr[256];
    cstr[255] = '\0';
    recv(sock, cstr, 256, 0);
    return cstr;
}

@~~sipo~~ · 12.04.2023, 22:30

Проблема заключается в том, что после остановки сервера соединение все еще установлено, и при попытке повторного вызова функции connect() вы получаете ошибку "Transport endpoint is already connected". Чтобы решить эту проблему, вам необходимо закрыть сокет перед повторным вызовом функции connect(). Для этого вы можете использовать функцию close() сокета, которую можно вызвать внутри метода connectToServer() перед повторным вызовом функции connect(). Вот как может выглядеть исправленный код:

C++

bool Client::connectToServer()
{
    if(sock >= 0) close(sock);
    sock = socket(AF_INET, SOCK_STREAM, 0);
    if(sock < 0)
    {
        perror("socket");
        exit(EXIT_FAILURE);
    }
 
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
    addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
    
    if(connect(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("connect");
        return false;
    }
    return true;
}

Здесь мы добавили вызов close() сокета, чтобы закрыть его, а затем создали новый сокет с помощью функции socket(). Затем мы повторно задали значения структуры sockaddr_in и вызвали функцию connect() для установления нового соединения. Это должно позволить клиенту переподключаться к серверу после его перезапуска.

	12.04.2023, 22:30