接收器和用户的概念看起来与我类似.此外,我没有看到在反应流规范中明确定义接收器的概念.
注意:此处,从反应式流规范中使用术语订户和订户。
在基于Spring Boot Webflux的微服务中考虑以下@RestController方法。
@GetMapping(path = "/users", produces = MediaType.APPLICATION_JSON_VALUE)
public Flux<TradingUser> listUsers() {
return this.tradingUserRepository.findAll();
}
@GetMapping(path = "/users/{username}", produces = MediaType.APPLICATION_JSON_VALUE)
public Mono<TradingUser> showUsers(@PathVariable String username) {
return this.tradingUserRepository.findByUserName(username);
}
Run Code Online (Sandbox Code Playgroud)
在这里,“谁/什么”将充当“订户”?我假设Spring Boot框架提供了Subscriber(?),有人可以提供详细信息或与此相关的任何链接吗?
假设我正在使用诸如postman / curl / browser之类的客户端来调用上述宁静的端点,那么在这种情况下,客户端如何向响应服务器发出需求信号?(只有Subscriber在Subscription对象上具有使用request(n)方法来表示需求的句柄。但是,由于Subscriber可能也是在Spring Boot框架实现的服务器端,因此实际的客户端如何发出信号?)我显然缺少了一些东西。