微服务架构下的API调用与整合：实现高效数据整合

在微服务架构中，高效地调用和整合不同服务的API是构建高性能应用的关键。本教程将带你深入了解如何实现这一目标。

任务目标

我们的目标是从电影目录服务获取用户评分的电影ID，然后为每个电影ID调用电影信息服务，整合这些数据并返回给用户。

技术步骤

实现这一目标需要以下几个关键步骤：

获取电影ID：从评分服务获取所有评分的电影ID。
循环调用电影信息服务：为每个电影ID调用电影信息服务获取详细信息。
整合数据：将获取的数据整合并返回给用户。

整合数据

通过调用不同的API来整合数据。首先从评分API获取电影ID列表，然后为每个ID调用电影信息服务获取详细信息。

List < Rating > ratings = new ArrayList < > ();
ratings.add(new Rating("1234", 4));
ratings.add(new Rating("5678", 5));

调用电影信息服务

为了获取电影信息，我们将使用REST模板调用电影信息服务。

硬编码示例

为了简化演示，我们暂时硬编码评分数据。在实际应用中，这些数据将通过API获取。

public class Rating {
    private String movieId;
    private int rating;

    public Rating(String movieId, int rating) {
        this.movieId = movieId;
        this.rating = rating;
    }

    // Getters and setters
}

创建电影信息模型

创建一个电影信息模型类，用于存储电影详细信息。

public class Movie {
    private String movieId;
    private String name;

    public Movie(String movieId, String name) {
        this.movieId = movieId;
        this.name = name;
    }

    // Getters and setters
}

循环调用API

对于每个评分，我们将循环调用电影信息服务获取电影详细信息。

private List < CatalogItem > getCatalogItems(List < Rating > ratings) {
    return ratings.stream()
        .map(this::getCatalogItem)
        .collect(Collectors.toList());
}

private CatalogItem getCatalogItem(Rating rating) {
    Movie movie = restTemplate.getForObject(
        "http://localhost:8080/movies/" + rating.getMovieId(), 
        Movie.class
    );
    return new CatalogItem(
        movie.getName(), 
        "Test Description", 
        rating.getRating()
    );
}

创建REST模板实例

在代码中创建REST模板实例，用于发送HTTP请求并接收响应。

@Bean
public RestTemplate getRestTemplate() {
    return new RestTemplate();
}

调用API并转换对象

使用REST模板的getForObject方法调用API，并将响应转换为电影信息对象。

Movie movie = restTemplate.getForObject(
    "http://localhost:8080/movies/" + rating.getMovieId(), 
    Movie.class
);

处理对象转换

确保电影信息类中有空构造函数，以便正确反序列化。

public class Movie {
    private String movieId;
    private String name;

    public Movie() {}

    public Movie(String movieId, String name) {
        this.movieId = movieId;
        this.name = name;
    }

    // Getters and setters
}

整合数据并返回

将获取的电影信息整合到目录项中，并返回给用户。

public class CatalogItem {
    private String name;
    private String description;
    private int rating;

    public CatalogItem(String name, String description, int rating) {
        this.name = name;
        this.description = description;
        this.rating = rating;
    }

    // Getters and setters
}

异步调用讨论

讨论如何使用异步方式调用API，以提高应用的性能和响应速度。

private List < CatalogItem > getCatalogItemsAsync(List < Rating > ratings) {
    List < CompletableFuture < CatalogItem >> futures = ratings.stream()
        .map(this::getCatalogItemAsync)
        .collect(Collectors.toList());

    return futures.stream()
        .map(CompletableFuture::join)
        .collect(Collectors.toList());
}

private CompletableFuture < CatalogItem > getCatalogItemAsync(Rating rating) {
    return CompletableFuture.supplyAsync(() - > {
        Movie movie = restTemplate.getForObject(
            "http://localhost:8080/movies/" + rating.getMovieId(), 
            Movie.class
        );
        return new CatalogItem(
            movie.getName(), 
            "Test Description", 
            rating.getRating()
        );
    });
}

错误处理

处理API调用过程中可能出现的错误，确保应用的健壮性和可靠性。

private CatalogItem getCatalogItemWithErrorHandling(Rating rating) {
    try {
        Movie movie = restTemplate.getForObject(
            "http://localhost:8080/movies/" + rating.getMovieId(), 
            Movie.class
        );
        return new CatalogItem(
            movie.getName(), 
            "Test Description", 
            rating.getRating()
        );
    } catch (RestClientException e) {
        // Handle error
        return new CatalogItem("Movie not found", "Description", 0);
    }
}