Hystrix熔断器整合 - 服务熔断和服务降级

实战前需了解：https://blog.csdn.net/wanzijy/article/details/125041622
Hystrix熔断器整合 - 搭建项目：https://blog.csdn.net/wanzijy/article/details/125496651
Hystrix熔断器整合 - 请求缓存：https://blog.csdn.net/wanzijy/article/details/125512072
Hystrix熔断器整合 - 请求合并：https://blog.csdn.net/wanzijy/article/details/125579664
Hystrix熔断器整合 - 服务隔离之线程池隔离：https://blog.csdn.net/wanzijy/article/details/125630353
Hystrix熔断器整合 - 服务隔离之信号量隔离：https://blog.csdn.net/wanzijy/article/details/125826690
Hystrix熔断器整合 - 服务熔断和服务降级：https://blog.csdn.net/wanzijy/article/details/125826853
Hystrix熔断器整合 - Feign实现服务容错：https://blog.csdn.net/wanzijy/article/details/125985304
Hystrix熔断器整合 - 可视化界面三部曲：https://blog.csdn.net/wanzijy/article/details/126005452

1. 服务熔断

1.1 说明

由于某些原因使得服务出现了过载现象，为防止造成整个系统故障，从而采用的一种防护措施，也成为过载保护

以下操作均在 order-service-rest 模块中进行

1.2 修改 ProductServiceImpl

@HystrixCommand(commandProperties = {
	//  当请求符合熔断条件触发 fallbackMethod ，默认 20个
	@HystrixProperty(name = HystrixPropertiesManager.CIRCUIT_BREAKER_REQUEST_VOLUME_THRESHOLD, value = "10"),

	//  请求错误率大于 50% 就启动熔断器，然后 for 循环发起重试请求，当请求符合条件触发 fallbackMethod ，默认时 50%
	@HystrixProperty(name = HystrixPropertiesManager.CIRCUIT_BREAKER_ERROR_THRESHOLD_PERCENTAGE, value = "50"),

	//  熔断多少秒后去重试，默认 5s
	@HystrixProperty(name = HystrixPropertiesManager.CIRCUIT_BREAKER_SLEEP_WINDOW_IN_MILLISECONDS, value = "5000")
    }, fallbackMethod = "selectProductByIdFallback")  //  这里的方法名要和下面定义的回调方法的方法名相同
    public Product selectProductListById(Integer id) {
        System.out.println("------selectProductListById------" +
LocalDateTime.now().format(DateTimeFormatter.ISO_LOCAL_TIME));
	if (1 == id) {
		throw new RuntimeException("查询主键为 1 的商品信息导致异常");
	}
	return restTemplate.getForObject("http://product-service/product/" + id, Product.class);
}

public Product selectProductByIdFallback(Integer id) {
	return new Product(id, "托底数据", 1, 2666D);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

1.3 修改 OrderServiceImpl

@Override
public Order searchOrderById(Integer id) {
	return new Order(id, "order-003", "中国", 2666D,
Arrays.asList(productService.selectProductListById(1)));
}
1
2
3
4
5

1.4 测试

连续快速的访问：http://localhost:9090/order/1/product ，因为在注解中设置的次数是10次，所以在测试时要大于等于10次去访问该接口

2. 服务降级

其实上述所有的 fallbackMethod 都是降级

以下操作均在 order-service-rest 模块中进行

2.1 修改 ProductServiceImpl

@HystrixCommand(fallbackMethod = "selectProductByIdFallback")
public Product selectProductListById(Integer id) {
	return restTemplate.getForObject("http://product-service/product/" + id, Product.class);
}
1
2
3
4

2.2 测试

访问 http://localhost:9090/order/1/product

此时关掉 product-service 模块，再次访问