Hello,
I tried use the boost::asio to create a SSL-Server, but I fail.
The Code I used is attached to this Text.
acceptor_ and context_ give me true result, but the start_accept()
methode give me a Handshake-Error: 10009 (invalid descriptor handle).
How can I avoid this, and how can I fix the Code in the right point ?
Thanks for reading
paule32
// -----------------------------------------------------------------
// File: BoostServer.cc
// Author: (c) 2023 Jens Kallup - paule32
// All rights reserved
//
// only for education, and non-profit usage !
// -----------------------------------------------------------------
# include <stdio.h>
# include <stdlib.h>
# include <sys/types.h>
# include <iostream>
# include <string>
# include <functional>
# include <thread>
# include <memory>
# include <boost/asio.hpp>
# include <boost/asio/ssl.hpp>
using namespace boost::asio;
using namespace std;
// -----------------------------------------------------------------
// @brief namespace name for Version 1.0.0 of our project ...
// -----------------------------------------------------------------
namespace dBaseRelease
{
std::string ApplicationExeName;
// -----------------------------------------------------------------
// @brief This member handle the exception message text that is use
// to "try catch" exception's during the runtime of the
// application.
//
// @param std::string& message - The e.what() message.
// @return nothing
//
// @since dBaseRelease
// @author paule32
// -----------------------------------------------------------------
void handle_exception(const std::string& message) {
std::string error_message;
for (int len = 0; len < message.length(); ++len) {
if (message[len] == '[') break;
error_message.push_back(message[len]);
}
std::cerr << "Exception "
<< error_message
<< std::endl;
}
class SSLServer: public std::enable_shared_from_this<SSLServer> {
public:
SSLServer(io_service& service, uint16_t port):
acceptor_(service, ip::tcp::endpoint(ip::tcp::v4(), port)),
context_ (ssl::context::tlsv12) {
context_.set_options(
ssl::context::default_workarounds |
ssl::context::sslv2 |
ssl::context::sslv3 |
ssl::context::tlsv12);
if (isAcceptorInitialized()
&& isContextInitialized ()) {
std::cout << "acceptor ok" << std::endl;
std::cout << "context ok" << std::endl;
start_accept();
} else {
std::cout << "server init error" << std::endl;
}
}
private:
void start_accept() {
ssl_socket_ = std::make_shared<ssl::stream<ip::tcp::socket>
>(acceptor_.get_executor(), context_);
// ----------------------------------
// Starte den asynchronen Handshake
// ----------------------------------
ssl_socket_->async_handshake(ssl::stream_base::server,
[this](const boost::system::error_code& error) {
if (!error) {
// -----------------------------------
// Wenn der Handshake erfolgreich ist,
// akzeptiere die Verbindung
// -----------------------------------
if (ssl_socket_ && ssl_socket_->lowest_layer().is_open()) {
std::cout << "SSL-Handshake erfolgreich und verbunden."
<< std::endl;
acceptor_.async_accept(ssl_socket_->lowest_layer(),
[this](const boost::system::error_code& accept_error) {
if (!accept_error) {
handle_client();
} else {
std::cerr
<< "Accept error: "
<< accept_error.message()
<< std::endl;
}
});
} else {
std::cerr << "SSL-Handshake erfolgreich, aber
Verbindung nicht geöffnet."
<< std::endl;
}
} else {
std::cerr
<< "Handshake error: "
<< error.message()
<< " ("
<< error.value()
<< ")"
<< std::endl;
}
});
}
void handle_client() {
// ------------------------------------
// Lese/Schreibe Daten mit ssl_socket_
// ------------------------------------
boost::asio::async_read_until(*ssl_socket_, buffer_, '\n',
[this](const boost::system::error_code& read_error, std::size_t
bytes_transferred) {
if (!read_error) {
std::istream is(&buffer_);
std::string received_data;
std::getline(is, received_data);
std::cout << "Received data from client: "
<< received_data
<< std::endl;
// -----------------------------------------
// Hier kannst du auf die empfangenen Daten
// reagieren und die Antwort vorbereiten
// -----------------------------------------
std::string response = "Hello from the server!\n";
// -----------------------------------------
// Sende die Antwort an den Client
// -----------------------------------------
boost::asio::async_write(*ssl_socket_,
boost::asio::buffer(response),
[this](const boost::system::error_code& write_error,
std::size_t) {
if (!write_error) {
// -----------------------------
// Schließe die Verbindung
// -----------------------------
ssl_socket_->lowest_layer().close();
// -----------------------------
// Starte die nächste Akzeptanz
// -----------------------------
start_accept();
} else {
std::cerr
<< "Write error: "
<< write_error.message()
<< std::endl;
}
});
} else {
std::cerr
<< "Read error: "
<< read_error.message()
<< std::endl;
}
});
}
// ------------------------------------------------
// Überprüfung, ob der Acceptor initialisiert wurde
// ------------------------------------------------
bool isAcceptorInitialized() const {
return acceptor_.is_open();
}
// ------------------------------------------------
// Überprüfung, ob der Context initialisiert wurde
// ------------------------------------------------
bool isContextInitialized() {
try {
// ----------------------------------
// load certificate, and private key
// ----------------------------------
context_.use_certificate_chain_file("server.crt.pem");
context_.use_private_key_file("server.key.pem",
ssl::context::pem);
return true;
}
catch (const boost::system::system_error& e) {
handle_exception(e.what());
return false;
}
}
private:
ip::tcp::acceptor acceptor_;
ssl::context context_;
std::shared_ptr<ssl::stream<ip::tcp::socket>> ssl_socket_;
boost::asio::streambuf buffer_;
};
} // namespace: dBaseRelease
int main(int argc, char **argv) {
using namespace dBaseRelease;
try {
ApplicationExeName = argv[0];
io_service service;
std::shared_ptr<SSLServer> server =
std::make_shared<SSLServer>(service, 12345);
service.run();
}
catch (const std::exception& e) {
std::cerr << "Exception: "
<< e.what()
<< std::endl;
return EXIT_FAILURE;
} return EXIT_SUCCESS;
}
--
Diese E-Mail wurde von Avast-Antivirussoftware auf Viren geprüft.
www.avast.com
_______________________________________________
Boost-users mailing list
Boost-users@lists.boost.org
https://lists.boost.org/mailman/listinfo.cgi/boost-users
