Java Spring Boot中ResponseEntity 500状态码的Feign调用处理疑问

Core服务控制器代码 #

@PostMapping("/getGroupDefinitions")
public ResponseEntity<ResponseDTO> getGroupDefinition(@RequestBody GetGroupDefinitionRequestDao getGroupDefinitionRequestDao) {
    String endPoint = "/getGroupDefinitions";
    Timestamp landingTime = Timestamp.valueOf(LocalDateTime.now());
    log.info("getGroupDefinitionRequestDao: {}", getGroupDefinitionRequestDao.toString());
    try {
        List<PimGroupDefinitionProjection> response = pimGroupDefinitionService.getGroupDefinitions(getGroupDefinitionRequestDao);
        return ResponseUtil.sendResponse(
                response,
                landingTime,
                HttpStatus.OK,
                200,
                RequestMethod.POST.name(),
                endPoint
        );
    } catch (Exception e) {
        log.error("Error while getting Group Definitions: {}", (Object) e.getStackTrace());
        ResponseEntity<ResponseDTO> errorResponse = ResponseUtil.sendErrorResponse(
                "GET_GROUP_DEFINITIONS_ERROR",
                "Error while getting group definitions, " + e.getMessage(),
                landingTime,
                HttpStatus.INTERNAL_SERVER_ERROR,
                500
        );
        log.error("Error while getting Group Definitions: {}", errorResponse);
        return errorResponse;
    }
}

BFF服务控制器代码 #

@ActivityLogging
@PostMapping("/getGroupDefinitions")
public ResponseEntity<ResponseDTO> getGroupDefinitions(@RequestBody GetGroupDefinitionsRequestDao getGroupDefinitionsRequestDao, HttpServletRequest request) {
    String endPoint = "/getGroupDefinitions";
    log.info(endPoint + "request {}", getGroupDefinitionsRequestDao);
    Timestamp landingTime = Timestamp.valueOf(LocalDateTime.now());
    try {
        getGroupDefinitionsCoreResponse = pimCoreClient.getGroupDefinitions(getGroupDefinitionsRequestDao);
        if (getGroupDefinitionsCoreResponse.getStatusCode() != HttpStatus.OK) {
            throw new Exception(Objects.requireNonNull(getGroupDefinitionsCoreResponse.getBody()).getResponseMessage().getMessage());
        }
        return ResponseUtil.sendResponse(
                Objects.requireNonNull(getGroupDefinitionsCoreResponse.getBody()).getResponseData(),
                landingTime,
                HttpStatus.OK,
                200,
                "POST",
                endPoint
        );
    } catch (UnauthorizedException e) {
        log.error(LocalExceptionMessage.MSG_UNAUTHORIZED_EX + LocalExceptionMessage.MSG_MESSAGE + e.getMessage());
        return ResponseUtil.sendErrorResponse(
                "U",
                e.getMessage(),
                landingTime,
                HttpStatus.UNAUTHORIZED,
                401
        );
    } catch (Exception e) {
        log.error(LocalExceptionMessage.MSG_EX_FOUND + LocalExceptionMessage.MSG_MESSAGE + e.getMessage());
        return ResponseUtil.sendErrorResponse(
                "INTERNAL_SERVER_ERROR",
                e.getMessage(),
                landingTime,
                HttpStatus.INTERNAL_SERVER_ERROR,
                500
        );
    }
}

技术问题 #

通过Feign实现BFF与Core微服务通信，调试时发现调用pimGroupDefinitionService.getGroupDefinitions(getGroupDefinitionRequestDao)后进入了Core的catch块。想明确两个问题：

1. BFF Controller中，会执行判断coreResponse状态码的if语句，还是直接进入catch块？
2. 状态码为500的ResponseEntity的处理逻辑是怎样的？

1. BFF的执行路径判断 #

这完全取决于你的Feign客户端配置：

• 默认配置（未禁用decode404、未自定义错误解码器）：当Core返回500状态码时，Feign会自动抛出FeignException（或其子类），此时BFF的try块里调用pimCoreClient.getGroupDefinitions(...)会直接触发异常，根本走不到后续的if判断语句，直接跳进catch (Exception e)块（因为FeignException属于Exception子类）。
• 自定义了ErrorDecoder：如果配置了错误解码器，让Feign把非200状态码的响应解析成正常的ResponseEntity返回，那BFF就能拿到完整的getGroupDefinitionsCoreResponse，进而执行if判断，然后手动抛出异常进入catch块。

2. 500状态码ResponseEntity的处理逻辑 #

Core服务侧流程 #

当pimGroupDefinitionService.getGroupDefinitions(...)抛出异常时：

1. 进入Core的catch块，先打印异常栈信息。
2. 调用ResponseUtil.sendErrorResponse()构建包含错误码GET_GROUP_DEFINITIONS_ERROR、带异常详情的错误信息、请求落地时间的ResponseDTO，再封装成状态码500的ResponseEntity。
3. 打印最终返回的错误响应日志，然后把这个ResponseEntity返回给BFF。

BFF服务侧流程 #

分两种场景：

• Feign自动抛异常的场景：
  1. Feign调用Core时捕获到500响应，直接抛出FeignException。
  2. BFF的try块中断，进入catch (Exception e)块。
  3. 打印异常日志，调用ResponseUtil.sendErrorResponse()构建错误码为INTERNAL_SERVER_ERROR、携带异常信息的ResponseEntity，状态码设为500返回给前端。
• Feign返回正常ResponseEntity的场景：
  1. BFF拿到Core返回的500状态码ResponseEntity，执行if判断语句，抛出携带Core错误信息的Exception。
  2. 进入catch (Exception e)块，后续处理和上面一致，最终返回500错误响应给前端。

内容的提问来源于stack exchange，提问作者Harsha Varthan