如何在反应链中传递数据

Question

每当我需要在反应链中传递数据时，我都会做如下操作：

public Mono<String> doFooAndPassDtoAsMono(Dto dto) {
    return Mono.just(dto)
        .flatMap(dtoMono -> {
            Mono<String> result = // remote call returning a Mono
            return Mono.zip(Mono.just(dtoMono), result);
        })
        .flatMap(tup2 -> {
            return doSomething(tup2.getT1().getFoo(), tup2.getT2()); // do something that requires foo and result and returns a Mono
        });
}

给定以下示例Dto类：

class Dto {
    private String foo;

    public String getFoo() {
        return this.foo;
    }
}

因为一直压缩数据以将其传递到链中（特别是向下几级）通常会变得很乏味，我想知道直接引用dto是否可以这样做：

public Mono<String> doFooAndReferenceParam(Dto dto) {
       Mono<String> result = // remote call returning a Mono
        return result.flatMap(result -> {
            return doSomething(dto.getFoo(), result); // do something that requires foo and result and returns a Mono
        });
}

我对第二种方法的担忧是，假设订阅者在线程池上订阅了这个Mono，我需要保证Dto是线程安全的吗（上面的例子很简单，因为它只携带一个String，但是如果不是呢）？

另外，哪一个被认为是“最佳实践”？

Answer 1

案子很简单如果

• 参考数据从一开始就可用（即在创建链之前），并且
• 创建链的目的是处理最多一个事件（即以单声道开始），以及
• 参考数据是不可变的

然后，您可以简单地引用参数或局部变量中的引用数据——就像在您的第二个解决方案中一样。这完全没问题，也没有并发问题。

强烈反对在反应流中使用可变数据。如果您有一个可变的Dto类，您可能仍然能够使用它（假设正确的同步），但这对于您的代码读者来说将是非常令人惊讶的。

Answer 2

根据您共享的内容，您可以简单地执行以下操作：

public Mono<String> doFooAndPassDtoAsMono(Dto dto) {
    return Mono.just(dto.getFoo());
}

您在第一个选项中使用zip的方式并不能解决任何目的。同样，第二个选项也不起作用，因为一旦单声道是空的，下一个平面地图就不会被触发。