使用postgres r2dbc-pool的连接池大小

Question

我无法使用spring webflux和r2dbc（使用r2dbc池驱动程序）打开超过10个连接。我的配置如下所示：

@Configuration
public class PostgresConfig extends AbstractR2dbcConfiguration {

  @Override
  @Bean
  public ConnectionFactory connectionFactory() {
    ConnectionFactory connectionFactory = ConnectionFactories.get(ConnectionFactoryOptions.builder()
        .option(DRIVER, "pool")
        .option(PROTOCOL, "postgresql")
        .option(HOST, host)
        .option(USER, user)
        .option(PASSWORD, password)
        .option(DATABASE, database)
        .build());
    ConnectionPoolConfiguration configuration = ConnectionPoolConfiguration.builder(connectionFactory)
        .maxIdleTime(Duration.ofMinutes(30))
        .initialSize(initialSize)
        .maxSize(maxSize)
        .maxCreateConnectionTime(Duration.ofSeconds(1))
        .build();
    return new ConnectionPool(configuration);
  }
}

当我指定10个以上的连接时，会出现如下错误：

org.springframework.dao.DataAccessResourceFailureException: 
Failed to obtain R2DBC Connection; nested exception is 
java.util.concurrent.TimeoutException: 
Did not observe any item or terminal signal within 1000ms in 'lift' 
(and no fallback has been configured)
    at org.springframework.data.r2dbc.connectionfactory.ConnectionFactoryUtils
    .lambda$getConnection$0(ConnectionFactoryUtils.java:71)

此外，连接的数量保持与初始大小相同。未创建新连接。

Answer 1

请注意，您可以使用版本0.8.4。发布（最新版本）https://mvnrepository.com/artifact/io.r2dbc/r2dbc-postgresql/0.8.4.RELEASE它不需要您实例化ConnectionFactory

Answer 2

好的，还应为ConnectionFactoryOptions指定最大\u大小。否则，连接池大小仍然保持为10。

import static io.r2dbc.pool.PoolingConnectionFactoryProvider.MAX_SIZE;

    ConnectionFactory connectionFactory = ConnectionFactories.get(ConnectionFactoryOptions.builder()
        .option(DRIVER, "pool")
        .option(PROTOCOL, "postgresql")
        .option(HOST, host)
        .option(USER, user)
        .option(PASSWORD, password)
        .option(DATABASE, database)
        .option(MAX_SIZE, maxSize)
        .build());

Answer 3

Spring boot（至少2.3.4）在由属性/yaml设置池大小时，有一个棘手的“问题”。如果在数据库url中包含“pool”，则大小集（初始大小或最大大小）不会有任何影响，将使用r2dbc池的默认值10和10。

这是由于ConnectionFactoryC中的PooledConnectionFactoryCon条件onfigurations.java在spring.r2dbc.pool.enabled=true时失败，如果r2dbc-pool依赖项位于类路径上，并且“pool”是spring.r2dbc.url属性的一部分。

来自池化连接工厂条件文档：

检查是否请求了ConnectionPool的条件。如果池化是通过配置选择加入的，并且r2dbc url不包含与池化相关的选项，则该条件匹配。

这反过来会导致未创建ConnectionPool bean。

跳过r2dbc url属性中的“pool”关键字，并具有r2dbc池依赖项，那么您将获得一个正确配置的池。