使用 RestTemplate 在循环中处理异常

Question

我有一个对象列表，对于每个对象，我需要使用 RestTemplate 访问外部 API。为此，我将 for 循环与 try-catch 块一起使用。如果外部 API 确实以 4xx、5xx 状态代码响应，我需要创建错误列表并抛出自定义异常，该异常使用异常处理程序处理以发送客户端友好的消息，这些消息也会发送电子邮件通知。要求是删除 try-catch 块并在循环中命中外部 API 并创建错误列表并检查错误列表是否不为空抛出异常并使用电子邮件通知一次发送所有错误消息异常处理方法handleApplicationErrors。但我相信当任何异常发生时 for 循环将是一个中断，如果没有 try-catch 块，我将无法创建错误消息列表，有什么可能的方法吗？

public void method() {
    List<Objects> objects = fetchObjects();
    List<String> errorList = new ArrayList();

    for(int i=0;i<objects.size();i++) {
      try{
        hitExternalApi(object)
      }
      catch(Exception e){
        errorList.add("Error Message")
      }
    }
    if(!errorList.isEmpty()) {
       throw new ErrorDTO(Status.BAD_REQUEST, errorList);
    }
}

  @Override
  public void hitExternalApi(Object object) { 
    httpHeaders.setContentType(MediaType.APPLICATION_JSON);
    HttpEntity<Object> request = new HttpEntity<>(object, httpHeaders);
    restTemplate.exchange(url, HttpMethod.POST, request, Void.class);
  }

@ExceptionHandler(ErrorDTO.class)
  public ResponseEntity<Problem> handleApplicationErrors(NativeWebRequest request, ErrorDTO error) {
    notificationService.sendNotification(error.getErrors());
    Problem problem =
        Problem.builder()
            .withStatus(error.getStatus())
            .withTitle(error.getMessage())
            .withDetail(error.getErrors().toString())
            .build();
    return create(error, problem, request);
  }

Answer 1

您应该能够通过将 try-catch 块向下移动到 hitExternalApi 方法来解决您的要求，如果您需要传递任何信息，请让它返回一个布尔值或 DTO。然后，for 循环可以检查 hitExternalApi 的返回值并在需要时填充 errorList。 修改代码示例：

public void method() {
   List<Objects> objects = fetchObjects();
   List<String> errorList = new ArrayList();

   for (int i = 0; i < objects.size(); i++) {
     if (!hitExternalApi(object)) {
       errorList.add("Error Message");
     }
   }
   if (!errorList.isEmpty()) {
     throw new ErrorDTO(Status.BAD_REQUEST, errorList);
   }
 }

 public boolean hitExternalApi(Object object) {
   httpHeaders.setContentType(MediaType.APPLICATION_JSON);
   HttpEntity<Object> request = new HttpEntity<>(object, httpHeaders);
   try {
     restTemplate.setErrorHandler();
     restTemplate.exchange(url, HttpMethod.POST, request, Void.class);
     return true;
   } catch (Exception exception) {
     return false;
   }
 }

默认情况下，（因此当使用DefaultResponseErrorHandler 时），restTemplate.exchange(...) 的调用将针对 4xx 和 5xx 响应抛出某种 RestClientException，因此您需要在某处处理此异常或提供您自己的ResponseErrorHandler 并围绕它构建逻辑。

Answer 2

你可以创建一个额外的对象来控制流程

public class ApiResponsePojo {
    private HttpStatus status;
    private String message;
    private String data;
}

您可以使用这样的类并将其修改为您想要存储消息的方式。您可以通过状态检查是否有任何错误并在状态中填充一条消息

Answer 3

您可以将 for 循环放在一个函数中，并在调用该函数后调用异常。

请参考以下示例以获得更好的理解：

之前

public class ExceptionInLoop{
public static void sampleMethod(){
  String str[] = {"Mango", "Apple", "Banana", "Grapes", "Oranges"};
     try {
        for(int i=0; i<=10; i++) {
           System.out.println(str[i]);
           System.out.println(i);
        }
     }catch (ArrayIndexOutOfBoundsException ex){
        System.out.println("Exception occurred");
  }
  System.out.println("hello");
}
public static void main(String args[]) {
  sampleMethod();
}}

之后

public class ExceptionInLoop{
public static void print(String str) {
  System.out.println(str);
}
public static void sampleMethod()throws ArrayIndexOutOfBoundsException   {
  String str[] = {"Mango", "Apple", "Banana", "Grapes", "Oranges"};
     for(int i=0; i<=10; i++) {
        try {
           print(str[i]);
           System.out.println(i);
        } catch(Exception e){
        System.out.println(i);
     }
  }
}
public static void main(String args[]) {
  try{
     sampleMethod();
  }catch(ArrayIndexOutOfBoundsException e) {
     System.out.println("");
  }
}}