Spring Boot Flux可迭代对象元素间隔延迟发射的实现问题

1. 排除客户端缓冲问题 #

多数普通浏览器、低版本Postman默认会对SSE响应做内容缓冲，攒到固定大小才会渲染输出，并非服务端没有按间隔发送数据。

• 排查方式：使用curl命令直接请求接口测试，curl默认不会缓冲SSE流，可直观看到实时输出：

curl http://localhost:你的服务端口/flux

如果curl可正常每隔3秒输出一条数据，说明服务端逻辑无异常，问题出在客户端工具的缓冲机制。

2. 禁用服务端输出缓冲 #

Spring WebFlux默认会对响应开启小幅输出缓冲，可通过以下方案强制关闭：

• 方案1：在项目配置文件中添加配置：

spring:
  webflux:
    codec:
      max-in-memory-size: 0

• 方案2：修改接口返回类型，使用ServerSentEvent包装返回元素，Spring会严格按照SSE协议标准输出每条数据，不会做额外缓冲：

@GetMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE)
Flux<ServerSentEvent<Item>> getItems(){
    return Flux.fromIterable(items)
            .delayElements(Duration.ofSeconds(3))
            .map(item -> ServerSentEvent.builder(item)
                    .build());
}

3. 调度器上下文确认 #

delayElements默认使用并行调度器，无需额外配置。你尝试的zipWith写法逻辑本身没有问题，出现12秒才返回的情况基本是触发了服务端全量缓冲机制，按上述方案修改为ServerSentEvent包装返回后即可解决。

修正后完整可运行代码示例 #

@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<ServerSentEvent<Item>> getItems(){
        return Flux.fromIterable(items)
                .delayElements(Duration.ofSeconds(3))
                .map(item -> ServerSentEvent.builder(item)
                        .build());
    }
}

@Data
@AllArgsConstructor
class Item{
    String name;
    String description;
}

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