JPA 存储库和阻塞 I/O

Question

我遇到一个问题，在使用 JpaRepository 写入数据库后，我需要在单独的线程上执行几个慢速 HTTP 请求。问题是doActualJob()在等待一系列期货解决时的阻塞。这似乎可以防止底层 Hibernate 会话关闭，从而导致应用程序很快用完连接。如何编写此函数，以便在执行阻塞 I/O 时数据库连接不保持打开状态？甚至可以使用 JpaRepositories，还是我需要使用像 EntityManager/SessionFactory 这样的较低级别的 API？@Serviceclass 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);}

Answer 1

嗯——非阻塞数据库 IO 在 Java/JDBC 世界中以标准方式是不可能的。简而言之——你的 Spring 数据存储库最终将使用 JPA ORM 实现（比如 Hibernate），而 JPA ORM 实现又将使用 JDBC 与之交互本质上是阻塞的数据库。Oracle（异步数据库访问 API ）目前正在做这方面的工作，以提供与 JDBC 类似但非阻塞的 API。他们打算将此作为标准提出。Spring 人员在这方面也有一项令人兴奋的并行工作，即R2DBC – 反应式关系数据库连接。他们实际上也将其与 Spring 数据集成（链接) 这样可以帮助您集成到您的解决方案中。可以在此处找到 Spring 的一个很好的教程。

Answer 2

我建议使用单独的JTA 事务写入数据库。这样做，定义一个像这样的方法

@Transactional(Transactional.TxType.REQUIRES_NEW)

public void saveJobStart(final long someJobId) {

    SomeJob someJob = mSomeJobRepository.findOne(someJobId);

    someJob.setJobStarted(Instant.now());

    mSomeJobRepository.saveAndFlush(someJob);

}

当然不完全一样。如果doActualjob()失败，在您的情况下，数据库将不会保留开始日期。在我的提议中，它会坚持下去。作为补偿，您需要在新事务中删除doSlowJobcatch中的bloc 中的开始日期，然后重新处理异常。 throw