加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程开发 > Java > 正文

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

发布时间:2020-12-14 19:30:24 所属栏目:Java 来源:网络整理
导读:我遇到一个问题,在使用JpaRepository写入数据库后,我需要在单独的线程上执行几个缓慢的HTTP请求.问题在于doActualJob()在等待一系列期货结算时会阻塞.这似乎阻止了基础的Hibernate会话关闭,从而导致应用程序不久后耗尽连接. 如何编写此函数,以便在执行阻塞I

我遇到一个问题,在使用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编写的一个很好的教程.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读