获取 webflux 事件循环调度程序

Question

我将webflux与netty和jdbc一起使用，因此我用以下方式包装阻塞 jdbc 操作：

static <T> Mono<T> fromOne(Callable<T> blockingOperation) {
    return Mono.fromCallable(blockingOperation)
        .subscribeOn(jdbcScheduler)
        .publishOn(Schedulers.parallel());
}

阻塞操作将由jdbcScheduler处理，我希望其他管道将由webflux event-loop Scheduler处理。

如何获取 webflux 事件循环调度程序？

Answer 1

我强烈建议重新审视技术选项。如果你打算使用 jdbc，它仍然是阻塞的，那么你不应该使用 webflux。这是因为 webflux 将在非阻塞堆栈中发挥作用，但与 Jdbc 结合使用时，它将成为瓶颈。性能实际上会下降。