如何在Reactor中对包装为Mono的Closeable资源使用try-with-resources模式？

你需要的是异步获取资源+自动释放（无论成功/失败/取消），Mono.using只支持同步获取资源，所以应该用Reactor专门为异步资源场景设计的usingWhen方法，完美对应异步版的try-with-resources。

最优解决方案代码 #

Mono.usingWhen(
    // 异步获取资源的Publisher（直接传入你的myClientMono）
    myClientMono,
    // 使用资源执行业务逻辑，返回业务结果流
    myClient -> myClient.doSomething(),
    // 资源释放逻辑：无论业务流成功、失败还是被取消，都会执行
    myClient -> Mono.fromRunnable(myClient::close)
)
.subscribe(System.out::println);

关键细节说明 #

1. 完全异步，无阻塞：usingWhen的第一个参数直接接收异步资源流（你的myClientMono），不需要用block()破坏异步性，完全符合Reactor的非阻塞设计。
2. 可靠的资源释放：第三个参数的释放逻辑会被Reactor自动触发，覆盖所有终止场景：
   • 业务流成功完成
   • 业务流抛出异常
   • 订阅被主动取消
     相当于把close()放在了try-with-resources的finally块里，不会出现资源泄漏。
3. 处理阻塞的close操作：如果myClient.close()是阻塞方法，建议给释放逻辑指定单独的线程池，避免阻塞业务线程：

   myClient -> Mono.fromRunnable(myClient::close).subscribeOn(Schedulers.boundedElastic())
   

4. 异步close的适配：如果你的MyClient提供了异步close方法（返回Mono<Void>或Publisher<Void>），直接传入这个方法即可，不需要用Mono.fromRunnable包装：

   myClient -> myClient.asyncClose()
   

为什么你的之前方案有问题 #

• 第一个方案用block()强制同步获取资源，完全违背了Reactor的异步非阻塞设计，会导致线程阻塞，不能用于异步场景。
• 第二个方案把close()写在flatMap里，只有当doSomething()成功执行时才会触发关闭；如果doSomething()抛出异常，close()根本不会被调用，会造成资源泄漏。

内容的提问来源于stack exchange，提问作者Berti