Boost Asio延迟写入TCP套接字

我有一个简单的TCP服务器，一个线程与asio循环和一个线程池来执行计算。我能够听到连接在主线程中写入内容。但我不能等待工作线程的回答，因为连接在被接受后立即关闭。Boost Asio延迟写入TCP套接字

我尝试使用截止日期计时器，但由于某种原因，它立即被称为“中止操作”错误。

整个过程我想实现的是：

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

这里是我的代码

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|[email protected]_wait 
@asio|1462018696.996675|0|[email protected] 
@asio|1462018696.996694|0*2|[email protected]_accept 
@asio|1462018696.996714|0*3|[email protected]_wait 
@asio|1462018696.996736|>1|ec=system:125

正如我们所看到的取消被称为计时器，但我没有在一个单一的取消我的代码，所以我不知道它为什么叫。

非常感谢您的帮助

来源

2016-04-30 DARK_DUCK

你还在听其他连接创建tcp_connection后？

既然你还没有要求你的新连接，io_service.run()为该线程可能只是完成async_read或async_read_some ...

如果您在tcp_connection构造启动deadline timer，它应该保持io_service.run()去和发送消息。

来源

2016-04-30 12:11:07 kenba

是的我在创建'tcp_connection'之后正在监听其他连接。'012_ 'io_sevice'仍在运行。问题是套接字本身被关闭 –

正如你所建议的，我在构造函数中启动了计时器（这也意味着计时器在任何传入连接之前启动）但是我仍然得到错误125.我将调试日志添加到我的文章 –

我找到了原因。

共享指针发生混乱，连接对象被破坏。 TCP对象也是如此。连接很近。

感谢@kenba的帮助！

来源

2016-04-30 13:37:41

我很高兴我帮你找到了问题的原因。如果您有兴趣使用现成的'boost asio' TCP服务器，我在[via-httplib]（https://github.com/kenba/via-httplib）上创建了一个作为HTTP服务器的一部分。 – kenba

太糟糕了我刚刚完成我的实施......如果我只知道：p –

Boost Asio延迟写入TCP套接字

回答

相关问题