操作取消了提升 asio async_receive_from

Operation canceled boost asio async_receive_from

本文关键字:async receive from asio 取消 操作      更新时间:2023-10-16

我有一个使用 boost/asio 设置的 UDP 服务器(我复制了这个示例,只是改变了一些东西)。下面是代码:

udp_server.hpp

using boost::asio::ip::udp;
class udp_server {
public:
udp_server(boost::asio::io_service&, int);
private:
boost::array<char, 256> recBuffer;
udp::socket socket_;
udp::endpoint remote_endpoint_;
void start_receive();
void handle_receive(const boost::system::error_code&, std::size_t);
void handle_send(boost::shared_ptr<std::string> /*message*/,
const boost::system::error_code& /*error*/,
std::size_t /*bytes_transferred*/)
{}
};

udp_server.cpp

udp_server::udp_server( boost::asio::io_service& io_service,
int port)
: socket_(io_service, udp::endpoint(udp::v4(), port)) {
serverNotifications.push_back("UDP Server class initialized.");
start_receive();
}
void udp_server::start_receive() {
socket_.async_receive_from(
boost::asio::buffer(recBuffer),
remote_endpoint_,
boost::bind(&udp_server::handle_receive,
this,
boost::asio::placeholders::error,
boost::asio::placeholders::bytes_transferred));
serverNotifications.push_back("Starting to receive UDP Messages.");
}
void udp_server::handle_receive(const boost::system::error_code& error,
std::size_t size) {
serverNotifications.push_back("RecFrom: " + remote_endpoint_.address().to_string());
if (!error) {
// I do data stuff here
} else {
errors.push_back("Handle Receive error: " + error.message());
}
}

初始化服务器后:

try {
udp_server server(io_service, ApplData.PORT, (size_t)ApplData.BUFLEN);
} catch (std::exception& e) {
// error handling
}

并在另一个函数中单独尝试捕获中io_service.run()运行它,我遇到了一些问题:

  • 我的回调函数handle_receive被调用,没有任何UDP消息在整个网络中发送(也就是只有我的笔记本电脑没有连接)
    • error.message()返回"操作已取消">
    • remote_endpoint_.address().to_string()返回"acfc:4000:0:0:7800::%2885986016",我无法将其识别为有用的内容
  • 我也认识到我的io_service一直在停止,但在我的理解中,它应该一直运行,对吧?

我已经考虑过在带有shared_from_this ptr绑定的回调函数中引用它,但由于在我离开程序之前我有一个udp_server类的真实实例,我想不出这样做的充分理由。

有人可以解释你这个失败的发生,这些错误告诉我我的代码是什么,或者我可以做些什么来避免它们?

没关系,Rubberduck调试就足够了。我刚刚读了这行

但是由于在我离开程序之前,我有一个 udp_server 类的真实实例,我想不出这样做的充分理由。

并注意到,我实际上没有这个,这是错误。