Reactor中.handle()与.map()的区别及选型疑问

你提供的两段代码在当前业务场景下都能正常工作，但两者的设计定位和适用场景有明确区别，具体选择可以参考以下分析：

先看你的两段实现代码 #

使用.handle()的实现 #

Flux.fromIterable(persons)
    .handle((person, sink) -> {
        try {
            stopProcessingStuff(person);
            disconnectPerson(person);
            sink.next(new DisconnectPersonResponse(Status.SUCCESS, person.id()));
        }
        catch (Exception ex) {
            sink.next(new DisconnectPersonResponse(Status.FAILURE, person.id()));
        }
    })

使用.map()的实现 #

Flux.fromIterable(persons)
    .map(person -> { // 注：原代码参数写的是b，应为笔误，改成person才能正常运行
        try {
            stopProcessingStuff(person);
            disconnectPerson(person);
            return new DisconnectPersonResponse(Status.SUCCESS, person.id());
        } catch (Exception e) {
            return new DisconnectPersonResponse(Status.FAILURE, person.id());
        }
    })

核心区别分析 #

• .map()：纯一对一转换
  它的设计目标就是做同步的元素转换，规则非常明确：输入一个元素，必须返回一个元素，既不能跳过元素，也不能输出多个元素。语义上，它就是在告诉维护者：这段逻辑只是把输入元素转换成另一种格式，没有额外的流控制逻辑。

• .handle()：灵活的流处理器
  它通过Sink对象提供了更灵活的流控制能力：

  • 可以选择不输出元素（不调用sink.next()）
  • 可以一个输入输出多个元素（多次调用sink.next()）
  • 可以手动触发流错误（sink.error()）或流完成（sink.complete()）
    它的语义是：这段逻辑不仅要处理元素，还要控制流的行为。

针对你的场景的选择建议 #

当前你的逻辑是每个输入person对应一个输出DisconnectPersonResponse，不管成功失败都是严格的一对一关系，没有任何额外的流控制需求。这种情况下：

• 优先选.map()：语义更清晰，代码更简洁，其他开发者一看就知道是做元素转换，符合Reactor的最佳实践。而且.map()的实现更轻量，不需要处理Sink的额外逻辑。
• 只有当未来你需要扩展逻辑（比如跳过某些person、一个person输出多个结果、手动终止流等）时，再考虑换成.handle()。

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