ribbon使用断路器 Hystrix

太过爱你忘了你带给我的痛 2023-02-25 14:24 33阅读 0赞

## SpringCloud视频教程： ##

[https://ke.qq.com/course/2805647?tuin=a3e3fb1&from\_uin=171851697&from=1000201007][https_ke.qq.com_course_2805647_tuin_a3e3fb1_from_uin_171851697_from_1000201007]

## **个人博客纯净版** ##

[http://www.51ufo.cn/%E5%BE%AE%E6%9C%8D%E5%8A%A1/%E5%88%86%E5%B8%83%E5%BC%8F/2020/07/10/SpringCloud%E5%85%A5%E9%97%A88-ribbon%E4%BD%BF%E7%94%A8%E6%96%AD%E8%B7%AF%E5%99%A8-Hystrix.html][http_www.51ufo.cn_E5_BE_AE_E6_9C_8D_E5_8A_A1_E5_88_86_E5_B8_83_E5_BC_8F_2020_07_10_SpringCloud_E5_85_A5_E9_97_A88-ribbon_E4_BD_BF_E7_94_A8_E6_96_AD_E8_B7_AF_E5_99_A8-Hystrix.html]

本文代码git地址 [https://gitee.com/xmingtx/springcloud-lesson.git][https_gitee.com_xmingtx_springcloud-lesson.git]

在微服务架构中，根据业务来拆分成一个个的服务，服务与服务之间可以相互调用（RPC），在Spring Cloud可以用RestTemplate+Ribbon和Feign来调用。为了保证其高可用，单个服务通常会集群部署。由于网络原因或者自身的原因，服务并不能保证100%可用，如果单个服务出现问题，调用这个服务就会出现线程阻塞，此时若有大量的请求涌入，Servlet容器的线程资源会被消耗完毕，导致服务瘫痪。服务与服务之间的依赖性，故障会传播，会对整个微服务系统造成灾难性的严重后果，这就是服务故障的“雪崩”效应。

为了解决这个问题，业界提出了断路器模型。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoYW9qdW5tYQ_size_16_color_FFFFFF_t_70][]

**在ribbon使用断路器**

在前面我们创建了一个consumer-ribbon服务，我们来改造一下，首先需要在pox.xml文件中加入hystrix的依赖：

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    </dependency>

在程序的启动类ConsumerApplication加`@EnableHystrix`注解开启Hystrix，如下：

@EnableHystrix
    @EnableEurekaClient
    @SpringBootApplication
    public class ConsumerApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(ConsumerApplication.class);
        }
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    }

创建HelloService类，代码如下：

@Service
    public class HelloService {
    
        @Autowired
        private RestTemplate restTemplate;
    
        @HystrixCommand(fallbackMethod = "helloFallback")
        public String callHello(String name) {
            return restTemplate.getForObject("http://eureka-client-provider/hello?name="+name,String.class);
        }
    
        public String helloFallback(String name) {
            return "hello," + name + ",sorry,error!";
        }
    }

改造一下HelloController，代码如下：

@RestController
    public class HelloController {
    
        @Autowired
        private HelloService helloService;
    
        @GetMapping(value = "/hello")
        public String hello(@RequestParam String name) {
            return helloService.callHello(name);
        }
    }

启动所有服务，我们在浏览器访问[http://localhost:8090/hello?name=xiaoming][http_localhost_8090_hello_name_xiaoming],返回以下结果:

hello, xiaoming, 我是服务提供者:端口为：8080

停止eureka-client-provider服务，再次访问，返回结果如下：

hello,xiaoming,sorry,error!

这证明断路器起到作用了。

[https_ke.qq.com_course_2805647_tuin_a3e3fb1_from_uin_171851697_from_1000201007]: https://ke.qq.com/course/2805647?tuin=a3e3fb1&from_uin=171851697&from=1000201007
[http_www.51ufo.cn_E5_BE_AE_E6_9C_8D_E5_8A_A1_E5_88_86_E5_B8_83_E5_BC_8F_2020_07_10_SpringCloud_E5_85_A5_E9_97_A88-ribbon_E4_BD_BF_E7_94_A8_E6_96_AD_E8_B7_AF_E5_99_A8-Hystrix.html]: http://www.51ufo.cn/%E5%BE%AE%E6%9C%8D%E5%8A%A1/%E5%88%86%E5%B8%83%E5%BC%8F/2020/07/10/SpringCloud%E5%85%A5%E9%97%A88-ribbon%E4%BD%BF%E7%94%A8%E6%96%AD%E8%B7%AF%E5%99%A8-Hystrix.html
[https_gitee.com_xmingtx_springcloud-lesson.git]: https://gitee.com/xmingtx/springcloud-lesson.git
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoYW9qdW5tYQ_size_16_color_FFFFFF_t_70]: /images/20230209/231518f651864d218d8f92e47724cbe0.png
[http_localhost_8090_hello_name_xiaoming]: http://localhost:8090/hello?name=xiaoming