// io_service 用于管理异步操作
io_service io_service;

// Acceptor 接受传入连接
tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 8080));

// Session 处理连接
struct Session : public std::enable_shared_from_this<Session> {
  tcp::socket socket;
  std::shared_ptr<Session> self;

  void run() {
    // 异步读取数据
    socket.async_read_some(
      boost::asio::buffer(buffer),
      [this](boost::system::error_code error, std::size_t bytes_transferred) {
        if (!error) {
          write_data(bytes_transferred);
        } else {
          close();
        }
      });
  }

  void write_data(std::size_t bytes_transferred) {
    // 异步写入数据
    socket.async_write_some(
      boost::asio::buffer(buffer, bytes_transferred),
      [this](boost::system::error_code error, std::size_t bytes_transferred) {
        if (!error) {
          run();
        } else {
          close();
        }
      });
  }

  void close() {
    socket.close();
  }
};

void start_accepting() {
  // 异步接受连接
  acceptor.async_accept(
    [this](boost::system::error_code error, tcp::socket socket) {
      if (!error) {
        // 创建和运行会话
        std::make_shared<Session>(std::move(socket))->run();
        start_accepting();
      }
    });
}

int main() {
  start_accepting();
  io_service.run();
  return 0;
}