Spring Webflux / Reactor：reactor-http-nio vs boundedElastic

编程问答 2022-11-22

问题描述

我对一些关于每个请求所属的线程模型的反应器概念有点困惑。我读过https://projectreactor.io/docs/core/release/reference，但还是不清楚。让我们看一个例子：

@Autowired
UserRepository userRepository;

@GetMapping
Flux<User> findAll() {
    log.info("findAll request arrived");
    final Flux<User> defer = Flux.defer(() -> {
          return Flux.fromIterable(userRepository.findAll());
    });
    return defer;
}

日志：[boundedElastic-4] - INFO - findAll 请求到达

在 Schedulers.boundedElastic 线程池中执行 GET 方法（根据文档进行 I/O 绑定工作）

@PostMapping
Mono<User> save(@RequestBody User user) {
    log.info("save request arrived");
    final Mono<User> newUser = Mono.fromCallable(() -> {
         final User userMono = userRepository.save(user);
          log.info("user saved!");
          return userMono;
    });
    return newUser.subscribeOn(Schedulers.boundedElastic());
}

日志：[reactor-http-nio-6] - INFO - 保存请求到达

POST 方法属于 http-nio 线程池。

@PostMapping("/test")
Mono<User> test() {
    log.info("test");
    return Mono.just(new User());
}

没有正文的 POST 也属于 Schedulers.boundedElastic。

@Bean
public ReactiveWebServerFactory reactiveWebServerFactory() {
    NettyReactiveWebServerFactory factory = new NettyReactiveWebServerFactory();
    final ReactorResourceFactory reactorResourceFactory = new ReactorResourceFactory();
    reactorResourceFactory.setLoopResources(LoopResources.create("http-nio",4,true));
    reactorResourceFactory.setUseGlobalResources(false);
    factory.setResourceFactory(reactorResourceFactory);
    factory.setPort(8080);
    return factory;
}

这是我如何配置 http-nio 线程池。

所以，我的问题是：

  1. 为什么带有正文的 POST 方法会被 http-nio 线程池处理？
  2. 这个 http-nio 线程池应该是一个较小的线程池，那么为什么带有主体的 POST 方法（我认为被认为是阻塞代码）落在它们身上？
  3. 有意义 return newUser.subscribeOn(Schedulers.boundedElastic()); 还是应该保持在同一个线程上？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

javajavamultithreadingmultithreadingreactorreactorreactorreactorspringspringwebflux