spring - Kotlin 协程与 Spring JPA 阻塞存储库

Question

我正在尝试将 kotlin 协程与“旧式”Spring JPA 存储库结合使用。我创建了一个新的协程范围并在“异步”中运行所有 JPA 调用。我发现即使使用非响应式 JDBC，我也可以提高吞吐量。

但我想知道，Spring JPA 存储库中可能存在一些协程包装器吗？用反射和 Spring“魔法”创造的东西？

Answer 1

首先我想澄清一件事以防止可能的混淆:如果你正在使用 Spring Data JPA，那么你应该知道这个框架使用 JDBC 驱动底层，这实际上是一个阻塞 API，这意味着所有的数据库调用都会使调用线程阻塞，直到总结果完成并准备好被消费.有了这些知识，我假设您正在使用 suspend与在 Dispatcher.IO 上运行的协同程序一起运行进行此类调用。该调度程序为每次调用提供一个线程(据我所知，它最多可扩展到 64 个线程)。该线程实际上在进行数据库调用时阻塞，这意味着协同程序和 suspend除了将阻塞调用切换到另一个线程(最终将被阻塞)之外，在这种情况下不会产生任何魔力。

也许你应该看看 r2dbc(响应式(Reactive) SQL 驱动程序)并使用 CoroutineCrudRepository<T, ID>来自 Spring Data 而不是使用标准 JpaRepostitory<T, ID> .

CoroutineCrudRepository<T, ID>具有 suspend 的所有方法这意味着您可以使用它们来创建“真正的”异步 API，而不会完全阻塞。

但是，r2dbc 可能不适合您的用例，因为它有很多限制，例如映射关系、缓存等。