Spring Reactive Restful API真的是无阻塞模型？非响应式客户端疑问

首先给出基于R2DBC的响应式代码实现：

@Repository
public interface PersonRepository extends ReactiveCrudRepository<Person, UUID> {
    Flux<Person> findAllByStatus(PersonStatusEnum status);
}

// ...

@Service
@RequiredArgsConstructor
public class PersonService {
    private final PersonRepository repo;

    Flux<Person> findAllByStatus(PersonStatusEnum status){
        return repo.findAllByStatus(status);
    }
}

// ...

@RestController
@RequestMapping("person")
@RequiredArgsConstructor
public class PersonController {
    private final PersonService service;
    
    @GetMapping(produces = MediaType.APPLICATION_JSON_VALUE)
    public ResponseEntity<Flux<Person>> findAllByStatus(@PathVariable("status") PersonStatusEnum status){
        return ResponseEntity.ok(service.findAllByStatus(status));
    }
}

场景说明：Person表共有1000条记录，其中900条状态为ACTIVE。终端客户端需获取所有ACTIVE状态的人员数据，示例未使用分页等最佳实践，客户端采用非响应式方式（如cURL或使用RestTemplate的Java应用）。已知R2DBC会自动执行背压机制控制数据库的数据发送量，以下是对相关疑问的解答：

1. 采用非响应式的客户端能否确保接收全部900条记录？ #

可以。Spring WebFlux在处理返回Flux的控制器方法时，会自动将响应式流转换为符合HTTP协议的完整响应体。无论客户端是cURL、RestTemplate这类非响应式工具，都会收到完整的900条数据——WebFlux会将Flux中的所有元素收集并序列化为JSON数组（或通过HTTP分块编码逐步发送，客户端会自动读取直到流结束），不会出现数据丢失的情况。

2. 客户端是否也需要是响应式的（例如使用WebClient）？ #

不需要。响应式API的设计本身就兼容非响应式客户端，Spring WebFlux会自动适配不同类型的客户端：

• 对于响应式客户端（如WebClient），它能利用背压机制逐步接收数据，避免一次性加载大量数据到内存；
• 对于非响应式客户端，WebFlux会确保将所有数据完整传递给客户端，客户端无需做响应式改造即可正常接收。

3. 若客户端非响应式，RestController是否会在某处阻塞，等待Repository完成数据库查询后再返回响应？非响应式客户端如何接收完整响应体？ #

是的，这里存在逻辑上的等待，但并非传统的线程阻塞：

• 当非响应式客户端发起请求时，Spring WebFlux会订阅Flux<Person>并开始从数据库异步拉取数据。由于非响应式客户端无法处理流式数据，WebFlux会将所有数据收集完成（或通过分块编码逐步发送，客户端会等待所有分块接收完毕），直到整个Flux处理完成后，再将完整响应返回给客户端。
• 不过这个过程中，处理请求的Netty事件循环线程不会被阻塞——WebFlux利用异步机制处理数据库查询和数据序列化，只是逻辑上需要等待所有数据准备完成后，才能满足非响应式客户端对完整响应体的要求。
• 非响应式客户端（如RestTemplate）会按照传统HTTP请求的方式，持续等待服务器返回完整响应体，直到所有数据接收完毕后才会继续执行后续代码。

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