我一直在努力尝试从官方boost主页获取此示例以运行:
#include <boost/asio/co_spawn.hpp>
#include <boost/asio/detached.hpp>
#include <boost/asio/io_context.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/signal_set.hpp>
#include <boost/asio/write.hpp>
#include <cstdio>
using boost::asio::ip::tcp;
using boost::asio::awaitable;
using boost::asio::co_spawn;
using boost::asio::detached;
using boost::asio::use_awaitable;
namespace this_coro = boost::asio::this_coro;
awaitable<void> echo(tcp::socket socket)
{
try
{
char data[1024];
for (;;)
{
std::size_t n = co_await socket.async_read_some(boost::asio::buffer(data), use_awaitable);
co_await async_write(socket, boost::asio::buffer(data, n), use_awaitable);
}
}
catch (std::exception& e)
{
std::printf("echo Exception: %s\n", e.what());
}
}
awaitable<void> listener()
{
auto executor = co_await this_coro::executor;
tcp::acceptor acceptor(executor, {tcp::v4(), 55555});
for (;;)
{
tcp::socket socket = co_await acceptor.async_accept(use_awaitable);
co_spawn(executor,
[socket = std::move(socket)]() mutable
{
return echo(std::move(socket));
},
detached);
}
}
int main()
{
try
{
boost::asio::io_context io_context(1);
boost::asio::signal_set signals(io_context, SIGINT, SIGTERM);
signals.async_wait([&](auto, auto){ io_context.stop(); });
co_spawn(io_context, listener, detached);
io_context.run();
}
catch (std::exception& e)
{
std::printf("Exception: %s\n", e.what());
}
}
我在Linux上,并将源保存到/usr/local/boost_1_70_0
。我在文档中读到必须包含<boost/system/error_code>
和<boost/system/system_error>
(为什么在代码示例中不这样?)。经过在StackOverflow上的大量阅读之后,我发现我也应该使用-lboost_system
,但是编译器只是抱怨说找不到它。另一个技巧是使用-lpthread
,现在它不再抱怨。我上次尝试的命令是g++ -I /usr/local/boost_1_70_0 main.cpp -lpthread
但是,它说:
error: ‘boost::asio::awaitable’ has not been declared
using boost::asio::awaitable;
^~~~~~~
这是代码中的错误吗?对于那些没有使用这些库经验的人来说,当存在很多陷阱时,他们很难上手。我可以看到还有许多人为此而苦苦挣扎,在我看来,所有答案都无济于事。我只是愚蠢,还是这个例子有问题?对于冗长的帖子,我深表歉意。如果有人可以帮我,我将深表感激,因为我为此付出了很多时间。
我一直在努力尝试从官方boost主页获取此示例来运行:#include
#include <boost/asio/detail/config.hpp>
#if defined(BOOST_ASIO_HAS_CO_AWAIT) || defined(GENERATING_DOCUMENTATION)
#include <experimental/coroutine>
boost / asio / detail / config.hpp: