首页 > 解决方案 > 获取 webflux 事件循环调度器

问题描述

我将webfluxnettyjdbc一起使用,所以我用下一种方式包装阻塞 jdbc 操作:

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

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

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

标签: spring-webfluxproject-reactorreactor-netty

解决方案


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


推荐阅读