使用use_future的Boost Asio async_send_to多播不起作用

问题描述

ITNOA

我有一个程序想要将带有async_send_to的消息发送到一个多播组。但我想此操作阻止了异步操作，因此我使用use_future来实现以下目标

gw::BoostMessageSender::BoostMessageSender(const std::string& group_address,const std::string& interface_name,uint16_t port_number,ba::io_context& io_context)
    : AbstractMessageSender(group_address,interface_name,port_number),io_context(io_context),endpoint(ba::ip::address::from_string(group_address),socket(io_context,endpoint.protocol())
{
    if (!socket.is_open())
        socket.open(endpoint.protocol());

    socket.set_option(ba::ip::udp::socket::reuse_address(true));
}

bool gw::BoostMessageSender::send(const std::string& message) noexcept
{    
    std::future<std::size_t> result = socket.async_send_to(ba::buffer(message),endpoint,ba::use_future);

    return result.get() == message.size();
}

我像下面这样使用此类

int main()
{
    const string group_address = "235.127.1.1";
    constexpr uint16_t PORT_NUMBER = 8765;

    boost::asio::io_context io_context;

    BoostMessageSender message_sender(group_address,"eth1",PORT_NUMBER,io_context);

    std::thread t1([&io_context]()
        {
            io_context.run();
        });

    this_thread::sleep_for(1s);

    message_sender.send("Any bodey there?");

    cout << "send message: "; // --- this line is not run never :(((
    
    io_context.stop();
    t1.join();
    return 0;
}

我的问题是为什么send message永远不会在控制台中写入内容？

陌生人，即我用tcpdump -i eth0 -nnSX port 8765检查我的网络，并在呼叫async_send_to之后看到发送到网络的多播消息，但是result.get()从未返回结果并挂在其上。 / p>

我哪里错了？

我在以下平台上测试了这些代码

Visual Studio 2019 16.7.4
Windows 10 1909 latest update
Boost 1.73.0

Ubuntu 20.04.1 LTS
GCC 9.3.0
Boost 1.71.0

解决方法

io_context::run在没有要执行的挂起作业时返回。

您可以创建工作卫士以确保即使未启动异步任务也不会完成运行。使用make_work_guard函数：

boost::asio::io_context io_context;
auto workGuard = boost::asio::make_work_guard(io_context);