java - 在 Hibernate/C3P0 中处理连接池耗尽并避免死锁

Question

我的旧应用程序按照链查询我的数据库:Spring Tx -> Hibernate -> C3P0 。现在我需要在现有架构的基础上实现新的功能。

我通常使用 @Transactional 输入事务上下文注释或手动调用 PlatformTransactionManager .

有时，为了执行异步和大数据操作，我使用SessionFactory打开无状态 session 。 API。我们从未遇到任何其他问题，因为我们的线程池得到了很好的控制

第一次，我的要求是并行执行多个数据库操作以提高性能。我对此表示怀疑，因为我对多线程操作非常小心。

对于数据库中的每个实体，我可以在单独的线程上执行协调操作。但每个协调操作为其生成的两个线程中的每一个都使用一对连接。所以每个线程基本上有 4 个连接。

多线程类(class)告诉学生，为了防止死锁(吃掉哲学家的问题)，应该以事务方式获取资源:一旦你获取了一个 fork ，如果你无法在合理的时间内获取第二个 fork ，请释放第一个并重试。

我的问题很简单。鉴于 SessionFactory API，如果池已满，我如何编写不会无限期等待来自 c3p0 的 4 个连接的代码？我的意思是我需要 4 StatelessSession仅当有 4 个空间时才进行，否则我可以等待并重试。

据我所知，SessionFactory API 处于阻塞状态，不允许设置看门狗

Answer 1

目前的想法是使用简单的旧解决方法。

一般来说，在 Java 世界中，如果 API 不提供用于获取资源的看门狗方法，您可以将其委托(delegate)给 Future，Future 提供 get(int timeout, TimeUnit timeUnit) API 来约束执行。

第1步:用于资源获取的看门狗定时器

那么基本上，如何在超时范围内获得无状态 session ？

private Future<StatelessSession> getStatelessSession(SessionFactory sessionFactory)
{
    return asyncTaskExecutor.submit(new Callable<StatelessSession>()
    {

        @Override
        public StatelessSession call() throws Exception
        {
            return sessionFactory.openStatelessSession();
        }
    });
}

try {
    StatelessSession session = getStatelessSession(sessionFactory).get(3000,TimeUnit.MILLISECONDS);
} catch (TimeoutException e) {
    // go to step 2
}

第 2 步:像哲学家一样吃饭

正如我所说，我的问题看起来基本上就像哲学家就餐一样，只不过我们不仅有两把 fork ，还有总共 4 个勺子和刀子。

StatelessSession session1, session2, session3, session4;
for (int i=0; i<MAX_ATTEMPTS;i++) {
    try {
        session1 = tryGetSessionOrBoooooom();
    } catch(TimeoutException ex) {
        continue;
    }
    try {
        session2 = tryGetSessionOrBoooooom();
    } catch(TimeoutException ex) {
        session1.close();
        continue;
    }
    try {
        session3 = tryGetSessionOrBoooooom();
    } catch(TimeoutException ex) {
        session2.close();
        session1.close();
        continue;
    }
    try {
        session4 = tryGetSessionOrBoooooom();
    } catch(TimeoutException ex) {
        session3.close();
        session2.close();
        session1.close();
        continue;
    }
}

如果超出 MAX_ATTEMPTS 会发生什么，这取决于您，开发者!