java - 如何在可迭代的 Spring Boot Flux 中延迟发出每个项目

Question

我的问题略有不同，但我可以用以下方式描述问题。

我想要的是一些代码，每个延迟周期(3 秒)发出一个项目。但是当我点击 /flux URL 时，页面等待 3 秒并给出所有 4 个项目。这意味着它会在 3 秒后发出所有项目，而不是每 3 秒发出一个项目。

@RestController
@RequestMapping("/flux")
public class MyController {

    List<Item> items = Arrays.asList(
            new Item("name1","description1"),
            new Item("name2","description2"),
            new Item("name3","description3"),
            new Item("name4","description4"));
    @GetMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    Flux<Item> getItems(){
        return Flux.fromIterable(items)
                .delayElements(Duration.ofSeconds(3));
    }
}
@Data
@AllArgsConstructor
class Item{
    String name;
    String description;
}

更新

我看到了这个post解释如何在 RxJava 中执行此操作，所以我尝试了这个。但是使用 ZipWith 结果更糟。现在页面等待 12 秒。这意味着只有当 Flux 完成时才会发送浏览器响应......不知道为什么。

Flux<Item> getItems(){
            return Flux.fromIterable(items)
           .zipWith(Flux.interval(Duration.ofSeconds(3)),(item,time)->item);
}

附注使用 Spring WebFlux 依赖，因此本地启动时使用 Netty 而不是 Tomcat。

Answer 1

我们可以使用 delayElements(Duration delay) 告诉 react 器在特定延迟后发出元素。它总是尝试在特定持续时间后发出元素而不阻塞。

将此 URL 放在 google chrome 浏览器或任何其他消费者客户端(如 curl)而不是 postman 中。

---

curl

curl --location --request GET 'http://localhost:8080/fluxv2' \
--header 'Content-Type: text/event-stream' \
--data-raw ''

---

不要尝试用 postman 测试 API，因为 postman 目前不支持流式 API。

---

@RestController
@RequestMapping("/fluxv2")
public class MyController {
    Flux<String> stringFlux = Flux.fromIterable(List.of("CM", "Abdullah", "Khan"));
    @GetMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    Flux<String> getItems() {
        return stringFlux.delayElements(Duration.ofSeconds(3)).log();
    }
}

Logs shown that elements are emitting after specific delay