经过gateway后的某个请求到达微服务A，微服务A调用微服务B，如果微服务B出现异常该怎么做让gateway捕捉到

### 微服务架构中 Gateway 捕捉下游微服务 B 异常的最佳实践 在微服务架构中，当某个微服务（如微服务 B）发生异常时，API 网关需要具备捕捉并妥善处理这些异常的能力。以下是关于如何利用 Spring Cloud Gateway 和 Spring Cloud Circuit Breaker 实现这一目标的具体方法。 #### 使用全局过滤器捕获异常 Spring Cloud Gateway 提供了一种机制，允许开发者定义全局过滤器来拦截和处理来自下游微服务的错误响应。可以通过自定义 `GlobalFilter` 来实现这一点： ```java import org.springframework.cloud.gateway.filter.GatewayFilterChain; import org.springframework.cloud.gateway.filter.GlobalFilter; import org.springframework.core.Ordered; import org.springframework.http.HttpStatus; import org.springframework.stereotype.Component; import org.springframework.web.server.ServerWebExchange; import reactor.core.publisher.Mono; @Component public class ErrorHandlerFilter implements GlobalFilter, Ordered { @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { return chain.filter(exchange).onErrorResume(error -> { HttpStatus status = HttpStatus.INTERNAL_SERVER_ERROR; // 默认状态码 if (error instanceof RuntimeException) { // 自定义逻辑判断特定类型的异常 status = HttpStatus.BAD_GATEWAY; } exchange.getResponse().setStatusCode(status); return exchange.getResponse().writeWith(Mono.fromSupplier(() -> exchange.getResponse().bufferFactory() .wrap(("An error occurred: " + error.getMessage()).getBytes()))); }); } @Override public int getOrder() { return Ordered.HIGHEST_PRECEDENCE; } } ``` 上述代码展示了如何创建一个全局过滤器，在其中捕获任何可能抛出的异常，并返回适当的 HTTP 响应给客户端[^1]。 #### 集成断路器模式增强稳定性 为了进一步提升系统的健壮性，可以在网关层集成熔断器功能。借助 Resilience4j 或 Sentinel 这样的工具，可以轻松实现对下游依赖的保护。下面是一个简单的例子展示如何配置 Hystrix 断路器支持： ```yaml spring: cloud: gateway: routes: - id: service_b_route uri: lb://microservice-b predicates: - Path=/api/serviceb/** filters: - name: RequestRateLimiter args: redis-rate-limiter.replenishRate: 10 redis-rate-limiter.burstCapacity: 20 - name: CircuitBreaker args: name: fallbackCmd fallbackUri: forward:/fallback/response ``` 这里设置了两个主要的功能：限流 (`RequestRateLimiter`) 和熔断 (`CircuitBreaker`) 。一旦触发了熔断条件，请求会被重定向至指定路径 `/fallback/response` ，从而提供友好的降级页面或者消息[^4]。 #### 定义回退控制器 最后一步就是编写实际用来呈现降级内容的服务端点： ```java @RestController @RequestMapping("/fallback") public class FallbackController { @GetMapping("/response") public String handleFallback() { return "{\"message\": \"Service is temporarily unavailable due to high load or maintenance.\"}"; } } ``` 这样即使微服务 B 出现问题，也不会影响整个应用对外的表现，而是优雅地给出提示信息[^5]。 ---