SpringBoot WebFlux整合MongoDB批量删除时count始终返回0如何解决

开发者阿泽

2026-9-29

问题根因

你定义的Flux.fromIterable(ids)整段响应式处理流程仅完成了逻辑声明，没有被订阅触发执行，因此流内部的count.getAndAdd(1)逻辑完全不会运行，你直接返回了初始化值为0的AtomicInteger，所以结果永远是0。

此外在响应式编程中使用AtomicInteger这类外部共享变量统计数据是不推荐的写法，既不符合响应式无状态设计原则，也存在线程安全风险。

正确实现

@ApiOperation(value = "Delete multi cities")
@DeleteMapping
public Mono<ResponseEntity<Integer>> deleteByIds(@RequestBody @NotNull Set<String> ids) {
    return Flux.fromIterable(ids)
            .flatMap(cityService::findById)
            .flatMap(city -> cityService.deleteById(city.getId()).thenReturn(city))
            // 统计成功删除的条目数
            .count()
            .doOnNext(count -> log.debug("count = {}", count))
            .map(count -> ResponseEntity.ok(count.intValue()));
}