SpringCloud学习心得---Hystrix熔断机制
本帖最后由 zyt温柔发 于 2022-2-17 17:04 编辑8 Hystrix
8.1服务熔断机制
熔断机制是应对雪崩效应的一种微服务链路保护机制。
当扇出链路的某个微服务不可用或者响应时间太长时，会进行服务的降级，进而熔断该节点微服务的调用，快速响应错误信息。当检测到该节点微服务调用响应正常后恢复调用链路。在 SpringCloud 框架里熔断机制通过 Hystrix 实现。Hystrix 会监控微服务间调用的状况，当失败的调用到一定阈值，缺省是 5 秒内 20 次调用失败就会启动熔断机制。熔断机制的注解是@HystrixCommand
8.1.1 依赖信息
```
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
```
8.1.2 主启动类注解
// 使用@EnableCircuitBreaker注解开启断路器功能
@EnableCircuitBreaker
@SpringBootApplication
public class AtzytMainType {
public static void main(String[] args) {
SpringApplication.run(AtzytMainType.class, args);
}
}
8.1.3 ResultEntity(统一使用这个类型作为 Ajax 请求或远程方法调用返回响应的数据格式)
package com.study.spring.cloud.util;
/**
* 整个项目统一使用这个类型作为Ajax请求或远程方法调用返回响应的数据格式
* @AuThor Lenovo
*
* @Param <T>
*/
public class ResultEntity<T> {
public static final String SUCCESS = "SUCCESS";
public static final String FAILED = "FAILED";
public static final String NO_MESSAGE = "NO_MESSAGE";
public static final String NO_DATA = "NO_DATA";
/**
* 操作成功，不需要返回数据
* @return
*/
public static ResultEntity<String> successWithoutData() {
return new ResultEntity<String>(SUCCESS, NO_MESSAGE, NO_DATA);
}
/**
* 操作成功，需要返回数据
* @param data
* @return
*/
public static <E> ResultEntity<E> successWithData(E data) {
return new ResultEntity<>(SUCCESS, NO_MESSAGE, data);
}
/**
* 操作失败，返回错误消息
* @param message
* @return
*/
public static <E> ResultEntity<E> failed(String message) {
return new ResultEntity<>(FAILED, message, null);
}
private String result;
private String message;
private T data;
public ResultEntity() {
}
public ResultEntity(String result, String message, T data) {
super();
this.result = result;
this.message = message;
this.data = data;
}
@Override
public String toString() {
return "ResultEntity ";
}
public String getResult() {
return result;
}
public void setResult(String result) {
this.result = result;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public T getData() {
return data;
}
public void setData(T data) {
this.data = data;
}
}
8.1.4 handler 方法
// @HystrixCommand注解指定当前方法出问题时调用的备份方法（使用fallbackMethod属性指定）
@HystrixCommand(fallbackMethod = "getEmpWithCircuitBreakerBackup")
@RequestMapping("/provider/get/emp/with/circuit/breaker")
public ResultEntity<Employee> getEmpWithCircuitBreaker(@RequestParam("signal") String signal) throws InterruptedException {
if("quick-bang".equals(signal)) {
throw new RuntimeException();
}
if("slow-bang".equals(signal)) {
Thread.sleep(5000);
}
return ResultEntity.successWithData(new Employee(666, "empName666", 666.66));
}
public ResultEntity<Employee> getEmpWithCircuitBreakerBackup(@RequestParam("signal") String signal) {
String message = "方法执行出现问题，执行断路 signal="+signal;
return ResultEntity.failed(message);
}
测试效果：
正常访问：
异常访问：
学习了不错 学习了挺好 楼主几年工作经验啊？ atai 发表于 2022-2-17 21:06
楼主几年工作经验啊？
上班两年了，最近有空学习学习:lol:lol:lol
页:
[1]