Boost Asio 延迟写入 tcp 套接字

Question

我有一个简单的 TCP 服务器，它有一个带有 asio 循环的线程和一个用于计算的线程池。我能够听到连接在主线程中向其写入内容。但我等不及工作线程的回答，因为连接被接受后立即关闭。

我尝试使用截止时间计时器，但由于某种原因，它立即被调用并出现“中止操作”错误。

我要实现的整个过程是：

• 接受连接
• 写点东西
• 向工作池发送任务
• 等待工作人员的答复（我正在使用线程安全队列从工作人员池中读取消息）
• 将答案写入套接字
• 关闭连接

这是我的代码

class tcp_connection
: public boost::enable_shared_from_this<tcp_connection>
{
  public:
    typedef boost::shared_ptr<tcp_connection> pointer;

    static pointer create(boost::asio::io_service& io_service)
    {
      return pointer(new tcp_connection(io_service));
    }

    tcp::socket& socket()
    {
      return socket_;
    }

    void start()
    {
      message_ = "Write me in 5 sec";
      boost::asio::deadline_timer t(service_, boost::posix_time::seconds(5));
      t.async_wait(boost::bind(&tcp_connection::writeAfter, shared_from_this(), boost::asio::placeholders::error));
    }

  private:
    tcp_connection(boost::asio::io_service& io_service)
      : service_(io_service), socket_(io_service)
    {
    }

    void writeAfter(const boost::system::error_code&) {
      std::cout << "writing to socket" << std::endl;
      boost::asio::async_write(socket_, boost::asio::buffer(message_),
          boost::bind(&tcp_connection::handle_write, shared_from_this(),
            boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred));
    }


    void handle_write(const boost::system::error_code& /*error*/,
        size_t /*bytes_transferred*/)
    {
    }

    boost::asio::io_service &service_;
    tcp::socket socket_;
    std::string message_;
};

编辑：调试日志

@asio|1462018696.996630|0*1|deadline_timer@0x7ffd9dd40228.async_wait
@asio|1462018696.996675|0|deadline_timer@0x7ffd9dd40228.cancel
@asio|1462018696.996694|0*2|socket@0x7ffd9dd403e0.async_accept
@asio|1462018696.996714|0*3|deadline_timer@0x7ffd9dd40408.async_wait
@asio|1462018696.996736|>1|ec=system:125

我们可以看到取消是在计时器上调用的，但我的代码中没有一个取消，所以我不知道为什么调用它。

非常感谢您的帮助

Answer 1

您在创建tcp_connection 后还在监听其他连接吗？

由于您尚未为新连接调用 async_read 或 async_read_some，因此该线程的 io_service.run() 可能已经完成...

如果您在tcp_connection 构造函数中启动deadline timer，它应该保持io_service.run() 继续并发送消息。

Answer 2

我找到了原因。

共享指针很乱，我的连接对象被破坏了。 TCP 对象也是如此。连接已关闭。

感谢@kenba 的帮助！