小编Mat*_*son的帖子

我遇到一个问题，在使用 JpaRepository 写入数据库后，我需要在单独的线程上执行多个缓慢的 HTTP 请求。问题是doActualJob()在等待一系列 future 解决时会发生阻塞。这似乎阻止了底层 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);
}