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

Question

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

代码是这样的：

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 函数会 return 一个 Publish< Void> 对象，但我不知道如何处理两个数据流（Mono< Result> 和 Publish< Void>) 在一起!

有人可以帮我吗？

Answer 1

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

像这样：

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

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

In reactive programming how to elegantly close the connection in the database connection pool

java

spring

mysql-connector

reactive

webflux