Reactor资源释放

在Reactor中，doFinally 和 using 是两个与命令式编程中的 finally 块和 Java 7 引入的 try-with-resources 构造相对应的操作符。它们的共同目标是在资源或操作完成后执行清理操作，以确保资源被正确释放或副作用被处理。

1. doFinally 与 finally 块的类比

• finally 块：在命令式编程中，finally 块用于在 try 块执行完成后（无论是否发生异常）执行清理操作。例如，打开文件后，无论是否成功读取，都需要在 finally 块中关闭文件。这种机制确保了资源的正确释放，避免了资源泄漏。

• doFinally：在Reactor中，doFinally 操作符用于在Flux或Mono终止时执行清理操作。它类似于 finally 块，但适用于响应式流中的事件处理。doFinally 接收一个 SignalType 参数，表示终止的类型（完成、错误或取消），从而可以进行针对性的清理操作。

  例如：

  Flux<String> flux =
      Flux.just("foo", "bar")
          .doOnSubscribe(s -> stats.startTimer())
          .doFinally(type -> {
              stats.stopTimerAndRecordTiming();
              if (type == SignalType.CANCEL) {
                  statsCancel.increment();
              }
          })
          .take(1);
  

  在这个例子中，doFinally 会在流完成、出错或被取消时执行清理操作，并根据终止类型进行相应的统计或日志记录。

2. using 与 try-with-resources 的类比

• try-with-resources：Java 7 引入的语法结构，允许在 try 语句中声明资源，并在 try 块执行完毕后自动关闭这些资源。例如：

  try (SomeAutoCloseable disposableInstance = new SomeAutoCloseable()) {
      return disposableInstance.toString();
  }
  

  这种方式不仅减少了代码冗余，还避免了手动关闭资源时可能出现的错误。

• using：在Reactor中，Flux.using() 是 try-with-resources 的响应式等效项。它允许在Flux终止时执行资源清理操作，类似于 try-with-resources 中的自动关闭机制。using 接收三个参数：

  • 第一个参数用于获取资源；
  • 第二个参数用于利用资源生成数据流；
  • 第三个参数用于在处理完成后清理资源。

  例如：

  Flux<String> flux =
      Flux.using(
          () -> disposableInstance, 
          disposable -> Flux.just(disposable.toString()), 
          Disposable::dispose
      );
  

  在这个例子中，using 会在Flux终止时自动调用 dispose 方法，释放资源。

3. 总结类比

4. 关键区别与用途

• doFinally：用于在流终止时执行副作用操作，例如记录日志、统计时间等。它提供了终止类型的提示（完成、错误、取消），以便进行针对性处理。
• using：用于处理从资源派生的Flux，并在处理完成后清理资源。它类似于 try-with-resources，但适用于响应式流。

5. 示例对比

命令式编程中的 finally 块

Stats stats = new Stats();
stats.startTimer();
try {
    doSomethingDangerous();
}
finally {
    stats.stopTimerAndRecordTiming();
}

Reactor 中的 doFinally

Flux<String> flux =
    Flux.just("foo", "bar")
        .doOnSubscribe(s -> stats.startTimer())
        .doFinally(type -> {
            stats.stopTimerAndRecordTiming();
            if (type == SignalType.CANCEL) {
                statsCancel.increment();
            }
        })
        .take(1);

命令式编程中的 try-with-resources

try (SomeAutoCloseable disposableInstance = new SomeAutoCloseable()) {
    return disposableInstance.toString();
}

Reactor 中的 using

Flux<String> flux =
    Flux.using(
        () -> disposableInstance, 
        disposable -> Flux.just(disposable.toString()), 
        Disposable::dispose
    );

6. 总结

• doFinally 是 Reactor 中用于在流终止时执行副作用操作的等效于 finally 块的操作符。
• using 是 Reactor 中用于在资源处理完成后自动清理资源的等效于 try-with-resources 的操作符。
• 两者都用于确保资源被正确释放或副作用被处理，从而避免资源泄漏或状态不一致的问题。