Hytrix：服务熔断

小半 • 2022年5月12日下午6:05 • 后端开发 • 阅读 196

熔断机制是赌赢雪崩效应的一种微服务链路保护机制。
为了避免因某个微服务后台出现异常或错误而导致整个应用或网页报错

演示在已有的服务提供者上做修改加入Hytrix服务熔断

引入Hystrix依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
    <version>1.4.6.RELEASE</version>
</dependency>

修改controller

编写熔断后跳转的方法，在需要熔断的接口上添加注解 **@HystrixCommand(fallbackMethod = “hystrixQuery”)**指向跳转的方法

@RestController
public class DeptController {
    @Autowired
    private DeptService deptService;

    @HystrixCommand(fallbackMethod = "hystrixQuery")
    @GetMapping("/dept/{id}")
    public Dept queryById(@PathVariable("id") Long id){
        Dept dept = deptService.queryById(id);
        if (dept==null){
            throw new RuntimeException("id=>"+id+"不存在该用户");
        }
        return dept;
    }

    /**
     * 产生熔断后
     * @param id
     * @return
     */
    public Dept hystrixQuery(@PathVariable("id") Long id){
        return new Dept()
                .setDeptno(id)
                .setDname("id=>"+id+"没有对应的信息---@Hystrix")
                .setDbSource("no database");
    }
}

启动类添加注解@EnableCircuitBreaker 开启对熔断的支持

@SpringBootApplication
@EnableEurekaClient //在服务启动后自动注册到eureka中
@EnableDiscoveryClient // 服务发现~
@EnableCircuitBreaker //添加对熔断的支持
public class DeptProviderHystrix_8001 {
    public static void main(String[] args) {
        SpringApplication.run(DeptProviderHystrix_8001.class,args);
    }
}