Блог

Я пытаюсь написать асинхронный сервер с использованием asio с зашифрованными сокетами SSL. В настоящее время у меня есть код, который не использует SSL, и после выполнения этого руководства у меня есть общее представление о том, как принимать сокет SSL, однако я не знаю, как адаптировать этот код для приема SSL-соединения:

 void waitForClients() {

    acceptor.async_accept(
        [this](std::error_code ec, asio::ip::tcp::socket socket) {
            if (!ec) {
                Conn newConn = std::make_shared<Connection>(ctx, std::move(socket));
                connections.push_back(newConn);

            } else {
                std::cerr << "[SERVER] New connection error: " << ec.message() << "n";
            }
            waitForClients();
        }
    );
}

//this is how the tutorial shows to accept a connection
ssl_socket socket(io_context, ssl_context);
acceptor.accept(socket.next_layer());
 

Проблема в том, что обратный вызов for acceptor.async_accept выдает обычный asio::ip::tcp::socket , а не an asio::ssl::ssl_socket<asio::ip::tcp::socket> , и я не могу найти никакой документации, которая предполагает, что существует метод async_accept ввода SSL-сокета таким образом. Единственный метод, который я видел, — это сначала создать сокет, а затем принять его впоследствии, что невозможно сделать таким асинхронным способом.

Любая помощь будет высоко оценена.

Я решил проблему, поняв, что вторым аргументом конструктора asio::ssl::stream<asio::ip::tcp::socket> является любой инициализатор для базового типа asio::ip::tcp::socket . Таким образом, проблема может быть решена:

 void waitForClients() {
    acceptor.async_accept(
        [this](std::error_code ec, asio::ip::tcp::socket socket) {
            if (!ec) {
                //initialise an ssl stream from already created socket
                asio::ssl::stream<asio::ip::tcp::socket> sslStream(sslCtx, std::move(socket);
                //then pass it on to be used
                Conn newConn = std::make_shared<Connection>(ctx, sslStream);
                connections.push_back(newConn);

            } else {
                std::cerr << "[SERVER] New connection error: " << ec.message() << "n";
            }
            waitForClients();
        }
    );
}