0

この問題に遭遇したとき、boost::asio の例を変更しようとしていました: 読みやすいようにコードを単純化しました (詳細については、多くのcouts が表示されます):

-コードのどこかで、次を開始しasync_readます。

class WhoAreYouProtocol
{
public:
    std::string ID; //json string containing ID of the client
private:
    void WhoAreYou_handler(const boost::system::error_code& e,session_ptr sess) {

      ID.resize(1);//just for testing
      ID = "A";
      std::cout << "1.Address of String1 " << &ID << " value[" << ID << "] size " << ID.size() << std::endl; 
    sess->async_read(ID,
            boost::bind(&WhoAreYouProtocol::WhoAreYou_response_handler, this,
                    boost::asio::placeholders::error, boost::ref(ID), sess));
}

void WhoAreYou_response_handler(const boost::system::error_code& e, std::string &ID_, session_ptr sess) {//...  }

};

次に、プログラムは次のことを行う必要があります。

  1. まず、メインバッファのサイズを 読み取ります
  2. 文字列変数のサイズを受信データのサイズに変更します
  3. メインバッファを文字列変数に読み込みます

コードは次のとおりです 。

class session
{
public:

  template <typename Handler>
  void async_read(std::string& t, Handler handler)
  {
      t.resize(2);//just testing
      std::cout << "Address of String2 " << &t << std::endl;
      std::cout << "String2 size " << t.size() << std::endl;
      t = "AB";
      std::cout << "2.Address of String " << &t << " value[" << t << "] size " << t.size() << std::endl;
    // Issue a read operation to read exactly the number of bytes in a header.
    void (session::*f)(const boost::system::error_code&,std::string&, boost::tuple<Handler>) = &session::handle_read_header<Handler>;
    boost::asio::async_read(socket_, boost::asio::buffer(inbound_header_),boost::bind(f,this, boost::asio::placeholders::error, boost::ref(t),boost::make_tuple(handler)));


  }

メイン バッファのサイズを変更して読み取ります。

  /// Handle a completed read of a message header. The handler is passed using
  /// a tuple since boost::bind seems to have trouble binding a function object
  /// created using boost::bind as a parameter.
  template <typename Handler>
  void handle_read_header(const boost::system::error_code& e,std::string& t, boost::tuple<Handler> handler)
  {
      t.resize(3);//and again, just testing
      t = "ABC";
      std::istringstream is(std::string(inbound_header_, header_length));
      std::size_t inbound_data_size = 0;
      inbound_data_.resize(inbound_data_size);

      void (session::*f)(const boost::system::error_code&,std::string&, boost::tuple<Handler>) = &session::handle_read_data<Handler>;
      boost::asio::async_read(socket_, boost::asio::buffer(inbound_data_),boost::bind(f, this,boost::asio::placeholders::error, boost::ref(t), handler));

  }

最後に、最後の問題ハンドラー:

  /// Handle a completed read of message data.
  template <typename Handler>
  void handle_read_data(const boost::system::error_code& e,std::string& t, boost::tuple<Handler> handler)
  {
      std::cout << "4.Address of String " << &t  << std::endl;
      //any of the following lines crashes!!!!
      std::cout << "4. value[" << t << "] size " << t.size() << std::endl;
//    t.resize(4); //crash!!!
        std::string archive_data(&inbound_data_[0], inbound_data_.size());
        t = archive_data;//my target is to reach here but it crashes!!!!
  }

private:
  /// The size of a fixed length header.
  enum { header_length = 8 };

  /// Holds an outbound header.
  std::string outbound_header_;

  /// Holds the outbound data.
  std::string outbound_data_;

  /// Holds an inbound header.
  char inbound_header_[header_length];

  /// Holds the inbound data.
  std::vector<char> inbound_data_;
};

要するに、string最初async_readのハンドラーから最後のハンドラーまで、いくつかのパスを渡しました (ご覧のとおり、いくつかのホップが必要でした)。

問題: 最後のハンドラーで、文字列に対するほぼすべての操作がクラッシュしました (cout、assign、resize)

コードを調べて、どこで何か間違ったことをしたかをお知らせください。...そしてそれを解決する方法:)

どうもありがとう

4

1 に答える 1

3

async_readバッファが何であるかがわからないため、データを入れるだけのバッファであると想定し、文字列の内部データを上書きします（文字列に含まれるバッファには書き込みません。ヒープに割り当てられたメモリへのポインター)。これにより、未定義の動作と発生しているクラッシュが発生します。

Boost ASIO が提供するバッファリングを使用し、コールバックでそのデータを文字列に入れます。

于 2013-04-26T09:39:59.477 に答える