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

2019-12-10 22:02:28 阅读：280 来源： 互联网

我遇到一个问题,在使用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

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

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