CircuitBreaker斷路器Fallback如何擷取異常

在Spring Cloud 2020新版裡, 可以使用新版的 CircuitBreaker 斷路器, 可以配置Fallback, 可以是内部的, 也可以是外部的Fallback.

内部 Fallback

這裡搭建一個内部fallback, 配置如下:

server:
  port: 8900

spring:
  application:
    name: ms-gateway
  main:
    allow-bean-definition-overriding: true
  cloud:
    zookeeper:
      connect-string: ${ZK_HOSTS:127.0.0.1:2181}
      discovery:
        enabled: true
        preferIpAddress: true
    loadbalancer:
      ribbon:
        enabled: false
    gateway:
      discovery:
        locator:
          lowerCaseServiceId: true
          enabled: true
      routes:
        - id: default
          uri: lb://ms-fundmain-service
          predicates:
            - Path=/fundmain/**
          filters:
            - StripPrefix=1
            - name: CircuitBreaker
              args:
                name: fetchIngredients
                fallbackUri: forward:/defaultfallback
            - name: Retry
              args:
                retries: 2
                series: SERVER_ERROR

      

fallback攔截了服務端異常, defaultfallback的實作如下:

@RestController
public class DefaultFallback {

private static final Logger logger = LoggerFactory.getLogger(GatewayErrorAttributes.class);

@RequestMapping("/defaultfallback")
@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
public Map<String, Object> defaultfallback() {

Map<String, Object> map = new HashMap<>();
map.put("code", 5001);
map.put("msg", "服務異常");
return map;
    }

}
      

這樣就可以實作一個最簡單的fallback, 如果要擷取服務的實際錯誤資訊, 則改造如下:

@RestController
public class DefaultFallback {

private static final Logger logger = LoggerFactory.getLogger(GatewayErrorAttributes.class);

@RequestMapping(value = "/defaultfallback")
@ResponseStatus
public Mono<Map<String, Object>> fallback(ServerWebExchange exchange) {
Map<String, Object> result = new HashMap<>(4);
result.put("code", 5001);

Exception exception = exchange.getAttribute(ServerWebExchangeUtils.CIRCUITBREAKER_EXECUTION_EXCEPTION_ATTR);

ServerWebExchange delegate = ((ServerWebExchangeDecorator) exchange).getDelegate();
logger.error("服務調用失敗，URL={}", delegate.getRequest().getURI(), exception);

result.put("uri", delegate.getRequest().getURI());

if (exception instanceof TimeoutException) {
result.put("msg", "服務逾時");
        }
else if (exception != null && exception.getMessage() != null) {
result.put("msg", "服務錯誤: " + exception.getMessage());
        }
else {
result.put("msg", "服務錯誤");
        }
return Mono.just(result);
    }
}

      

這次注入了一個 ServerWebExchange, 然後擷取儲存在 CIRCUITBREAKER_EXECUTION_EXCEPTION_ATTR 裡面的執行個體, 拿到相應的異常資訊.

外部Fallback

請參考 https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/, 使用 FallbackHeaders 即可.
      

spring:
  application:
    name: ms-gateway
  main:
    allow-bean-definition-overriding: true
  redis:
    host: 127.0.0.1
    port: 6379
    database: 0
  cloud:
    zookeeper:
      connect-string: ${ZK_HOSTS:127.0.0.1:2181}
      discovery:
        enabled: true
        preferIpAddress: true
    loadbalancer:
      ribbon:
        enabled: false
    gateway:
      discovery:
        locator:
          lowerCaseServiceId: true
          enabled: true
      routes:
        - id: testoutsidefallback
          uri: lb://ms-fundmain-service
          predicates:
            - Path=/fundmain2/**
          filters:
            - StripPrefix=1
            - name: CircuitBreaker
              args:
                name: fetchIngredients2
                fallbackUri: forward:/externalfallback
        - id: ingredients-fallback
          uri: lb://ms-fundmain-service
          predicates:
            - Path=/externalfallback
          filters:
            - name: FallbackHeaders
              args:
                executionExceptionTypeHeaderName: Exception-Type
                executionExceptionMessageHeaderName: Exception-Message
      

支援四個字段:

• executionExceptionTypeHeaderName ("Execution-Exception-Type")
• executionExceptionMessageHeaderName ("Execution-Exception-Message")
• rootCauseExceptionTypeHeaderName ("Root-Cause-Exception-Type")
• rootCauseExceptionMessageHeaderName ("Root-Cause-Exception-Message")

實作示例 Fallback如下: (注意, 此Controller不能放在網關項目裡, 否則就要用内部Fallback才行)

@RestController
public class ExternalFallback {

private static final Logger logger = LoggerFactory.getLogger(ExternalFallback.class);

private static final String EXECUTION_EXCEPTION_TYPE = "Exception-Type";
private static final String EXECUTION_EXCEPTION_MESSAGE = "Exception-Message";

@RequestMapping("/externalfallback")
@ResponseStatus
public Map<String, Object> externalfallback(HttpServletRequest request) {

Map<String, Object> map = new HashMap<>();
map.put("code", 5002);
map.put("msg", "服務異常");

map.put(EXECUTION_EXCEPTION_TYPE, request.getHeader(EXECUTION_EXCEPTION_TYPE));
map.put(EXECUTION_EXCEPTION_MESSAGE, request.getHeader(EXECUTION_EXCEPTION_MESSAGE));

return map;
    }
}

      

這次注入了一個 HttpServletRequest, 然後擷取儲存在 Header 裡面的資訊, 拿到相應的異常.

作者：飛雲~風之谷​