Java-JPA存储库和阻止I / O

前端之家收集整理的这篇文章主要介绍了Java-JPA存储库和阻止I / O 前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

我遇到一个问题,在使用JpaRepository写入数据库后,我需要在单独的线程上执行几个缓慢的HTTP请求.问题在于doActualJob()在等待一系列期货结算时会阻塞.这似乎阻止了基础的Hibernate会话关闭,从而导致应用程序不久后耗尽连接.

如何编写此函数,以便在执行阻塞I / O时不会保持数据库连接打开?甚至可以使用JpaRepositories,还是我需要使用较低级别的API,例如EntityManager / SessionFactory?

  1. @Service
  2. class SomeJobRunner {
  3. private final SomeJobRepository mSomeJobRepository; //extends JpaRepository
  4. @AutoWired
  5. public SomeJobRunner(final SomeJobRepository someJobRepository) {
  6. mSomeJobRepository = someJobRepository;
  7. }
  8. @Async
  9. public void doSlowJob(final long someJobId) {
  10. SomeJob someJob = mSomeJobRepository.findOne(someJobId);
  11. someJob.setJobStarted(Instant.now());
  12. mSomeJobRepository.saveAndFlush(someJob);
  13. doActualjob(); // Synchronous job doing several requests using Unirest in series
  14. someJob = mSomeJobRepository.findOne(someJobId);
  15. someJob.setJobEnded(Instant.now());
  16. mSomeJobRepository.saveAndFlush(someJob);
  17. }
最佳答案
在Java / JDBC世界中,以标准方式无法实现无阻塞的数据库IO.简单地说,您的Spring数据存储库最终将使用JPA ORM实现(例如Hibernate),而该实现又将使用JDBC与本质上是阻塞的数据库. Oracle(Asynchronous Database Access API)目前正在对此进行工作,以提供与JDBC类似的API,但没有阻塞.他们打算将此作为标准提出.此外,Spring人员在这方面也进行了令人兴奋的并行工作,即R2DBC – Reactive Relational Database Connectivity.他们实际上也已将其与Spring数据(link)集成在一起,因此可以帮助您集成到解决方案中.可以在here上找到Spring编写的一个很好的教程.

猜你在找的Java相关文章