如何使用 Beast websockets 进行异步 read/write
How to do async read/write with Beast websockets
如何使用 Beast 库中的 websockets 进行异步写入和读取?我已尝试调整 Beast 文档 here 中提供的同步 write/read 示例,但下面的代码未按预期运行。
我期望得到以下输出:
*launch application*
Written data ...
Received data : Hello world!
*Ctrl-C*
Closing application ...
我明白了:
*launch application*
*Ctrl-C*
Closing application ...
代码:
#include <beast/core/to_string.hpp>
#include <beast/websocket.hpp>
#include <boost/asio.hpp>
#include <iostream>
#include <string>
/// Block until SIGINT or SIGTERM is received.
void sig_wait(beast::websocket::stream<boost::asio::ip::tcp::socket&>& ws)
{
boost::asio::io_service ios;
boost::asio::signal_set signals(ios, SIGINT, SIGTERM);
signals.async_wait(
[&](boost::system::error_code const&, int)
{
ws.close(beast::websocket::close_code::normal);
std::cout << "Closing application ..." << std::endl;
});
ios.run();
}
int main(int argc, char *argv[])
{
// Normal boost::asio setup
std::string const host = "echo.websocket.org";
boost::asio::io_service ios;
boost::asio::ip::tcp::resolver r{ios};
boost::asio::ip::tcp::socket sock{ios};
boost::asio::ip::tcp::resolver::iterator iter (r.resolve(boost::asio::ip::tcp::resolver::query{host, "80"}));
boost::asio::connect(sock,iter);
// WebSocket connect and send message
beast::websocket::stream<boost::asio::ip::tcp::socket&> ws{sock};
ws.handshake(host, "/");
ws.async_write(boost::asio::buffer(std::string("Hello world!")),
[&](beast::error_code const&)
{
std::cout << "Written data ..." << '\n';
}
);
// Register handle for async_read
beast::streambuf sb;
beast::websocket::opcode op;
ws.async_read(op,sb,
[&](beast::error_code const&)
{
std::cout << "Received data : " << to_string(sb.data()) << '\n';
}
);
sig_wait(ws);
}
旁注:总的来说,我对 Boost 库还很陌生,所以我可能弄错了一些基础知识...
您必须调用 io_service::run(),这是为 io_service 设置动画的阻塞调用。
现在有异步 WebSocket 客户端示例,您可以学习或复制:http://www.boost.org/doc/libs/develop/libs/beast/doc/html/beast/examples.html
这是一个从 main 调用 io_service::run() 的异步客户端示例:
http://www.boost.org/doc/libs/develop/libs/beast/example/websocket/client/async/websocket_client_async.cpp
如何使用 Beast 库中的 websockets 进行异步写入和读取?我已尝试调整 Beast 文档 here 中提供的同步 write/read 示例,但下面的代码未按预期运行。
我期望得到以下输出:
*launch application*
Written data ...
Received data : Hello world!
*Ctrl-C*
Closing application ...
我明白了:
*launch application*
*Ctrl-C*
Closing application ...
代码:
#include <beast/core/to_string.hpp>
#include <beast/websocket.hpp>
#include <boost/asio.hpp>
#include <iostream>
#include <string>
/// Block until SIGINT or SIGTERM is received.
void sig_wait(beast::websocket::stream<boost::asio::ip::tcp::socket&>& ws)
{
boost::asio::io_service ios;
boost::asio::signal_set signals(ios, SIGINT, SIGTERM);
signals.async_wait(
[&](boost::system::error_code const&, int)
{
ws.close(beast::websocket::close_code::normal);
std::cout << "Closing application ..." << std::endl;
});
ios.run();
}
int main(int argc, char *argv[])
{
// Normal boost::asio setup
std::string const host = "echo.websocket.org";
boost::asio::io_service ios;
boost::asio::ip::tcp::resolver r{ios};
boost::asio::ip::tcp::socket sock{ios};
boost::asio::ip::tcp::resolver::iterator iter (r.resolve(boost::asio::ip::tcp::resolver::query{host, "80"}));
boost::asio::connect(sock,iter);
// WebSocket connect and send message
beast::websocket::stream<boost::asio::ip::tcp::socket&> ws{sock};
ws.handshake(host, "/");
ws.async_write(boost::asio::buffer(std::string("Hello world!")),
[&](beast::error_code const&)
{
std::cout << "Written data ..." << '\n';
}
);
// Register handle for async_read
beast::streambuf sb;
beast::websocket::opcode op;
ws.async_read(op,sb,
[&](beast::error_code const&)
{
std::cout << "Received data : " << to_string(sb.data()) << '\n';
}
);
sig_wait(ws);
}
旁注:总的来说,我对 Boost 库还很陌生,所以我可能弄错了一些基础知识...
您必须调用 io_service::run(),这是为 io_service 设置动画的阻塞调用。
现在有异步 WebSocket 客户端示例,您可以学习或复制:http://www.boost.org/doc/libs/develop/libs/beast/doc/html/beast/examples.html
这是一个从 main 调用 io_service::run() 的异步客户端示例: http://www.boost.org/doc/libs/develop/libs/beast/example/websocket/client/async/websocket_client_async.cpp