1

当我读取和写入超过 100000 条消息时，我收到了以下handleRead()函数异常。boost::asio::read()

terminate called after throwing an instance of
'boost::exception_detail::clone_impl<boost::exception_detail::error_info_injector<boost::system::system_error> >'
what():  asio.ssl error

实现如下

读取功能

void start()
{
boost::asio::async_read(_socket,
boost::asio::buffer(_messageHeader, 8),
    _strand.wrap(
      boost::bind(
        handleRead,
        shared_from_this(),
        boost::asio::placeholders::error,
        boost::asio::placeholders::bytes_transferred
        )
      )
    );
}

void handleRead(const boost::system::error_code& e,
   std::size_t bytesTransferred)
{
  if (!e) 
  {

   BOOST_STATIC_ASSERT( sizeof(MessageHeader) == 8 );

   Message message;
   message.header.fromString(
      std::string(_messageHeader.data(),
        sizeof(MessageHeader)
        )
      );

    boost::asio::read(_socket,
       boost::asio::buffer(_buffer, message.header.length));

   message.body = std::string(_buffer.data(), message.header.length);

   this->start();
  }
  else {
   this->close();
  }
}

实现消息队列以写入消息

void sendResponse(const Message& response)
{
  std::string stringToSend(response.toString());

  boost::system::error_code error;
  boost::asio::ip::tcp::endpoint endpoint = socket().remote_endpoint(error);

  if ( error ) {
  this->close();
  }

  _strand.post(
     boost::bind(
       writeImpl,
       shared_from_this(),
       stringToSend
       )
    );
}

void writeImpl(const std::string &message)
{
  _outbox.push_back( message );
  if ( _outbox.size() > 1 ) {
    return;
  }
  this->write();
}

void write()
{
 const std::string& message = _outbox[0];
 boost::asio::async_write(
    _socket,
    boost::asio::buffer( message.c_str(), message.size() ),
    _strand.wrap(
      boost::bind(
        writeHandler,
        shared_from_this(),
        boost::asio::placeholders::error,
        boost::asio::placeholders::bytes_transferred
        )
      )
    );
}

void writeHandler(
     const boost::system::error_code& e,
     const size_t bytesTransferred
     )
{
  _outbox.pop_front();

  if ( e ) {
  this->close();
  }
  if ( !_outbox.empty() ) {
   this->write();
 }
}
4

1 回答 1

1

看起来这是一个客户端应用程序？如果这是一个服务器，那么您可能需要重新考虑在 HandleRead 中完成的同步读取，并使一切异步。但是，对于客户端应用程序或连接很少的服务器来说，这可能没问题。

100,000 是一个非常有趣的数字——对人来说，而不是对计算机来说。这个数字表明某个地方有人设置了人为的限制。因此，如果您的应用程序是客户端，则检查服务器代码以确保在 100,000 条消息后它没有关闭套接字连接，反之亦然，如果您的应用程序是服务器。也许某处有一个尺寸为 100,000 的硬编码数组，并在达到限制时抛出错误，这具有关闭套接字连接的副作用。

无论您在哪里测试 ASIO 操作的错误条件，都应在检测到错误时添加一些日志记录信息。至少，将一些调试数据写入控制台。例如，在您的 handleRead 方法中，在调用 close 方法之前，添加一些调试日志记录。在我的应用程序中，我有一个将其写入控制台和日志文件的类。

于 2013-02-14T14:44:11.103 回答