springcloud gateway 熔断 降级 限流

一、Spring Cloud Hystrix 1. 什么是 Hystrix Hystrix 是一个延迟和容错库，用于隔离依赖服务的访问点，以防止这些依赖服务的故障导致雪崩效应。它提供了熔断、限流和降级等机制，保障了对依赖服务的访问。 2. Hystrix的核心概念 熔断：在一段时间内，如果服务的错误比例超过了设定的阈值，那么这个服务就会被熔断，示例代码： ``` @HystrixCommand(fallbackMethod = "fallbackMethod") public String method() { int i = new Random().nextInt(10); if (i % 2 == 0) { throw new RuntimeException("error"); } return "success"; } public String fallbackMethod(){ return "fallback"; } ``` 限流：在一段时间内，如果服务的请求数量超过了设定的阈值，那么这个服务就会被限流，示例代码： ``` @HystrixCommand(fallbackMethod = "fallbackMethod", commandProperties = { @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "500"), @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"), @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "50"), @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "30000")}) public String method() { return "success"; } public String fallbackMethod(){ return "fallback"; } ``` 降级：在一段时间内，如果依赖服务不可用，那么就会调用预先备选的服务逻辑或返回预先设定的响应，示例代码： ``` @HystrixCommand(fallbackMethod = "fallbackMethod") public String method() { return restTemplate.getForObject("http://service-provider/method", String.class); } public String fallbackMethod(){ return "fallback"; } ``` 3. Hystrix的集成 添加依赖 ``` <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency> ``` 开启熔断 ``` @SpringBootApplication @EnableCircuitBreaker public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } } ``` 添加注解 ``` @Service public class Service { @HystrixCommand(fallbackMethod = "fallbackMethod") public String method() { return "success"; } public String fallbackMethod() { return "fallback"; } } ``` 4. 测试 启动服务后，访问 http://localhost:8080/method，可以看到服务正常返回"success"。将calledOnce设置为false并再次访问该URL，可以看到服务返回"fallback"。 二、Spring Cloud Gateway 1. 什么是 Gateway Gateway 是 Spring Cloud 提供的一种 API 网关服务，基于 Spring 5.0、Spring Boot 2.0 和 Project Reactor 等技术开发。 2. Gateway 的三种机制 熔断：默认使用 Hystrix 进行熔断，示例代码： ``` spring.cloud.gateway.routes.id=route1 spring.cloud.gateway.routes.uri=http://httpbin.org:80 spring.cloud.gateway.routes.predicate[0]=Host=**.somehost.org spring.cloud.gateway.routes.predicate[1]=Path=/get spring.cloud.gateway.routes.filters[0]=Hystrix=hystrixCommandName ``` 限流：使用 RequestRateLimiter Gateway Filter 进行限流，示例代码： ``` spring.cloud.gateway.routes[0].id=count_route spring.cloud.gateway.routes[0].uri=http://httpbin.org:80 spring.cloud.gateway.routes[0].predicates[0]=Path=/get spring.cloud.gateway.routes[0].filters[0]=RequestRateLimiter=my-limiter-key,2,10,PT1S ``` 降级：可以使用 Hystrix 进行降级，示例代码： ``` spring.cloud.gateway.routes[0].id=test_route spring.cloud.gateway.routes[0].uri=http://localhost:9090 spring.cloud.gateway.routes[0].predicates[0]=Path=/test spring.cloud.gateway.routes[0].filters[0]=Hystrix=mycommand ``` 3. Gateway 的集成 添加依赖 ``` <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-gateway</artifactId> </dependency> ``` 4. 测试 启动服务后，访问 http://localhost:8080/get，可以看到服务正常返回。将请求频率配置为 0.1s，再次访问该 URL，可以看到服务返回 429 Too Many Requests。 参考资料： 1. Spring Cloud Hystrix 官方文档：https://cloud.spring.io/spring-cloud-static/spring-cloud-netflix/2.2.1.RELEASE/reference/html/#spring-cloud-hystrix 2. Spring Cloud Gateway 官方文档：https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.2.1.RELEASE/reference/html/

Spring Cloud Alibaba是一个基于Spring Cloud的开源框架，提供了丰富的微服务开发工具包，包括服务注册与发现、配置管理、消息总线、负载均衡、熔断降级、分布式事务、流量控制、安全控制、分布式追踪等功能。 Spring Cloud Alibaba与Nacos、Dubbo、Sentinel等组件协同工作，Nacos作为注册中心和配置中心，Dubbo作为RPC框架，Sentinel作为流量控制和熔断降级组件，共同构建起完整的微服务生态体系。 使用Spring Cloud Alibaba进行服务注册和发现，可以通过注解@EnableDiscoveryClient开启服务注册与发现功能，并通过@FeignClient或@LoadBalanced注解实现服务调用和负载均衡。 使用Spring Cloud Alibaba进行服务治理，可以通过注解@EnableCircuitBreaker开启熔断降级功能，并通过@SentinelResource注解配置熔断降级规则。 使用Spring Cloud Alibaba进行熔断降级，可以通过Sentinel Dashboard进行实时监控和管理，同时通过注解@SentinelRestTemplate实现对RestTemplate的熔断降级。 使用Spring Cloud Alibaba进行服务配置管理，可以通过注解@EnableConfigNacosConfig和@Value注解实现动态配置管理。 使用Spring Cloud Alibaba进行分布式事务管理，可以通过注解@EnableDistributedTransaction开启分布式事务管理功能，并通过@GlobalTransactional注解实现分布式事务的统一管理和控制。 使用Spring Cloud Alibaba进行链路追踪，可以通过注解@EnableZipkinServer和@EnableZipkinClient开启链路追踪功能，并通过Sleuth和Zipkin实现对微服务调用链的追踪和分析。 使用Spring Cloud Alibaba进行服务限流，可以通过Sentinel进行实时流控和熔断降级，同时通过注解@SentinelResource实现对服务的限流控制。 Spring Cloud Alibaba支持微服务的服务网关管理，可以通过注解@EnableZuulProxy或@EnableGateway开启服务网关功能，并通过Zuul或Gateway实现微服务的API网关管理。