如何优雅地停止使用 nghttp2 asio 构建的 HTTP2 服务器

Question

我知道如何使用 nghttp2 asio 库来构建 HTTP2 服务器和客户端应用程序。

documentation 表示有 stop 和 join API 用于正常停止 HTTP2 服务器。

有没有使用stop和join的工作示例？特别是，一旦 listen_and_serve 被调用，线程就会进入忙循环。是否建议从不同的线程调用 stop？不幸的是，文档中没有给出任何线索或示例代码。

编辑：

这是一个工作程序，我试图在 SIGINT 上停止服务器。

#include <iostream>
#include <thread>
#include <nghttp2/asio_http2_server.h>

using namespace nghttp2::asio_http2;
using namespace nghttp2::asio_http2::server;

nghttp2::asio_http2::server::http2 myserver;
void signalHandler( int signum ) {
  std::cout << "Interrupt signal (" << signum << ") received." << std::endl;
  myserver.stop();
  myserver.join();
  exit(0);
}

int main(int argc, char *argv[]) {
  signal(SIGINT, signalHandler);
  std::thread::id this_id = std::this_thread::get_id();
  std::cout << "Main thread running at " << this_id << std::endl;
  boost::system::error_code ec;

  myserver.handle("/api/ping", [](const request &req, const response &res) {
    std::thread::id this_id = std::this_thread::get_id();
    std::cout << "Ping Request received at " << this_id << std::endl;
    req.on_data([](const uint8_t *data, std::size_t len){
      std::cerr.write(reinterpret_cast<const char *>(data), len);
      std::cerr << std::endl;
    });
    res.write_head(200);
    res.end("hello, ping\n");
  });

  if (myserver.listen_and_serve(ec, "0.0.0.0", "8080")) {
    std::cerr << "error: " << ec.message() << std::endl;
  }
}

在按下 Control+C 后，执行在 myserver.stop() 挂起。我尝试仅使用 myserver.stop() 或 myserver.join() 但没有任何改进。如果我像下面这样直接调用 exit(0)，服务器会因分段错误而停止。

void signalHandler( int signum ) {
  std::cout << "Interrupt signal (" << signum << ") received." << std::endl;
  myserver.stop();
  myserver.join();
  exit(0);
}

感谢任何帮助。

Answer 1

listen_and_serve中的asynchronous参数应设置为true，默认为asynchronous = false。

请注意，在最后一个客户端连接关闭之前，服务器不会退出并等待 myserver.join()。当您调用 myserver.close() 时，服务器停止接受新连接。

下面的工作解决方案：

#include <iostream>
#include <thread>
#include <nghttp2/asio_http2_server.h>

using namespace nghttp2::asio_http2;
using namespace nghttp2::asio_http2::server;

nghttp2::asio_http2::server::http2 myserver;
void signalHandler( int signum ) {
  std::cout << "Interrupt signal (" << signum << ") received." << std::endl;
  myserver.stop();
}

int main(int argc, char *argv[]) {
  signal(SIGINT, signalHandler);
  std::thread::id this_id = std::this_thread::get_id();
  boost::system::error_code ec;

  myserver.handle("/api/ping", [](const request &req, const response &res) {
    std::thread::id this_id = std::this_thread::get_id();
    std::cout << "Ping Request received at " << this_id << std::endl;
    req.on_data([](const uint8_t *data, std::size_t len){
      std::cerr.write(reinterpret_cast<const char *>(data), len);
      std::cerr << std::endl;
    });
    res.write_head(200);
    res.end("hello, ping\n");
  });

  if (myserver.listen_and_serve(ec, "0.0.0.0", "8080", true)) {
    std::cerr << "error: " << ec.message() << std::endl;
  }
  myserver.join();
}

如何优雅地停止使用 nghttp2 asio 构建的 HTTP2 服务器

How to gracefully stop a HTTP2 server built with nghttp2 asio

boost-asio

http2

nghttp2

编辑：