当使用Spring反应器和Spring靴时，如何返回通量作为响应？

Question

我正在尝试将SpringReactor与我的SpringBoot应用程序一起使用。

我正在使用ProjectReactor 3.0.7。松开并安装Spring护套1.5.3。释放

在我的服务类中有一个返回通量的方法。

我想将该值返回到web层中的控制器。但是，我没有看到json响应中返回的值。

当我从浏览器调用http://localhost:8080时，我得到的响应是，{“预取”：-1}

我不确定我是否应该在返回响应之前做一些从Flux到String的转换。

我的代码在，https://github.com/bsridhar123/spring-reactor-demo/blob/master/src/main/java/com/demo/reactor/ReactiveApp.java

你能帮我找到正确的方法吗？

Answer 1

只有Spring 5（目前处于RC阶段）和Spring Boot 2（目前处于Milestone阶段）才会使用Retor进行完全的无功支持。

您可以独立于Spring使用Retor，但这并不会使框架变得反应性和异步，因此您会失去一些好处。您不能简单地返回Flux，因为框架还不理解这种类型。

但是，如果您必须协调大量服务调用，我相信它在服务层仍然很有用。

在这种情况下，您可以在整个服务层中使用Flux和Mono，并将它们转换为Spring 4的DeferredResult。比如：

DeferredResult<ResponseEntity<String>> result = new DeferredResult<>();
service.getSomeStringMono()
       .map(n -> ResponseEntity.ok(n))
       .defaultIfEmpty(ResponseEntity.notFound().build()
       .subscribe(re -> result.setResult(re),
                  error -> result.setErrorResult(error));
return result;