Java 中的微服务聚合器模式：构建高效的组合服务

大约 3 分钟

也称为

API 组合

微服务聚合器设计模式的意图

微服务聚合器模式有助于将来自多个微服务的响应聚合到单个统一响应中，从而优化可扩展系统中的客户端-服务器交互。

微服务聚合器模式的详细解释，并附带实际案例

实际案例

在旅行预订平台中，聚合器微服务整合来自航班、酒店和租车微服务的数据，提供无缝的用户体验并提高可扩展性。平台使用聚合器微服务，而不是用户向每个服务发出单独的请求。此微服务调用每个服务，收集其响应，然后将信息整合到单个统一响应中，并将其发送回用户。这通过在一个地方提供所有必要的旅行信息来简化用户体验，并减少用户需要与底层服务进行的直接交互次数。

通俗地说

微服务聚合器收集来自各个微服务的数据片段，并返回一个聚合结果以供处理。

Stack Overflow 说

微服务聚合器调用多个服务来实现应用程序所需的功能。

Java 中微服务聚合器模式的编程示例

我们的网络市场利用聚合器微服务从不同的微服务中获取组合的产品和库存信息，确保高效的数据处理和改进系统性能。

让我们从数据模型开始。这是我们的 Product。

public class Product {
    private String title;
    private int productInventories;
    // Other properties and methods...
}

接下来，我们可以引入我们的 Aggregator 微服务。它包含用于调用相应微服务的客户端 ProductInformationClient 和 ProductInventoryClient。


@RestController
public class Aggregator {

    @Resource
    private ProductInformationClient informationClient;

    @Resource
    private ProductInventoryClient inventoryClient;

    @RequestMapping(path = "/product", method = RequestMethod.GET)
    public Product getProduct() {

        var product = new Product();
        var productTitle = informationClient.getProductTitle();
        var productInventory = inventoryClient.getProductInventories();

        //Fallback to error message
        product.setTitle(requireNonNullElse(productTitle, "Error: Fetching Product Title Failed"));

        //Fallback to default error inventory
        product.setProductInventories(requireNonNullElse(productInventory, -1));

        return product;
    }
}

以下是信息微服务实现的本质。库存微服务类似，它只返回库存数量。


@RestController
public class InformationController {
    @RequestMapping(value = "/information", method = RequestMethod.GET)
    public String getProductTitle() {
        return "The Product Title.";
    }
}

现在，调用我们的 Aggregator REST API 会返回产品信息。

# Example bash call
curl http://localhost:50004/product

# Example output
{"title":"The Product Title.","productInventories":5}

何时在 Java 中使用微服务聚合器模式

微服务聚合器模式非常适合需要从多个微服务获取组合响应的场景，例如在电子商务和仪表板应用程序中，聚合数据可以增强用户体验和系统效率。

微服务聚合器模式的优缺点

优点

简化的客户端：客户端只需与一个服务交互，而不是管理对多个微服务的调用，这简化了客户端逻辑。
减少延迟：通过聚合响应，减少了网络调用的次数，从而可以提高应用程序的整体延迟。
解耦：客户端与各个微服务解耦，可以在不影响客户端的情况下更灵活地更改微服务环境。
集中逻辑：聚合允许对从各种服务收集的数据进行集中转换和逻辑应用，这比在客户端处理数据或将其分散到多个服务中更有效。

缺点

单点故障：如果聚合器服务没有设计为具有高可用性和可扩展性，它可能会成为瓶颈或单点故障。
复杂性：实现聚合器可能会引入复杂性，特别是在处理多个服务时，数据聚合逻辑和错误处理方面的复杂性。

API 网关：微服务聚合器模式通常与 API 网关一起使用，API 网关为客户端提供访问多个微服务的单一入口点。
组合：微服务聚合器模式可以被视为组合模式的一种形式，其中组合是来自多个微服务的聚合响应。
外观：微服务聚合器模式可以被视为外观模式的一种形式，其中外观是聚合器服务，它为客户端提供了一个简化的接口。