如何在从浏览器/REST客户端调用时自动订阅RESTendpoint？

Question

在ProjectReactor或Reactive流中，在订阅（）之前不会发生任何事情。

Reactive streams数据流不会发生，除非有人订阅它，但我看到所有REST API（如Find、save和inserts）都不显式调用subscribe，而是数据在生产者和订阅者之间流动。

@RestController
class PersonController {

      private final PersonRepository repository;

      public PersonController(PersonRepository repository) {
        this.repository = repository;
      }
      @GetMapping("/all")
      public Flux<Person> index() {

         return repository.findAll();

     }
      @GetMapping("/people")
      Flux<String> namesByLastname(@RequestParam Mono<String> lastname) {

        Flux<Person> result = repository.findByLastname(lastname);
        return result.map(it -> it.getFullName());
      }

      @PostMapping("/people")
      Flux<People> AddPeople(@RequestBody Flux<Person> people) {

          return repository.saveAll(people);
      }
}

为什么我们不需要调用RESTendpoint的subscribe来启动Project Reactor中的数据流？

我是不是漏掉了什么？

Answer 1

您是对的--当应用程序设置flux/monoreactive管道时，管道中的任何内容都不会执行，直到有东西subscribe订阅它。

以下是Spring WebFlux中请求/响应交换期间发生的情况：

• 服务器接收请求并将其转发给WebFlux
• 根据请求和您的应用程序代码，将构建一个反应管道，包括过滤器、控制器等。您可以将其视为连接请求和响应的管道
• HTTP客户端通过TCP堆栈请求读取，背压信息由基础服务器传输。