### 一.为什么需要熔断器 >我们知道我们的项目会被分成很多的服务,而每个服务是独立运行的,服务和服务之间通过REST API 实现远程相互调用,既然是远程调用就有可能会因为网络故障,或被调用的服务本身出现问题而造成服务调用延迟，调用失败等问题,而这些问题可能造成调用方对外部服务也调用失败，从而造成一些列连锁反应，甚至造成整个应用瘫痪。 例如：服务A调用服务B，而服务B调用服务C，如果服务B调用服务C出现故障，那么服务A调用服务B可能也会出现连锁反应,那么整个应用可能都会出现问题。而这种效果也被叫做雪崩效应。 ### 二.什么是熔断器Hystrix >熔断器就好比家里电路装置的“保险”,当电路断路,那么“保险”装置的“保险丝”就会被熔断,从而达到断开电路的效果,以防止不良后果。而Spring Cloud Hystrix 实现了熔断器,线程隔离等一些列的服务保护功能,当Hystrix判定请求出现故障,会立马对请求做出响应动作,不会继续执行正常请求逻辑,请求线程也不会处于阻塞状态,从而有效防止雪崩效应。 ### 三.实现基于Ribbon使用熔断器 >1.改造项目Consumer，引入 hystrix 的依赖包 ``` org.springframework.cloud spring-cloud-starter-netflix-hystrix ``` >2.主程序打上@EnableHystrix标签，开启熔断器功能 ``` /** * @EnableHystrix： 开启 hystrix ，开启熔断器功能 */ @EnableHystrix @SpringBootApplication @EnableEurekaClient @EnableFeignClients public class ConsumerApplication { public static void main(String[] args) { SpringApplication.run(ConsumerApplication.class, args); } //通过@LoadBalanced注解表明这个restRemplate开启负载均衡的功能。 //RestTemplate是spring内置的http请求封装 @Bean @LoadBalanced RestTemplate restTemplate() { return new RestTemplate(); } } ``` 3.在ConsumerController中的方法上打上注解 @HystrixCommand注解,开启熔断器功能 ``` //HystrixCommand:给方法启用熔断器功能,当出现访问故障，自动调用 fallbackMethod 指向的方法 @RequestMapping("/consumer") @HystrixCommand(fallbackMethod = "errorMethod") public String consumer(@RequestParam("name") String name){ String result = restTemplate.getForObject("http://PRODUCER/provide?name="+name,String.class); return result; } public String errorMethod(String name){ return "你好，"+name+"，访问错误"; } ``` >4.测试：一次启动 EurekaServer，Producer,Consumer服务,访问地址http://localhost:3333/consumer?name=zs ，你将会看到“zs:你好呀这里是Producer服务”， 当关掉 Producer服务，再访问会出现： "你好，zs，访问错误"; 当Producer服务关掉，那么Consumer服务不能调用Producer服务的接口,那么马上回执行errorMethod方法进行故障处理。 ### 四.实现基于feign的熔断器 feign默认实现了熔断器功能，不需要引入额外的包 >1.基于Consumer项目，配置文件开启熔断器功能 ``` eureka: client: serviceUrl: defaultZone: http://localhost:1111/eureka/ #服务地址 server: port: 3333 spring: application: name: consumer1 #开启熔断器 feign: hystrix: enabled: true ``` >2.MyFeignClient接口开启熔断器功能，给@FeignClient标签添加fallback属性指定熔断器逻辑处理类 ``` //PRODUCER:指向要访问的服务 //configuration = FooConfiguration.class Feign Client配置类，指定负载均衡策略 //fallback = MyFeignClientImpl.class: MyFeignClient接口的实现类，需要复写 provide方法，并实现错误处理逻辑 //当访问出现故障，程序会自动调用实现类的 provide方法的错误处理逻辑。 @FeignClient(value = "PRODUCER",configuration = FooConfiguration.class,fallback = MyFeignClientImpl.class) public interface MyFeignClient { //当此方法别调用会自动请求到 PRODUCER服务的 /provide 资源 @RequestMapping(value = "/provide") public String provide(@RequestParam("name") String name); } ``` >3.定义类 MyFeignClientImpl ``` @Component public class MyFeignClientImpl implements MyFeignClient { @Override public String provide(String name) { return "你好,"+name+"，访问出现错误"; } } ``` >4.测试：一次启动EurekaServer，Producer，Consumer，访问地址：http://localhost:3333/feign?name=zs ，你将会看到 “zs:你好呀这里是Producer服务”， 然后关闭Producer服务，再访问将会看到 “你好,zs，访问出现错误”,当Consomer服务找不到Producer服务接口时就自动调用了MyFeignClientImpl实现类的熔断器逻辑处理方法。