我正在为WebSocket和TCP服务器使用boost::beast库。
由于要求,我必须使用相同的端口。因此,我实现了遵循它的服务器。
void on_run() {
// Set suggested timeout settings for the websocket
m_ws.set_option(...);
m_ws.async_accept(
beast::bind_front_handler(
&WsSessionNoSSL::on_accept,
shared_from_this()));
}
virtual void on_accept(beast::error_code ec) {
if(ec) {
std::string msg = ec.message();
CONSOLE_INFO("err: {}", msg);
if(msg != "bad method") {
return fail(ec, "accept");
} else {
doReadTcp();
return;
}
}
doReadWs();
}
void doReadTcp() {
m_ws.next_layer().async_read_some(boost::asio::buffer(m_recvData, 15),
[this, self = shared_from_this()](const boost::system::error_code &error,
size_t bytes_transferred) {
if(error) {
return fail(error, "tcp read fail");
}
CONSOLE_INFO("recvs: {}", bytes_transferred);
doReadTcp();
});
}
void doReadWs() {
m_ws.async_read(...);
}
接受函数失败后,我尝试读取原始 tcp 数据,但我无法知道传递的数据。我只能通过ec.message((知道失败原因。当接受函数失败时,我可以知道传递的数据吗?
如果不可能像我所想的那样,如何解决这个问题?
我找到了解决方案。
m_ws.async_accept(net::buffer(m_untilStr),
beast::bind_front_handler(
&WsSessionNoSSL::on_accept,
shared_from_this()));
websocket::stream 支持缓冲接受功能。
因此,首先 tcp 套接字填充握手数据,调用 async_accept(缓冲区、处理程序(。