Spring Cloud基础教程（五）：Ribbon熔断器使用（Hystrix）

客官°小女子只卖身不卖艺 2022-05-24 04:39 90阅读 0赞

在微服务的架构中，服务之间的相互调用，有可能因为网络原因或是依赖服务自身问题出现调用故障或延迟，而这些问题会直接导致调用方的对外服务也出现延迟，若此时调用方的请求不断增加，最后就会出现因等待出现故障的依赖方响应而形成任务积压，线程资源无法释放，最终导致自身服务的瘫痪，进一步甚至出现故障的蔓延最终导致整个系统的瘫痪。如果这样的架构存在如此严重的隐患，那么相较传统架构就更加的不稳定。为了解决这样的问题，因此产生了断路器等一系列的服务保护机制。

# 一、准备 #

将[服务消费者（Ribbon）][Ribbon]这篇博客Consumer-Ribbon工程复制，名字命令为Consumer-Ribbon-Hystrix。

# 二、工程修改 #

工程gradle依赖修改为

dependencies {
    	compile('org.springframework.boot:spring-boot-starter-web')
    	compile('org.springframework.cloud:spring-cloud-starter-eureka:1.4.4.RELEASE')
    	compile('org.springframework.cloud:spring-cloud-starter-hystrix:1.4.4.RELEASE')
    	compile('org.springframework.cloud:spring-cloud-starter-ribbon:1.4.4.RELEASE')
    	testCompile('org.springframework.boot:spring-boot-starter-test')
    }

启动类添加@EnableHystrix注解

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.cloud.netflix.hystrix.EnableHystrix;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @EnableDiscoveryClient
    @SpringBootApplication
    @EnableHystrix
    public class ConsumerRibbonApplication
    {
    
    	public static void main(String[] args) {
    		SpringApplication.run(ConsumerRibbonApplication.class, args);
    	}
    
        @Bean
        @LoadBalanced
        RestTemplate restTemplate() {
            return new RestTemplate();
        }
    }

添加RibbonConsumerService接口

public interface RibbonConsumerService
    {
        String client();
    }

添加Service的实现类，在client方法上增加@HystrixCommand注解，当服务出现异常的时候，自动调用fallback类，使用熔断器的功能，保证服务可以正常的执行。

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.web.client.RestTemplate;
    
    /**
     * Created by wzj on 2018/5/20.
     */
    @Service
    public class RibbonConsumerServiceImpl implements RibbonConsumerService
    {
        /**
         * 注入
         */
        @Autowired
        private RestTemplate restTemplate;
    
        @HystrixCommand(fallbackMethod = "fallback")
        @Override
        public String client()
        {
            return restTemplate.getForObject("http://service-producer/client", String.class);
        }
    
        public String fallback()
        {
            return "fallback";
        }
    }

修改ConsumerController类

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    /**
     * Created by wzj on 2018/5/19.
     */
    @RestController
    public class ConsumerController
    {
        /**
         * 注入
         */
        @Autowired
        private RibbonConsumerService ribbonConsumerService;
    
    
        @RequestMapping("/consumer")
        public String client()
        {
            return ribbonConsumerService.client();
        }
    }

修改application.properties配置文件

spring.application.name=consumer-ribbon-hystrix
    server.port=10008
    eureka.client.serviceUrl.defaultZone=http://localhost:10001/eureka/

# 三、测试 #

启动Eureka-Server、Service-Producer-A和该工程，浏览器访问[http://127.0.0.1:10008/consumer][http_127.0.0.1_10008_consumer],服务可以正常调用。

![20180520224925350][]

关闭Service-Producer-A服务，再次访问，服务调用出现问题，自动访问fallback函数。

![20180520225029561][]

源码Github地址：[https://github.com/HelloKittyNII/SpringCloud/tree/master/SpringCloudFramework][https_github.com_HelloKittyNII_SpringCloud_tree_master_SpringCloudFramework]

[Ribbon]: https://blog.csdn.net/u010889616/article/details/80373613
[http_127.0.0.1_10008_consumer]: http://127.0.0.1:10008/consumer
[20180520224925350]: /images/20220524/1c3ec09cac904f9093d7fe1d7ec3a2f9.png
[20180520225029561]: /images/20220524/f23887c36f7c48749ce870d8c333fb91.png
[https_github.com_HelloKittyNII_SpringCloud_tree_master_SpringCloudFramework]: https://github.com/HelloKittyNII/SpringCloud/tree/master/SpringCloudFramework