Spring Boot 服务间通信异常处理

Question

我有一个正在调用另一个服务 B 的微服务 A。我正在尝试使用 @ExceptionHandler 处理错误消息。

我想将从 B 收到的错误消息传播到服务 A。 但在其余的调用响应中，它给出了 HttpStatus 代码但没有正文（null）。下面是截图：

postman 中服务 B 的响应如下所示。我想在我的服务 A 中获得相同的错误响应消息。

以下是我的代码：

RestServiceCall.java

public List<AccessResponse>  daxObjectAccessibilitycall(AccessDataObject requestEntity) {
        ResponseEntity<AccessResponse[]> responseEntity = restTemplate.postForEntity(getFullPathService(), requestEntity, AccessResponse[].class);
        if (responseEntity == null) {
            return Collections.emptyList();
        }

        AccessResponse[] accessResponse = responseEntity.getBody();
        return Arrays.asList(accessResponse);
    }

在错误处理期间，它会抛出一个异常，在此代码中处理：

public boolean myFoo(MyDto){
.
.
.

        try {
            myObjectAccessibilitycall = serviceCall.objectAccessibilitycall(accessDataObj);
        } catch (RestClientException e) {
            logger.error("Error while getting response from Accessibility", e);
            throw new myException("Error: ", e);
        }

        if (!CollectionUtils.isEmpty(myObjectAccessibilitycall )) {
            for (AccessResponse accessResponse : myObjectAccessibilitycall ) {
                accessFlag = accessResponse.isResponseMsg();
            }
        }
        return accessFlag;
    }

感谢您对此的任何帮助。 干杯！

Answer 1

有两种选择 1. 使用@ControllerAdvice 处理异常。下面我们正在处理 IllegalArgumentException 和 IllegalStateException 异常。就像你需要处理 HttpClientErrorException

@ControllerAdvice
public class RestResponseEntityExceptionHandler 
  extends ResponseEntityExceptionHandler {

    @ExceptionHandler(value 
      = { IllegalArgumentException.class, IllegalStateException.class })
    protected ResponseEntity<Object> handleConflict(
      RuntimeException ex, WebRequest request) {
        String bodyOfResponse = "This should be application specific";
        return handleExceptionInternal(ex, bodyOfResponse, 
          new HttpHeaders(), HttpStatus.CONFLICT, request);
    }
}

选项 2. 你可以捕获 RestClientResponseException

<T> ResponseEntity consumeWebService(String url, Class<T> responseType) {  
    try {
        return restTemplate.getForEntity(url, responseType);
    } catch (RestClientResponseException e) {
        return ResponseEntity
            .status(e.getRawStatusCode())
            .body(e.getResponseBodyAsString());
    }
}