springcloud熔断器Hystrix的用法及说明
springcloud熔断器Hystrix使用
说起springcloud熔断让我想起了去年股市中的熔断,多次痛的领悟,随意实施的熔断对整个系统的影响是灾难性的,好了接下来我们还是说正事。
熔断器
雪崩效应
在微服务架构中通常会有多个服务层调用,基础服务的故障可能会导致级联故障,进而造成整个系统不可用的情况,这种现象被称为服务雪崩效应。服务雪崩效应是一种因“服务提供者”的不可用导致“服务消费者”的不可用,并将不可用逐渐放大的过程。
如果下图所示:A作为服务提供者,B为A的服务消费者,C和D是B的服务消费者。A不可用引起了B的不可用,并将不可用像滚雪球一样放大到C和D时,雪崩效应就形成了。

熔断器(CircuitBreaker)
熔断器的原理很简单,如同电力过载保护器。它可以实现快速失败,如果它在一段时间内侦测到许多类似的错误,会强迫其以后的多个调用快速失败,不再访问远程服务器,从而防止应用程序不断地尝试执行可能会失败的操作,使得应用程序继续执行而不用等待修正错误,或者浪费CPU时间去等到长时间的超时产生。熔断器也可以使应用程序能够诊断错误是否已经修正,如果已经修正,应用程序会再次尝试调用操作。
熔断器模式就像是那些容易导致错误的操作的一种代理。这种代理能够记录最近调用发生错误的次数,然后决定使用允许操作继续,或者立即返回错误。
熔断器开关相互转换的逻辑如下图:

熔断器就是保护服务高可用的最后一道防线。
Feign Hystrix
因为熔断只是作用在服务调用这一端,因此我们根据上一篇的示例代码只需要改动spring-cloud-consumer项目相关代码就可以。因为,Feign中已经依赖了Hystrix所以在maven配置上不用做任何改动。
第一种方法
1、配置文件
application.properties添加这一条:
feign.hystrix.enabled=true
2、创建回调类
@Component
public class GradeClientImpl implements GradeClient {
@Override
public List<Grade> findAll() {
//可以:
//打印日志
//使用消息队列发送消息
//发送短信
//测试用
List<Grade> list = new ArrayList<Grade>();
Grade grade = new Grade();
grade.setGradeId(404);
grade.setGradeName("进入了熔断器");
list.add(grade);
return list;
}
}
3、添加fallback属性
@FeignClient(name="eureka-grade",fallback = GradeClientImpl.class)
public interface GradeClient {
@GetMapping(value = "/grades")
List<Grade> findAll();
}
改动点就这点,很简单吧。
第二种方法
1、添加依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>
2、在启动类添加注解
@EnableHystrix
@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
@EnableHystrix
public class EurekaStudentApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaStudentApplication.class, args);
}
}
3、修改控制层代码
@RestController
public class StudentController {
@Autowired
private StudentService studentService;
@Autowired
private GradeClient gradeClient;
@GetMapping(value = "/grades")
//一旦出错则执行Grades方法
@HystrixCommand(fallbackMethod = "Grades")
public List<Grade> findAll1(){
return gradeClient.findAll();
}
//出错执行的方法
public List<Grade> Grades() {
//可以:
//打印日志
//使用消息队列发送消息
//发送短信
//测试
List<Grade> list = new ArrayList<>();
Grade grade = new Grade();
grade.setGradeId(0);
grade.setGradeName("出错了,执行了熔断器");
list.add(grade);
return list;
}
@GetMapping(value = "/students")
public List<Student> findAll(){
return studentService.findAll();
}
}
以上两种方法都是一样的 然后测试一下:
那我们就来测试一下看看效果吧。
依次启动eureka-server、eureka-client、eureka-student、eureka-grade四个项目


然后我们关闭 eureka-grade


总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
相关文章
如何在拦截器中获取url路径里面@PathVariable的参数值
这篇文章主要介绍了如何在拦截器中获取url路径里面@PathVariable的参数值,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教2021-08-08
SpringBoot3 + Sa-Token 双Token登录认证实战案例解析
本文详细介绍了如何在SpringBoot3项目中使用Sa-Token框架实现双Token登录认证,全面展示了双Token登录认证的实现过程,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧2026-02-02
95%的Java程序员人都用不好Synchronized详解
这篇文章主要为大家介绍了95%的Java程序员人都用不好Synchronized详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-03-03


最新评论