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

Question

最近在学习 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>）！

有人可以帮助我吗？

Answer 1

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

像这样的东西：

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