从单个服务多次调用多个微服务的最佳方法或设计模式是什么？

Question

微服务 A 依赖于微服务 B 和 C。当客户端调用服务 A 上的某个端点时，这将导致从 A 向服务 B 和 C 发出多个 HTTP 请求以获取依赖的详细信息。同时处理这种情况的最佳、性能有效的设计模式或方法是什么？

注意：在这种情况下我们没有使用 API 网关。

Answer 1

根据您的问题，我认为无法利用基于事件/反应式的方法，并且已经根据此处考虑的权衡做出了架构决策（请注意，在本源中，下面提出的方法被称为“混合”）。

编排

在这些条件下，您正在寻找的模式称为Orchestration。查看这个很棒的答案以获得更广泛的概述。

快速回顾一下，您可以使用Spring Integration之类的东西来实现以下要点：

• 在处理对 A 的请求时，尽可能同时执行对 B 和 C 的调用，以实现 A 的最快响应时间
• 将并发调用的结果累积、转换和聚合为完整的响应实体
• 利用线程池限制B、C并发请求，防止级联故障放大
• 快速失败：如果某些请求失败，则提前取消后续的一堆调用（即，如果对 B 的调用不成功，则不调用 C）
• 截止：涉及您可以等待当前运行的对 B 和 C 的一堆调用完成并在经过后由 A 响应错误的最大处理时间

更新 - 依赖于客户端Reactor 模式的实现

如果您可以使用 Spring 5/Spring Boot 2.x，您还可以使用基于Project Reactor 的Spring WebFlux以响应式方式调用 B 和 C来实现上述几点。

概括地说，您可以执行以下操作：

@Service
public class MyService {

    private final WebClient webClient;

    ...

    public Mono<Details> someRestCall(String name) {
        return this.webClient.get().url("{name}/details", name)
                        .retrieve().bodyToMono(ResponseEntity.class);
    }

}

...


Mono<ResponseEntity> b1 = myService.someRestCall("serviceB");
Mono<ResponseEntity> c1 = myService.someRestCall("serviceC");
Mono<ResponseEntity> b2 = myService.someOtherRestCall("serviceB");

ResponseEntity response = Flux
       .parallel(NUM_CPUS)
       .merge(b1, c1, b2)
       .limitRequest(MAX_REQUESTS)
       .onErrorReturn(ERR_RESPONSE_ENTITY)
       .blockLast(CUTOFF_TIMEOUT);

（基于这个例子）