以反应性的方式协调多个传出请求

Question

这更多是一个最佳实践问题。 在我当前的系统（Monolith）中，单个传入的HTTP API请求可能需要从几个后端来源收集类似结构化的数据，然后将其汇总，然后将数据返回到API响应中的客户端。

在当前实现中，我只需使用ThreadPool并行将所有请求发送到后端源，并且倒计时锁存锁定，以了解返回的所有请求。

我试图找出使用vert.x/quarkus等Reactice堆栈转换上述描述的最佳实践。我想保留接受此API调用的服务的反应性，通过HTTP调用多个（类似）后端源，汇总数据。

我可以粗略地猜测我可以使用静止的反应性来作为传入请求，也许是MP HTTP客户端的后端请求（不确定其反应性），但我不确定什么可以替换我的线程池以并行执行和执行。汇总返回数据的最佳方法是什么？

我认为，使用HTTP反应端客户端，我可以在循环中调用所有后端源，并且由于其反应性将“感觉到”像Parralel的工作。也许返回的数据应该通过流API加重（以加入数据流）？但是我不确定。 我知道这是一个漫长的问题，但有些指针会很棒。

谢谢！

Answer 1

您可以放下线程池，不需要它并行调用后端服务。

是的，MP RESTCLIENT是反应性的。假设您有这项服务，它援引了后端来获得漫画小人：

@RegisterRestClient(configKey = "villain-service")
public interface VillainService {

    @GET
    @Path("/")
    @NonBlocking
    @CircuitBreaker
    Uni<Villain> getVillain();

}

英雄的类似服务，heroservice。您可以将它们注入端点课上，取回小人和英雄，然后计算战斗：

@Path("/api")
public class Api {

    @RestClient
    VillainService villains;

    @RestClient
    HeroService heroes;

    @Inject
    FightService fights;

    @GET
    public Uni<Fight> fight() {
        Uni<Villain> villain = villains.getVillain();
        Uni<Hero> hero = heroes.getRandomHero();

        return Uni.combine().all().unis(hero, villain).asTuple()
                .chain(tuple -> {
                    Hero h = tuple.getItem1();
                    Villain v = tuple.getItem2();

                    return fights.computeResult(h, v);
                });
    }
}