就像 Richard 刚才说的那样。这里是重新编写的 websocket_client_coro_ssl.cpp
示例:
#include "/home/sehe/custom/superboost/libs/beast/example/common/root_certificates.hpp"
#include <boost/asio/co_spawn.hpp>
#include <boost/asio/experimental/as_tuple.hpp>
#include <boost/asio/use_awaitable.hpp>
#include <boost/asio/use_future.hpp>
#include <boost/beast.hpp>
#include <boost/beast/ssl.hpp>
#include <boost/beast/websocket.hpp>
#include <boost/beast/websocket/ssl.hpp>
#include <cstdlib>
#include <functional>
#include <iostream>
#include <string>
namespace beast = boost::beast;
namespace http = beast::http;
namespace websocket = beast::websocket;
namespace net = boost::asio;
namespace ssl = boost::asio::ssl;
using tcp = boost::asio::ip::tcp;
net::awaitable<void>
do_session(
std::string host,
std::string const& port,
std::string const& text,
ssl::context& ctx)
{
using net::use_awaitable;
using net::experimental::as_tuple;
auto ex = co_await net::this_coro::executor;
tcp::resolver resolver(ex);
websocket::stream<
beast::ssl_stream<beast::tcp_stream>> ws(ex, ctx);
try
{
auto const results = co_await resolver.async_resolve(
host, port, use_awaitable);
beast::get_lowest_layer(ws).expires_after(
std::chrono::seconds(30));
auto ep = co_await beast::get_lowest_layer(ws).async_connect(
results, use_awaitable);
if(! SSL_set_tlsext_host_name(
ws.next_layer().native_handle(), host.c_str()))
{
throw beast::system_error(
static_cast<int>(::ERR_get_error()),
net::error::get_ssl_category());
}
host += ':' + std::to_string(ep.port());
beast::get_lowest_layer(ws).expires_after(
std::chrono::seconds(30));
ws.set_option(websocket::stream_base::decorator(
[](websocket::request_type& req)
{
req.set(
http::field::user_agent,
std::string(BOOST_BEAST_VERSION_STRING) +
" websocket-client-coro");
}));
co_await ws.next_layer().async_handshake(
ssl::stream_base::client, use_awaitable);
beast::get_lowest_layer(ws).expires_never();
ws.set_option(websocket::stream_base::timeout::suggested(
beast::role_type::client));
co_await ws.async_handshake(host, "/", use_awaitable);
co_await ws.async_write(
net::buffer(std::string(text)), use_awaitable);
beast::flat_buffer buffer;
auto [ec, bytes] =
co_await ws.async_read(buffer, as_tuple(use_awaitable));
if(ec)
{
if(ec != net::error::eof)
throw beast::system_error(ec);
} else
{
std::cout << beast::make_printable(buffer.data())
<< std::endl;
co_await ws.async_close(
websocket::close_code::normal, use_awaitable);
}
} catch(beast::system_error const& se)
{
throw;
}
}
int main(int argc, char** argv)
{
if(argc != 4)
{
std::cerr <<
"Usage: websocket-client-coro-ssl <host> <port> <text>\n" <<
"Example:\n" <<
" websocket-client-coro-ssl echo.websocket.org 443 \"Hello, world!\"\n";
return EXIT_FAILURE;
}
auto const host = argv[1];
auto const port = argv[2];
auto const text = argv[3];
net::io_context ioc;
ssl::context ctx{ssl::context::tlsv12_client};
load_root_certificates(ctx);
net::co_spawn(
ioc.get_executor(),
do_session(host, port, text, ctx),
[&](std::exception_ptr e)
{
try
{
std::rethrow_exception(e);
} catch(std::exception const& e)
{
std::cerr << "Err: " << e.what() << "\n";
}
});
ioc.run();
return EXIT_SUCCESS;
}