c++ - 在capnproto中实现一个等待服务端的客户端连接函数

Question

我正在尝试在 capnproto 中实现类似 boost 的 connect 函数，它会阻塞并重试直到服务器启动，或者 basic_socket::async_connect 让我实现一个回调来尝试再次连接。

例如，运行这段代码:

auto ioContext = kj::setupAsyncIo();
auto address = ioContext.provider->getNetwork()                                              
               .parseAddress("localhost:7500").wait(ioContext.waitScope);
auto connection = address->connect().wait(ioContext.waitScope);

如果服务器宕机，显然会抛出异常。

所以我的问题是:

1. 有没有办法注册一个回调来处理连接/连接失败？
2. capnproto 中是否有一个内置机制已经启用自动重新连接？

Answer 1

没有任何内置的东西，但你可以像这样很容易地实现它:

kj::Promise<kj::AsyncIoStream> keepTryingConnect(kj::NetworkAddress& addr) {
  return addr.connect().catch_(
      [&addr](kj::Exception&& e) -> kj::Promise<kj::Own<kj::AsyncIoStream>> {
    if (e.getType() == kj::Exception::Type::DISCONNECTED) {
      // Try again.
      return keepTryingConnect(addr);
    } else {
      // Propagate error.
      return kj::mv(e);
    }
  });
}

请注意，DISCONNECTED 异常类型是对任何类型的 transient 网络错误的包罗万象，并且明确用于此类目的。

至于断开连接时重新连接:系统无法自动执行此操作，因为 Cap'n Proto 不知道重试飞行中的请求是否安全，也不知道如何重建连接上存在的任何功能.您需要做的是在您的应用程序中找到可以捕获 DISCONNECTED 异常类型然后重试的地方，就像上面的代码一样。