1

我正在尝试使用 Spring Boot 2.0、webflux 和 reactiv Mongo 存储库。我有两种变体，首先删除然后将数据添加到集合中。在第一个变体中，线程阻塞直到删除完成，在第二个变体中，数据的添加被连接到删除。

变体 A

@GetMapping("init")
public String init() {
    Random rand = new Random();
    Flux<Power> powers = Flux.range(0, 10000)
            .map(i -> new Power(i,
                    LocalDateTime.now().toEpochSecond(ZoneOffset.of("+1")),
                    rand.nextDouble()));
    powerRepository.deleteAll().block();
    powerRepository.save(powers).blockLast();
    return "ok";
}

变体 B

@GetMapping("init")
public String init() {
    Random rand = new Random();
    Flux<Power> powers = Flux.range(0, 10000)
            .map(i -> new Power(i,
                    LocalDateTime.now().toEpochSecond(ZoneOffset.of("+1")),
                    rand.nextDouble()));
    powerRepository.deleteAll()
            .concatWith((v) -> powerRepository.save(powers)).blockLast();
    return "ok";
}

变体 A 返回，变体 B 不返回。有什么区别？结合两个存储库操作的正确方法是什么？

4

1 回答 1

3

如果没有更好的方法，则使用 .then 调用链。避免阻塞调用，而是返回 Mono.just("ok")。

public Mono<String> init() {
    return repo.deleteAll()
        .then(() -> repo.save(...))
        .then(() -> Mono.just("ok"));
}

使端点返回 Mono。

于 2017-03-01T13:51:32.613 回答