在反应式编程中如何优雅地关闭数据库连接池中的连接

如何解决在反应式编程中如何优雅地关闭数据库连接池中的连接

最近在学习 Spring WebFlux。当我尝试关闭连接池中的连接时，它不起作用！

代码是这样的：

return connectionPool.create().flatMap(connection -> {
    Mono<Result> result = Mono.from(connection.createStatement("").execute());
    connection.close();
    return result;
    })
    .flatMap(body -> Mono.from(body.map(((row,rowMetadata) -> row.get(0,String.class)))));

我注意到 close 函数会返回一个 Publish< Void> 对象，但我不知道如何一起处理两个数据流（Mono< Result> 和 Publish< Void>） ！

有人可以帮我吗？

解决方法

您可以将 doFinally() 处理程序附加到 Mono，以便无论流处理是否正常完成，它都可以确保连接关闭。

像这样：

.flatMap(c -> 
    Mono.from(c.createStatement("query goes here...")
      .execute())
      .doFinally((st) -> close(c))
 )