Boost asio: как сохранить клиентское соединение живым? - PullRequest
Новая
       8

Boost asio: как сохранить клиентское соединение живым?

3 голосов
/ 28 ноября 2010

Я пытаюсь создать клиента, который поддерживает соединение на сервере.

Однако, когда я получил данные один раз, соединение было закрыто. Я не понимаю почему.

Я думаю, что должен сделать цикл, но мы сказали, что это не очень хорошая идея. 

class client
{
public:
  client(boost::asio::io_service& io_service,
      const std::string& host, const std::string& service)
    : connection_(io_service)
  {
    // Resolve the host name into an IP address.
    boost::asio::ip::tcp::resolver resolver(io_service);
    boost::asio::ip::tcp::resolver::query query(host, service);
    boost::asio::ip::tcp::resolver::iterator endpoint_iterator =
      resolver.resolve(query);
    boost::asio::ip::tcp::endpoint endpoint = *endpoint_iterator;

    // Start an asynchronous connect operation.
    connection_.socket().async_connect(endpoint,
        boost::bind(&client::handle_connect, this,
          boost::asio::placeholders::error, ++endpoint_iterator));
  }

  /// Handle completion of a connect operation.
  void handle_connect(const boost::system::error_code& e,
      boost::asio::ip::tcp::resolver::iterator endpoint_iterator)
  {
    if (!e)
    {
      // Successfully established connection. Start operation to read the list
      // of stocks. The connection::async_read() function will automatically
      // decode the data that is read from the underlying socket.
      connection_.async_read(stocks_,
          boost::bind(&client::handle_read, this,
            boost::asio::placeholders::error));
    }
    else
    {
      std::cerr << e.message() << std::endl;
    }
  }

  /// Handle completion of a read operation.
  void handle_read(const boost::system::error_code& e)
  {
    if (!e)
    {
      // Print out the data that was received.
      for (std::size_t i = 0; i < stocks_.size(); ++i)
      {
        std::cout << "Paquet numero " << i << "\n";
        std::cout << "  age: " << stocks_[i].age << "\n";
        std::cout << "  name: " << stocks_[i].nom << "\n";
      }

                // Maybe Should i put something here ?
    }
    else
    {
      // An error occurred.
        std::cerr << "Error : " << e.message() << std::endl;
        connection_.socket().close();
    }

    // or maybe here ?

  }

private:
  /// The connection to the server.
  connection            connection_;
  std::vector<stock>    stocks_;
};

главное выглядит так: 

int main(int argc, char* argv[])
{
  try
  {
    // Check command line arguments.
    if (argc != 3)
    {
      std::cerr << "Usage: client <host> <port>" << std::endl;
      return 1;
    }

    boost::asio::io_service io_service;

    client client(io_service, argv[1], argv[2]);
    io_service.run();
  }
  catch (std::exception& e)
  {
    std::cerr << e.what() << std::endl;
  }

  return 0;
}

1 Ответ

7 голосов
/ 28 ноября 2010

Во-первых, у вашего asio io_service заканчивается работа.В handle_read, где вы помещаете свой комментарий «Может быть, я должен что-то здесь поместить», вы можете запланировать следующую операцию асинхронного чтения: 

connection_.async_read(stocks_,
      boost::bind(&client::handle_read, this,
        boost::asio::placeholders::error));

Обычно, если вы программируете асинхронно, один раз асинхронно.Обработчик вызывается, вы будете вызывать следующий асинхронный.операция, как вы сделали в асинхронном соединителе.

...