Saltar al contenido principal

Aggregator Microservices

ArchitecturalCloud distributedDecouplingMicroservicesAlrededor de 1 min

Propósito

El usuario realiza una sola llamada al servicio del agregador y, a continuación, el agregador llama a cada microservicio relevante.

Explicación

Ejemplo del mundo real

Nuestro mercado web necesita información sobre los productos y su inventario actual. Hace una llamada a un agregador
servicio que a su vez llama al microservicio de información del producto y al microservicio de inventario del producto que devuelve la
información combinada.

En palabras sencillas

Aggregator Microservice recopila datos de varios microservicios y devuelve un agregado para su procesamiento.

StackOverflow dice

Aggregator Microservice invoca múltiples servicios para lograr la funcionalidad requerida por la aplicación.

Ejemplo programático

Empecemos por el modelo de datos. Aquí está nuestro Product.

public class Product {
  private String title;
  private int productInventories;
  // getters and setters ->
  ...
}

A continuación, podemos presentar nuestro microservicio Aggregator (Agregador de microservicios). Contiene él ProductInformationClient (Información del producto del cliente) y él
ProductInventoryClient (Inventario del producto del cliente) de los clientes para llamar a los respectivos microservicios.

@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;
  }
}

Esta es la esencia de la implementación de microservicios de información. El microservicio de inventario es similar, simplemente regresa
recuentos de inventario.

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

Ahora llamando a nuestra REST API Aggregator devuelve la información del producto.

curl http://localhost:50004/product
{"title":"The Product Title.","productInventories":5}

Diagrama de clase

alt text
Aggregator Microservice

Aplicabilidad

Utilice el patrón Agregador de microservicios (Aggregator Microservices) cuando necesite una API unificada para varios microservicios, independientemente del dispositivo cliente.

Créditos