服务熔断机制
熔断机制是应对雪崩效应的一种微服务链路保护机制。
当扇出链路的某个微服务不可用或者响应时间太长时，会进行服务的降级，进而熔断该节点微服务的调用，快速响应错误信息。当检测到该节点微服务调用响应正常后恢复调用链路。在 SpringCloud 框架里熔断机制通过 Hystrix 实现。Hystrix 会监控微服务间调用的状况，当失败的调用到一定阈值，缺省是 5 秒内 20 次调用失败就会启动熔断机制。熔断机制的注解是@HystrixCommand
依赖信息
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>主启动类注解
// 使用@EnableCircuitBreaker注解开启断路器功能
@EnableCircuitBreaker
@SpringBootApplication
public class AtzytMainType {
public static void main(String[] args) {
SpringApplication.run(AtzytMainType.class, args);
}
}ResultEntity(统一使用这个类型作为 Ajax 请求或远程方法调用返回响应的数据格式)
package com.study.spring.cloud.util;
/**
* 整个项目统一使用这个类型作为Ajax请求或远程方法调用返回响应的数据格式
* [url=home.php?mod=space&uid=686208]@AuThor[/url] Lenovo
*
* [url=home.php?mod=space&uid=952169]@Param[/url] <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 [result=" + result + ", message=" + message + ", data=" + data + "]";
}
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;
}
}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); }
正常访问：
异常访问：
