如何在reactive java中从Mono中获取String

Question

我有一个接受Mono作为参数的方法。我只想从中得到实际的字符串。Googled但是除了调用Mono对象上的block()，没有找到答案，但是它会进行阻塞调用，所以要避免使用block（）。如果可能的话，请建议其他方法。我之所以需要这个字符串，是因为在这个方法中，我需要用实际的字符串值调用另一个方法，比如print（）。我明白这很容易，但我是反应性编程的新手。

代码：

public String getValue(Mono<String> monoString) {
    // How to get actual String from param monoString
    // and call print(String) method
}

public void print(String str) {
    System.out.println(str);
}

Answer 1

从单字 获得字符串而不使用阻塞调用并不容易，这是不可能的。根据定义。如果字符串还不可用(mono 允许），则只能等待它出现，而这正是阻塞的意义所在。

不是“获取字符串”，而是订阅到mono，当字符串可用时（可能立即），您传递的订阅者将获得该字符串。例如。

myMono.subscribe(
  value -> Console.out.println(value), 
  error -> error.printStackTrace(), 
  () -> Console.out.println("completed without a value")
)

将打印mymono产生的值或错误(value的类型是string，error的类型是throwable)。在https://projectreactor.io/docs/core/release/api/reactor/core/publisher/mono.html，还可以看到subscribe的其他变体。