我用 webflux 与 网易和 jdbc ,所以我以下一种方式包装阻塞 jdbc 操作:
static <T> Mono<T> fromOne(Callable<T> blockingOperation) {
return Mono.fromCallable(blockingOperation)
.subscribeOn(jdbcScheduler)
.publishOn(Schedulers.parallel());
}
阻塞操作将由 处理jdbcScheduler ,我希望另一个管道由 处理webflux 事件循环调度器 .
如何获得 webflux 事件循环调度程序?
最佳答案
我强烈建议重新审视技术选项。如果你打算使用 jdbc,它仍然阻塞,那么你不应该使用 webflux。这是因为 webflux 将在非阻塞堆栈中发挥作用,但与 Jdbc 结合,它将成为瓶颈。性能实际上会下降。
关于spring-webflux - 获取 webflux 事件循环调度程序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52652367/