Quarkus使用MicroProfile调用动态端点Rest API并验证HTTP状态的实现问题

你调用接口拿到的返回数据结构示例如下：

"ApiResources": [
    {
        "ApiFamilyType": "products-services",
        "ApiVersion": 1,
        "ApiResourceId": "d33ff8af-5a1b-4b43-90d4-34237997d080",
        "ApiDiscoveryEndpoints": [
            {
                "ApiEndpoint": "https://api.yyyyyyyy/v1/personal-accounts"
            },
            {
                "ApiEndpoint": "https://api.xxxxxxx/business-accounts"
            }
        ]
    }
]

实现步骤 #

• 首先定义Java实体类和上述JSON结构做字段映射，确保MicroProfile Rest Client可以正确反序列化返回结果。
• 注入自定义的Discovery API Rest Client实例，调用对应接口拿到完整的ApiResources列表。
• 逐层遍历ApiResources下的ApiDiscoveryEndpoints数组，提取所有的ApiEndpoint地址。
• 对每个地址发起HTTP请求，获取返回的HTTP状态码做合法性校验。

核心代码示例 #

// 层级映射实体定义
public class ApiDiscoveryResponse {
    private List<ApiResource> ApiResources;
    // 省略getter、setter
}

public class ApiResource {
    private String ApiFamilyType;
    private Integer ApiVersion;
    private String ApiResourceId;
    private List<ApiEndpointObj> ApiDiscoveryEndpoints;
    // 省略getter、setter
}

public class ApiEndpointObj {
    private String ApiEndpoint;
    // 省略getter、setter
}

// 业务校验逻辑
@Inject
@RestClient
YourDiscoveryApiClient discoveryApiClient;

@Inject
Client jaxrsClient;

public void validateAllEndpoints() {
    // 调用接口获取资源列表
    ApiDiscoveryResponse response = discoveryApiClient.getResourceList();
    
    // 遍历所有URL逐个校验状态
    response.getApiResources().stream()
        .map(ApiResource::getApiDiscoveryEndpoints)
        .flatMap(Collection::stream)
        .map(ApiEndpointObj::getApiEndpoint)
        .forEach(url -> {
            int status = jaxrsClient.target(url).request().get().getStatus();
            // 自定义状态校验逻辑示例
            if (status < 200 || status >= 300) {
                // 可替换为日志记录或者自定义异常抛出
                System.out.printf("接口%s调用异常，状态码：%d%n", url, status);
            } else {
                System.out.printf("接口%s调用正常，状态码：%d%n", url, status);
            }
        });
}

常用优化点 #

• 可以配置MicroProfile Rest Client的全局超时、重试策略，避免单个接口调用超时阻塞整个校验流程。
• 如需并发调用提升校验效率，可改用异步客户端或者把校验逻辑提交到独立线程池执行。
• 针对需要鉴权的接口，可在请求头统一注入Authorization参数，无需逐个接口配置。

内容的提问来源于stack exchange，提问作者Alex Braz