无法获取R2DBC，该发布服务器不支持多个订阅服务器

Question

我尝试使用spring-boot-starter-data-r2dbc和oracle-r2dbc运行r2dbc应用程序，但它给我一个异常“org . spring framework . Dao . dataaccessresourcefailureexception:无法获得r2dbc连接；嵌套异常为Java . lang . illegalstateexception:此发布者不支持多个订阅者。

这是我的属性文件：

spring.r2dbc.url=r2dbc:oracle:thin://localhost:1521:orcl
spring.r2dbc.username=user
spring.r2dbc.password=password

和 gradle 文件的依赖部分：

dependencies {
    ktlint 'com.pinterest:ktlint:0.41.0'
    implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8:$kotlinVersion")
    implementation("org.jetbrains.kotlin:kotlin-reflect:$kotlinVersion")
    implementation('com.fasterxml.jackson.module:jackson-module-kotlin')
    implementation('org.codehaus.janino:janino')
    implementation('org.springframework.cloud:spring-cloud-starter-stream-kafka')
    implementation('org.springframework.cloud:spring-cloud-stream')
    implementation('org.springframework.boot:spring-boot-configuration-processor')
    implementation('org.apache.httpcomponents:httpclient:4.5.8')
    implementation('org.springframework.retry:spring-retry')
    implementation("org.springframework.boot:spring-boot-starter-webflux")
    implementation('org.springframework.boot:spring-boot-starter-data-r2dbc')
    implementation('com.oracle.database.r2dbc:oracle-r2dbc')
    implementation('com.oracle.database.jdbc:ojdbc11:21.1.0.0')
}

此处的零件代码导致错误：

message.flatMap { fromMessage ->
                Mono
                    .zip(
                        listOf(
                            dimensionAdviserRepository
                                .findFirstByEntityIdOrderByFromDateDescToDateDesc(message.adviserKey)
                                .map { it?.adviserKey ?: -1L }
                                .switchIfEmpty(Mono.just(-1L)),
                            dimensionAccountRepository
                                .findFirstByEntityIdOrderByFromDateDescToDateDesc(fromMessage.accountKey!!)
                                .map { it?.account_key ?: -1L }
                                .switchIfEmpty(Mono.just(-1L))
))}

我缺少任何配置还是这是已知的限制？

Answer 1

看起来，您自己在Oracle R2DBC Github回购中打开了一张罚单，在这个问题之后出现了这个问题，并得到了答案。

帮助有同样问题的人：

这是Oracle R2DBC版本0.1.0的已知限制。它已经在版本0.2.0中得到了修复，但该版本的目标是R2DBC SPI版本0.9，Spring Data R2DBC目前不支持该版本，因为它还没有正式发布。

R2DBC SPI版本0.9的GA版本计划于2021 12月06日发布，在此之后，我们可以期望Spring Data R2DBC实现对其的支持，从而可以升级Oracle R2DBC驱动程序并摆脱此限制。

编辑：根据计划，R2DBC SPI的0.9.0.RELEASE版本于昨天发布。现在只需要等待支持0.9版本R2DBCSPI的SpringDataR2DBC的新版本。