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 に答える