R2DBC池在每个查询之前关闭所有连接

Question

我们正在使用Spring-Data-R2DBC，R2DBC-POOL和R2DBC-POSTGRESQL使用连接池。我们注意到了一些很高的响应时间，比从数据库本身获取的查询响应时间高得多（query_store.qs_view），

我们在池中添加了MetricsRecorder，用于调试目的，我们只在调用每种方法时才打印。看来，在每个SQL查询之前，我们获得了与池中有连接相同的RecordDestroylatency调用，并且recodallocationsuccessandlatency Invocations数量相同。我们假设这意味着每个连接在每个查询之前都会关闭并重新打开。然后，我们将其与数据库日志进行了比较，并证明这是真的：数量相同，无法从客户端接收数据：现有连接被远程主机，然后是连接。收到：消息。

为什么会发生这种情况？以下是我们用于创建连接工厂的代码。

@Configuration
open class DatabaseConfiguration : AbstractR2dbcConfiguration() {

//some variable initialisations

    @Bean
    override fun connectionFactory(): ConnectionFactory {
        val cf = PostgresqlConnectionFactory(
            PostgresqlConnectionConfiguration.builder()
                .host(hostname)
                .database(dbName)
                .schema(dbSchema)
                .username(dbUsername)
                .password(dbPassword)
                .build()
        )
        val cp = ConnectionPoolConfiguration.builder(cf)
            .initialSize(poolInitialSize)
            .maxSize(poolMaxSize)
            .metricsRecorder(DatabaseMetricsRecorder())
            .build()
        return ConnectionPool(cp)
    }
}

如前所述，databasemetricsRecorder只需打印每个操作即可。对于查询本身，我们正在扩展reactivevecrudrepository接口。 connection -continepoolConfiguration在此处以最简单的形式似乎有帮助。

Answer 1

这是R2DBC池中的一个已知错误，这是 evary 。作为解决方法，应明确设置maxlifetime，例如，我将其设置为毫秒中的最大允许值（否则，如果设置为一个值大于毫秒中的最大允许值，则R2DBC将投掷一个例外）：

    val cp = ConnectionPoolConfiguration.builder(cf)
        .initialSize(poolInitialSize)
        .maxSize(poolMaxSize)
        .maxLifeTime(Duration.ofMillis(Long.MAX_VALUE))
        .metricsRecorder(DatabaseMetricsRecorder())
        .build()