Java-JPA存储库和阻止I / O
作者:互联网
我遇到一个问题,在使用JpaRepository写入数据库后,我需要在单独的线程上执行几个缓慢的HTTP请求.问题在于doActualJob()在等待一系列期货结算时会阻塞.这似乎阻止了基础的Hibernate会话关闭,从而导致应用程序不久后耗尽连接.
如何编写此函数,以便在执行阻塞I / O时不会保持数据库连接打开?甚至可以使用JpaRepositories,还是我需要使用较低级别的API,例如EntityManager / SessionFactory?
@Service
class SomeJobRunner {
private final SomeJobRepository mSomeJobRepository; //extends JpaRepository
@AutoWired
public SomeJobRunner(final SomeJobRepository someJobRepository) {
mSomeJobRepository = someJobRepository;
}
@Async
public void doSlowJob(final long someJobId) {
SomeJob someJob = mSomeJobRepository.findOne(someJobId);
someJob.setJobStarted(Instant.now());
mSomeJobRepository.saveAndFlush(someJob);
doActualjob(); // Synchronous job doing several requests using Unirest in series
someJob = mSomeJobRepository.findOne(someJobId);
someJob.setJobEnded(Instant.now());
mSomeJobRepository.saveAndFlush(someJob);
}
解决方法:
在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编写的一个很好的教程.
标签:spring-boot,spring-data-jpa,java 来源: https://codeday.me/bug/20191210/2104531.html