1

我有一个服务器应用程序，它使用 boost::asio 的异步读/写函数与连接的客户端进行通信（直到它们断开连接）。

到目前为止一切都很好，但我想实现某种定时方法，服务器在经过一定时间后自行发送数据包。

我主要遵循boost::asio 网站上的教程/示例，所以我的程序基本上与给定示例具有相同的结构。

我试图通过创建一个 asio::deadline 计时器对象并将其传递给我已经通过调用 io_service.run() 像这样“调用”的 io_service 对象来实现此功能：

asio::deadline_timer t(*io, posix_time::seconds(200));
t.async_wait(boost::bind(&connection::handle_timed, 
                this, boost::asio::placeholders::error));

handle_timed 处理程序如下所示：

void connection::handle_timed(const system::error_code& error)
{
    //Ping packet is created here and gets stored in send_data

    async_write(socket_, asio::buffer(send_data, send_length), 
                boost::bind(&connection::handle_write, this, boost::asio::placeholders::error));
}

但是我遇到的问题是，deadline_timer 没有等待给定的时间，他几乎立即进入处理函数并想要发送数据包。

就像他一接触到异步操作就处理它，这当然不是我想要的。

是不是我不能在使用 io_service.run() 调用 io_service 对象后添加新的“对象”？或者也许我必须在之后专门将它包含在 io_service 对象的工作队列中？

此外，我无法理解如何在不与我拥有的正常消息流量混淆的情况下实现这一点。

4

1 回答 1

1

您可以随时添加工作io_service。您应该检查async_wait()回调中的错误，在我看来您deadline_timer超出了范围

asio::deadline_timer t(*io, posix_time::seconds(200));
t.async_wait(boost::bind(&connection::handle_timed, 
                this, boost::asio::placeholders::error));
...
// t goes out of scope here

你应该让它成为你connection班级的成员，就像socket_. 或者，boost::enable_shared_from_this在完成处理程序中使用并保留一份副本：

const boost::shared_ptr<asio::deadline_timer> t(new asio::deadline_timer(*io, posix_time::seconds(200)));
t.async_wait(boost::bind(&connection::handle_timed, 
                this, boost::asio::placeholders, t));

和你的完成处理程序

void connection::handle_timed(
    const system::error_code& error,
    const boost::shared_ptr<asio::deadline_timer>& timer
    )
{
    //Ping packet is created here and gets stored in send_data

    async_write(socket_, asio::buffer(send_data, send_length), 
                boost::bind(&connection::handle_write, this, boost::asio::placeholders::error));
}
于 2013-01-13T22:50:50.843 回答