Написать простой асинхронный сервер с помощью boost

@INexteR · Регистрация: 25.01.2023

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

Приветствую. Есть код

C++

class Server
{
private:
    asio::ip::tcp::acceptor acceptor;
    void StartAccept()
    {
        
    }
public:
    Server(asio::io_service& io_serv) : acceptor_(io_serv, asio::ip::tcp::endpoint(asio::ip::tcp::v4(), 51111))
    {
        StartAccept();
    }
 
    void HandleAccept(/*параметры?*/)
    {
        
    }
};

Помогите написать тело StartAccept, чтобы сервер был способен обрабатывать множество запросов. И также правильно указать параметры для функции-обработчика.
Я писал эти функции так

C++

void StartAccept()
{
    RequestHandler::Pointer connection = RequestHandler::Create(acceptor_.get_executor()/*???*/);
    acceptor.async_accept(connection->GetSocket(), 
        bind(&Server::HandleAccept, this, connection, asio::placeholders::error));//???
}
void HandleAccept(Handler::Pointer connection, asio::error_code& err)
{
    if (!err) {
        connection->Start();
    }
    StartAccept();
}

Но в StartAccept я не понимаю
1) Как из возвращаемого значения get_executor() asio::any_io_executor вывести asio::io:service.
2) Какие параметры требует acceptor.accept.
Класс RequestHandler выглядит так

C++

class RequestHandler : public enable_shared_from_this<RequestHandler>
{
private:
    asio::ip::tcp::socket socket;
    const int size = sizeof(int);
    int sum;
 
public:
    typedef shared_ptr<RequestHandler> Pointer;
    RequestHandler(asio::io_service& io_service) : socket(io_service) {}
    static Pointer Create(asio::io_service& io_service)
    {
        return Pointer(new RequestHandler(io_service));
    }
    asio::ip::tcp::socket& GetSocket()
    {
        return socket;
    }
 
    void Start()
    {
        socket.async_read_some(asio::buffer(&sum, size), bind(&RequestHandler::Read,
                shared_from_this(), asio::placeholders::error, asio::placeholders::bytes_transferred));
    }
 
    void Read(const asio::error_code& err, size_t bytes_transferred)
    {
        if (!err) {
            cout << sum << endl;
        }
        else {
            std::cerr << "error: " << err.message() << std::endl;
            socket.close();
        }
    }
}

@karlhildekruger · 25.07.2024, 20:42

C++

#include <iostream>
#include <memory>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
 
using boost::asio::ip::tcp;
 
class RequestHandler : public std::enable_shared_from_this<RequestHandler>
{
private:
    tcp::socket socket_;
    const int size = sizeof(int);
    int sum;
 
public:
    typedef std::shared_ptr<RequestHandler> Pointer;
    
    RequestHandler(boost::asio::io_service& io_service) : socket_(io_service) {}
 
    static Pointer Create(boost::asio::io_service& io_service)
    {
        return std::make_shared<RequestHandler>(io_service);
    }
 
    tcp::socket& GetSocket()
    {
        return socket_;
    }
 
    void Start()
    {
        socket_.async_read_some(boost::asio::buffer(&sum, size),
            boost::bind(&RequestHandler::Read, shared_from_this(),
            boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred));
    }
 
    void Read(const boost::system::error_code& err, size_t bytes_transferred)
    {
        if (!err) {
            std::cout << "Received sum: " << sum << std::endl;
        }
        else {
            std::cerr << "Error: " << err.message() << std::endl;
            socket_.close();
        }
    }
};
 
class Server
{
private:
    tcp::acceptor acceptor_;
    
    void StartAccept()
    {
        RequestHandler::Pointer connection = RequestHandler::Create(acceptor_.get_io_service());
        acceptor_.async_accept(connection->GetSocket(), 
            boost::bind(&Server::HandleAccept, this, connection, boost::asio::placeholders::error));
    }
 
    void HandleAccept(RequestHandler::Pointer connection, const boost::system::error_code& error)
    {
        if (!error) {
            connection->Start();
        }
        StartAccept();
    }
 
public:
    Server(boost::asio::io_service& io_service)
        : acceptor_(io_service, tcp::endpoint(tcp::v4(), 51111))
    {
        StartAccept();
    }
};
 
int main()
{
    try {
        boost::asio::io_service io_service;
        Server server(io_service);
        io_service.run();
    }
    catch (std::exception& e) {
        std::cerr << "Exception: " << e.what() << std::endl;
    }
 
    return 0;
}

@INexteR · 26.07.2024, 22:23 **[ТС]**

karlhildekruger, да, я пытался писать точно как у вас, но у меня в строке 56 не получается вызвать метод get_io_service: класс asio::basic_socket_acceptor<asio::ip::tcp, asio::any_io_executor> не содержит члена get_io_executor. Есть только методы get_executor и get_option. И следующая строка тоже выдает ошибку: Ошибка C2672 "asio::basic_socket_acceptor<asio::ip::tcp,asio::any_io_executor>::async_accept" : не найдена соответствующая перегруженная функция.

Добавлено через 4 часа 12 минут

Сообщение от INexteR

класс asio::basic_socket_acceptor<asio::ip::tcp, asio::any_io_executor> не содержит члена get_io_executor.

Исправил эту ошибку:

C++

1	Handler::Pointer connection = Handler::Create(acceptor_.get_executor().context());

Т.е. заменил asio::io_service на asio::execution_context

Добавлено через 1 час 17 минут
Я так понял чтобы переписать 57 строку без ошибок нужно подключить также boost/bind. Но у меня в проекте используется только asio. Как правильно подключить boost/bind?

	26.07.2024, 22:23

Опции темы