在反应流中阻塞呼叫

Question

我想知道正常的java API调用（我的意思是没有I/O的方法）是否应该被线程化为“迷你阻塞调用”？是否可以像这样实现Reactive Streams（在返回Publisher之前调用方法）：

  public Mono<String> doSomething(Object anyObject){
      validator.validate(anyObject); // it returns void so in this case it cannot be in filter
      return Mono.just(anyObject)
          .flatmap(service::process);
  }

而不是（在流中调用它）

  public Mono<String> doSomething(Object anyObject){
      return Mono.just(anyObject)
          .doOnNext(validator::validate)
          .flatmap(service::process);
  }

此验证器仅用于示例。这种方法是否有任何缺点，或者这些方法在返回语句之前应该总是包含在流中？

Answer 1

我想知道正常的java API调用（我的意思是没有I/O的方法）是否应该被线程化为“迷你阻塞调用”？

我不太清楚这里的迷你阻塞调用是什么意思——一个方法阻塞还是不阻塞。如果它不阻塞是因为它不需要（该方法不涉及任何IO或其他阻塞操作），那么它只是一个标准的同步操作。

在这种情况下，在可能的情况下，我喜欢遵守两个相关原则：

• 让一切都成为反应链的一部分（这让代码更清晰，意味着下游的操作员有适当的效果）
• 避免使用单声道。just（）

因此，我倾向于第二种方法，因为那里的一切显然都是反应性链的一部分，这使得代码更清晰地阅读恕我直言——你不会在反应性和非反应性代码之间来回切换。

然而，请记住，您将使用此方法作为更大的反应性链的一部分（最有可能是通过flatMap（）调用），如果可能的话，实际上我更喜欢另一种方法-即使用转换（）意味着您可以提供一个方法，该方法既接受Mono作为其参数，又返回一个：

public Mono<String> doSomething(Mono<String> mono){
  return mono
      .doOnNext(validator::validate)
      .flatmap(service::process);
}

这样一来，所有东西都会成为反应链的一部分，并具有避免使用Mono的额外优势。just（）。