小编Jat*_*tin的帖子

在项目反应堆或akka流中,接收器和用户之间的概念差异是什么?

接收器和用户的概念看起来与我类似.此外,我没有看到在反应流规范中明确定义接收器的概念.

project-reactor reactive-streams akka-stream

29
推荐指数
1
解决办法
3267
查看次数

在基于Spring Boot Webflux的微服务中,订户是谁?

注意:此处,从反应式流规范中使用术语订户和订户。

在基于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)
  1. 在这里,“谁/什么”将充当“订户”?我假设Spring Boot框架提供了Subscriber(?),有人可以提供详细信息或与此相关的任何链接吗?

  2. 假设我正在使用诸如postman / curl / browser之类的客户端来调用上述宁静的端点,那么在这种情况下,客户端如何向响应服务器发出需求信号?(只有Subscriber在Subscription对象上具有使用request(n)方法来表示需求的句柄。但是,由于Subscriber可能也是在Spring Boot框架实现的服务器端,因此实际的客户端如何发出信号?)我显然缺少了一些东西。

spring-boot reactive-streams spring-webflux

2
推荐指数
1
解决办法
539
查看次数