ConnectionPool：池为空 - 增加 maxPoolSize 或 borrowConnectionTimeout

Question

我在连接到数据库和 MQ 并使用 Atomikos 事务管理器的 springboot 应用程序中遇到了这个问题。

com.atomikos.jms.AtomikosJMSException|Connection pool exhausted - try increasing 'maxPoolSize' and/or 'borrowConnectionTimeout' on the AtomikosConnectionFactoryBean.
com.atomikos.datasource.pool.PoolExhaustedException: ConnectionPool: pool is empty - increase either maxPoolSize or borrowConnectionTimeout
    at com.atomikos.datasource.pool.ConnectionPool.waitForAtLeastOneAvailableConnection(ConnectionPool.java:326)
    at com.atomikos.datasource.pool.ConnectionPool.findOrWaitForAnAvailableConnection(ConnectionPool.java:144)
    at com.atomikos.datasource.pool.ConnectionPool.borrowConnection(ConnectionPool.java:132)
    at com.atomikos.datasource.pool.ConnectionPoolWithSynchronizedValidation.borrowConnection(ConnectionPoolWithSynchronizedValidation.java:23)
    at com.atomikos.jms.AtomikosConnectionFactoryBean.createConnection(AtomikosConnectionFactoryBean.java:601)
    at org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:196)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.access0(AbstractPollingMessageListenerContainer.java:77)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer$MessageListenerContainerResourceFactory.createConnection(AbstractPollingMessageListenerContainer.java:490)
    at org.springframework.jms.connection.ConnectionFactoryUtils.doGetTransactionalSession(ConnectionFactoryUtils.java:325)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:281)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:245)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1189)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1179)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1076)
    at java.lang.Thread.run(Thread.java:748)

我尝试打印 maxPoolSize，发现它是 1。这个页面是在 (https://www.atomikos.com/Documentation/ConfiguringJms) 之间出现的，我发现他们将 MaxPoolSize 增加到 5 的那一行。我只是尝试将它设置为 2它奏效了。

AtomikosConnectionFactoryBean xaConnectionFactory = new AtomikosConnectionFactoryBean();
        xaConnectionFactory.setXaConnectionFactory(ibmMQXAConnectionFactory);
        xaConnectionFactory.setMaxPoolSize(2);

有人可以帮助我了解理想的池大小应该是多少。它有什么用等等？

Answer 1

为了处理消息，Atomikos 使用 DB 和 JMS 连接（在您的情况下）。这些连接取自可用连接池。要了解为什么需要连接池，请遵循此 link 作为起点 - Connection_pool

简单来说——为了一次处理一条消息，Atomikos 需要一个 DB 和一个 JMS connection/session。因此，如果您计划并行处理 10 条消息，则每个连接池大小必须至少为 10（分别为 DB 10 和 JMS 连接池 10）。

ConnectionPool：池为空 - 增加 maxPoolSize 或 borrowConnectionTimeout

ConnectionPool: pool is empty - increase either maxPoolSize or borrowConnectionTimeout

connection-pooling

jta

jms

atomikos

spring-boot