用Mono包装阻塞客户端并执行序列

Question

我正在尝试创建一个需要执行ssh命令的反应式应用程序。

目前，有一个SSH客户端（基于sshd mina）正在阻塞（也许有一种方法可以以非阻塞的方式使用它，但我不知道）。我的想法是围绕这个阻塞客户端创建一个包装器，这样我就可以像下面的代码一样将阻塞调用转换为Mono。

public class SshReactiveClient extends AutoCloseable {
  private final SshClient sshClient;

  public SshReactiveClient(final SshClient sshClient) {
    this.sshClient = sshClient;
  }

  public Mono<SshResponse> open(final Duration timeout) {
    return Mono.fromCallable(() -> sshClient.open(timeout))
        .subscribeOn(Schedulers.boundedElastic());
  }

  public Mono<SshResponse> execCommand(final SshCommand command, final Duration timeout) {
    return Mono.fromCallable(() -> sshClient.execCommand(command, timeout))
        .subscribeOn(Schedulers.boundedElastic());
  }

  @Override
  public void close() throws Exception {
    sshClient.close();
  }
}

首先，这样做是不是一个好主意？什么会更好？

第二点是如何编写代码，以便我可以使用前面命令的响应执行一系列ssh命令来执行下一个命令？

Answer 1

你的理解是正确的。您需要包装阻塞或同步代码，并在单独的调度程序上运行它。更好的方法是客户端支持异步接口。

要按顺序执行命令，需要使用反应式API构建流。

execCommand(command1)
        .flatMap(res -> {
            var command2 = getCommand2(res);
            execCommand(command2)
        })
        .flatMap(res -> {
            var command3 = getCommand3(res);
            execCommand(command3)
        })