Проблема подключения объекта Boost ASIO Tcp Client/Server

Я пытаюсь создать «обработчик соединения» для клиента и сервера, серверная часть работает достаточно хорошо с другим клиентом, но когда я пытаюсь подключить клиент, созданный объектом, у меня всегда один и тот же сбой, и он появляется сразу после socket->connect.

это ошибка клиента:

terminate called after throwing an instance of 'boost::wrapexcept<boost::system::system_error>'
  what():  bind: Address already in use

это мой TCP.cpp:

TCP::TCP(TYPE type)
{
    switch (type)
    {
        case (CLIENT):
            setup_client();
        case (SERVER):
            setup_server();
        default:
            break;
    }
}

TCP::~TCP()
{
    _socket->close();
}

void TCP::setup_client()
{
    boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string("127.0.0.1"), PORT);
    _socket = new tcp::socket(_io_service);
    _socket->connect(endpoint);
}

void TCP::setup_server()
{
    _acceptor = new tcp::acceptor(_io_service, tcp::endpoint(tcp::v4(), PORT ));  //listen for new connection
    _socket = new tcp::socket(_io_service);  //socket creation 
    _acceptor->accept(*_socket);  //waiting for connection
}

string TCP::read_socket() {
    boost::asio::streambuf buf;
    boost::asio::read_until(*_socket, buf, "\n" );
    string data = boost::asio::buffer_cast<const char*>(buf.data());
    return data;
}

void TCP::send_socket(const string& message)
{
    const string msg = message + "\n";
    boost::asio::write(*_socket, boost::asio::buffer(message) );
}

и это мой .hpp:

#define PORT 8080

enum TYPE {
    CLIENT,
    SERVER
};

class TCP {
    public:
        TCP(TYPE type);
        ~TCP();
        string read_socket();
        void send_socket(const string& message);

    protected:
    private:
        void setup_server();
        void setup_client();

        boost::asio::io_service _io_service;
        tcp::acceptor *_acceptor;
        tcp::socket *_socket;
};

c++ boost tcp boost-asio tcpclient

22.12.2020 13:12

Стоит ли изучать PHP в 2023-2024 годах?

Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...

Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией

В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.

Приемы CSS-макетирования - floats и Flexbox

Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...

Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest

В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...

Концепция локализации и ее применение в приложениях React ⚡️

Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...

Пользовательский скаляр GraphQL

Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...

372

Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вам не хватает оператора break:

TCP::TCP(TYPE type) {
    switch (type) {
    case (CLIENT):
        setup_client();
        break;
    case (SERVER):
        setup_server();
        break;
    default:
        break;
    }
}

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

упрощенный

Удаление многих источников ошибок:

Прямой эфир на Колиру

#define PORT 8383
#include <boost/asio.hpp>
#include <iostream>
using namespace std::chrono_literals;
using boost::asio::ip::tcp;
using boost::system::error_code;

struct TCP {
    enum TYPE { CLIENT, SERVER };

    TCP(TYPE type);
    ~TCP();
    std::string read_socket();
    void send_socket(const std::string& message);

  private:
    boost::asio::io_service _io_service;
    tcp::socket _socket { _io_service };
    tcp::acceptor _acceptor { _io_service };
};

TCP::TCP(TYPE type) {
    if (type == CLIENT) {
        _socket.connect(tcp::endpoint{ {}, PORT});
    } else {
        _acceptor = tcp::acceptor{_io_service, {{}, PORT}};
        //_acceptor.bind({{}, PORT});
        _acceptor.accept(_socket);
    }
}

TCP::~TCP() {
    if (_socket.is_open())   _socket.close();
    if (_acceptor.is_open()) _acceptor.close();
}

std::string TCP::read_socket() {
    std::string data;
    auto n = read_until(_socket, boost::asio::dynamic_buffer(data), "\n");
    data.resize(n);
    return data;
}

void TCP::send_socket(const std::string& message) {
    write(_socket, boost::asio::buffer(message + "\n"));
}

int main() {
    std::thread server_th([&] {
        TCP s(TCP::SERVER);
        s.send_socket("ECHO: " + s.read_socket());
    });

    std::thread client_th([&] {
        std::this_thread::sleep_for(10ms);
        TCP c(TCP::CLIENT);
        c.send_socket("Hello world!");
        std::cout << c.read_socket() << "\n";
    });

    client_th.join();
    server_th.join();
}

Отпечатки