我做了 boost 教程:异步 TCP 日间服务器 http://think-async.com/Asio/asio-1.1.1/doc/asio/tutorial/tutdaytime3.html 当我想测试它时，服务器正在运行，这很好，但如果我执行 nc -C localhost 4242，客户端会收到服务器的消息，但之后客户端会直接断开连接。

这里是我的代码:

#include "server.h"
#include "connection.h"

Server::Server(boost::asio::io_service& io_service) : accept(io_service, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 4242))
{
  wait_connection();
}

Server::~Server()
{

}

void Server::wait_connection()
{
  std::cout << "wait_connection" << std::endl;
  boost::shared_ptr<Connection> new_connection =
  Connection::start_connection(accept.get_io_service());

  accept.async_accept(new_connection->getSocket(), boost::bind(&Server::callback_accept, this, new_connection, boost::asio::placeholders::error));
}

void Server::callback_accept(boost::shared_ptr<Connection> new_connection, const boost::system::error_code &error)
{
  if (!error)
  {
    new_connection->send_message_to_client();
    wait_connection();
  }
}


Connection::Connection(boost::asio::io_service& io_service) : socket(io_service)
{

}

Connection::~Connection()
{
  std::cout << "destructeur Connection" << std::endl;
}

boost::shared_ptr<Connection> Connection::start_connection(boost::asio::io_service& io_service)
{
  return (boost::shared_ptr<Connection>(new Connection(io_service)));
}

boost::asio::ip::tcp::socket& Connection::getSocket()
{
  return (this->socket);
}

void Connection::send_message_to_client()
{
  message = "Bienvenue!\n";

  boost::asio::async_write(socket, boost::asio::buffer(message), boost::bind(&Connection::callback_send, shared_from_this()));
}

void Connection::callback_send()
{

}

int main()
{
  try {

    boost::asio::io_service io_service;
    Server server(io_service);
    io_service.run();
  }
  catch (std::exception& e) {
    std::cerr << e.what() << std::endl;
  }

  return (0);
}

#ifndef SERVER_H
#define SERVER_H

#include <iostream>
#include <string>
#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/asio.hpp>
#include "connection.h"

class Server {
private:
  boost::asio::ip::tcp::acceptor accept;

public:
  Server (boost::asio::io_service&);
 ~Server ();

  void wait_connection();
  void callback_accept(boost::shared_ptr<Connection> new_connection, const boost::system::error_code& error);

};

#endif /* end of include guard: SERVER_H */


#ifndef CONNECTION_H
#define CONNECTION_H

#include <iostream>
#include <string>
#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/asio.hpp>

class Connection : public boost::enable_shared_from_this<Connection>
{
private:
  boost::asio::ip::tcp::socket socket;
  std::string message;
public:
  Connection (boost::asio::io_service&);
  ~Connection ();

  static boost::shared_ptr<Connection> start_connection(boost::asio::io_service&);
  boost::asio::ip::tcp::socket& getSocket();
  void send_message_to_client();
  void callback_send();
};

#endif /* end of include guard: CONNECTION_H */

最佳答案

症结:共享指针使对象保持事件状态，直到引用计数达到零。

您在此处将消息写入客户端。完成后，您将执行 callback_send:

boost::asio::async_write(socket, boost::asio::buffer(message),
                         boost::bind(&Connection::callback_send, shared_from_this()));

那么我们接下来要做什么？

void Connection::callback_send() {}

哦。那是……不多。所以。没有什么？

嗯。几乎没有。

这是“不做某事也是做某事”的情况。通过不发布另一个使套接字/连接保持事件状态的操作，这意味着连接将被释放。

因为没有其他东西将 shared_ptr 保留到连接，shared_ptr 将删除连接(调用析构函数，您可以看到它，因为它每次都会打印 destructeur Connection)。

所以。解决办法是什么？ 我们不知道。在您说“欢迎”之后，您想做什么取决于您。在最有可能的情况下，您将希望等待来自客户端的某种消息。这将涉及一些 async_read* 调用，它可以愉快地保持连接(再次是 shared_from_this())。

演示

假设您想要继续接收线路，并且您将相同的线路发回，相反:

void Connection::callback_send() {
    boost::asio::async_read_until(socket, request, "\n",
                             boost::bind(&Connection::on_request_received, shared_from_this(),
                                 boost::asio::placeholders::error,
                                 boost::asio::placeholders::bytes_transferred));
}

void Connection::on_request_received(boost::system::error_code ec, size_t n) {
    if (ec && !((ec == boost::asio::error::eof) && n))
        std::cout << "Receive error: " << ec.message() << "\n";
    else
    {
        std::cout << "Received request\n";

        {
            std::istream is(&request);
            std::getline(is, message);
        }

        std::reverse(message.begin(), message.end());

        std::cout << "Sending response: " << message << "\n";

        message += '\n';

        if (!ec) boost::asio::async_write(socket, boost::asio::buffer(message),
               boost::bind(&Connection::callback_send, shared_from_this()));
    }
}

关于c++ - 连接后连接丢失 -> 服务器 TCP boost.ASIO，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/46449276/