SpringCloud2.x搭建完整Demo(四) -集成Hystrix熔断机制

￡神魔★判官ぃ 2023-02-21 12:55 12阅读 0赞

**SpringCloud2.x搭建完整Demo(四) -集成Hystrix熔断机制**

**1.服务提供方业务方法调用失败（熔断）**

**2.服务提供方服务调用不通（降级）**

**3.集成HystrixDashboard仪表盘**

**4.集成Turbine服务监控**

**---------------------------------------------------------------------------------------------------------------------------**

### 1.**服务提供方业务方法报错** ###

1.1 【myspringcloud-provider-product】模块复制一份【myspringcloud-provider-product-hystrix】模块

1.2 【myspringcloud-provider-product-hystrix】模块添加POM依赖

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

1.3 【myspringcloud-provider-product-hystrix】模块ProductController修改

@RequestMapping(value="/getInfoById/{id}")
        @HystrixCommand(fallbackMethod = "getFallback")
        public Object get(@PathVariable("id") long id) {
           ProductPo product = iProductService.getInfoById(id);
            if(product == null) {
                throw new RuntimeException("该产品已下架！") ;
            }
            return product;
    }
    
    public Object getFallback(@PathVariable("id") long id){
            ProductPo product = new ProductPo();
            product.setProductName("HystrixName");
            product.setProductDesc("HystrixDesc");
            product.setProductId(0L);
            return product;
    }

1.4 【myspringcloud-provider-product-hystrix】模块修改启动类，增加熔断支持

@EnableCircuitBreaker

1.5 启动【myspringcloud-provider-product-hystrix】服务，查询一个数据库中不存在的ID，可以看到触发熔断

![20200630225340577.png][]

### **2.服务提供方服务器调用不通** ###

2.1 【myspringcloud-service】模块新增一个fallback目录，新增一个IProductClientServiceFallbackFactory工厂类，用于失败调用（消费方降级处理)

package com.en.service.fallback;
    
    import com.en.po.ProductPo;
    import com.en.service.IProductClientService;
    import feign.hystrix.FallbackFactory;
    import org.springframework.stereotype.Component;
    import java.util.List;
    
    @Component
    public class IProductClientServiceFallbackFactory implements FallbackFactory<IProductClientService> {
        @Override
        public IProductClientService create(Throwable throwable) {
            return  new IProductClientService() {
                @Override
                public ProductPo getProduct(long id) {
                    ProductPo product = new ProductPo();
                    product.setProductId(999999L);
                    product.setProductName("feign-hystrixName");
                    product.setProductDesc("feign-hystrixDesc");
                    return  product;
                }
    
                @Override
                public List<ProductPo> listProduct() {
                    return null;
                }
    
                @Override
                public boolean addPorduct(ProductPo product) {
                    return false;
                }
            };
        }
    }

2.2 【myspringcloud-service】模块修改IProductClientService，增加fallback配置

@FeignClient(name = "MYSPRINGCLOUD-PROVIDER-PRODUCT",configuration = FeignClientConfig.class,fallbackFactory = IProductClientServiceFallbackFactory.class)

2.3 【myspringcloud-consumer-feign】 修改application.yml配置文件，启用hystrix配置

feign:
     hystrix:
        enabled: true

2.4 启动注册中心、服务生产者、服务消费者

用消费者测试生产者服务：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy_size_16_color_FFFFFF_t_70][]

关闭生产者服务，再次调用，前端也可正常访问

![20200630234017696.png][]

### **3.集成HystrixDashboard仪表盘** ###

3.1 新建【microcloud-consumer-hystrix-dashboard】模块，并配置POM依赖

3.2 确保【microcloud-provider-product-hystrix】pom文件里有健康检查模块

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

3.3 【microcloud-consumer-hystrix-dashboard】修改application.yml配置文件

server:
     port: 9001

3.4 【microcloud-consumer-hystrix-dashboard】模块创建启动类

package com.en.config;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
    
    /**
     * @ClassName HystrixDashboardApp
     * @Description TODO
     * @Author liuxiaobai
     * @Date 2020/7/1 21:11
     * @Version 1.0
     **/
    @SpringBootApplication
    @EnableHystrixDashboard
    public class HystrixDashboardApp {
        public static void main(String[] args) {
            SpringApplication.run(HystrixDashboardApp.class,args);
        }
    }

3.5 【microcloud-provider-product-hystrix】模块修改applcation.yml文件

management:
      endpoints:
        web:
          exposure:
            include: '*'

3.6 启动【microcloud-provider-product-hystrix】模块，访问[http://localhost:9001/hystrix][http_localhost_9001_hystrix]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy_size_16_color_FFFFFF_t_70 1][]

3.7 仪表盘模块页面填入连接：[http://admin:root@localhost:8084/actuator/hystrix.stream][http_admin_root_localhost_8084_actuator_hystrix.stream]，即可实现对8084服务的监控

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy_size_16_color_FFFFFF_t_70 2][]

### **4.集成Turbine服务监控** ###

4.1  新建【myspringcloud-provider-user-hystrix】模块，用于仪表盘同时提供服务检测，POM如下

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>myspringcloud</artifactId>
            <groupId>com.en</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>myspringcloud-provider-user-hystrix</artifactId>
        <dependencies>
            <dependency>
                <groupId>com.en</groupId>
                <artifactId>myspringcloud-api</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>
        </dependencies>
    </project>

4.2  【myspringcloud-api】模块新建VO、【myspringcloud-provider-user-hystrix】模块 Controller和启动类

package com.en.po;
    import java.io.Serializable;
    
    public class Users implements Serializable {
        private String name;
        private int age;
        private String sex;
        public String getName() {
            return name;
        }
        public void setName(String name) {
            this.name = name;
        }
        public int getAge() {
            return age;
        }
        public void setAge(int age) {
            this.age = age;
        }
        public String getSex() {
            return sex;
        }
        public void setSex(String sex) {
            this.sex = sex;
        }
    }

package com.en.controller;
    
    import com.en.po.Users;
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RequestMapping("/users")
    public class UserController {
        @RequestMapping("/get/{name}")
        @HystrixCommand
        public  Object get(@PathVariable("name")String name) {
            Users users = new Users();
            users.setName(name);
            users.setAge(18);
            users.setSex("F");
            return users;
        }
    }

package com.en;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableCircuitBreaker
    @EnableEurekaClient
    public class UsersApp {
        public static void main(String[] args) {
            SpringApplication.run(UsersApp.class,args);
        }
    }

4.3   修改【myspringcloud-provider-user-hystrix】模块配置文件

server:
     port: 8090
    
    spring:
     application:
       name: myspringcloud-provider-users-hystrix
    
    logging:
      level:
        com.en.mapper: debug
    
    eureka:
      client: # 客户端进行Eureka注册的配置
        service-url:
          defaultZone: http://admin:root@eureka:7001/eureka,http://admin:root@eureka2:7002/eureka,http://admin:root@eureka3:7003/eureka
      instance:
        instance-id: myspringcloud-provider-users-hystrix
        prefer-ip-address: true
        lease-renewal-interval-in-seconds: 2 # 设置心跳的时间间隔（默认是30秒）
        lease-expiration-duration-in-seconds: 5  # 如果现在超过了5秒的间隔（默认是90秒）
    
    info:
      app.name: myspringcloud-provider-users-hystrix
      company.name: en
      build.artifactId: $project.artifactId$
      build.modelVersion: $project.modelVersion$
    
    management:
      endpoints:
        web:
          exposure:
            include: '*'

4.4 新增【microcloud-consumer-turbine】模块，pom文件如下

4.5 【microcloud-consumer-turbine】模块配置文件

server:
     port: 9101
    eureka:
      client:
        register-with-eureka: false
        service-url:
            defaultZone: http://admin:root@eureka:7001/eureka,http://admin:root@eureka2:7002/eureka,http://admin:root@eureka3:7003/eureka
    
    turbine:
      app-config: MYSPRINGCLOUD-PROVIDER-PRODUCT-HYSTRIX,MYSPRINGCLOUD-PROVIDER-USERS-HYSTRIX
      cluster-name-expression: new String("default")

4.6  新建【microcloud-consumer-turbine】模块启动类

package com.en;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.turbine.EnableTurbine;
    
    @SpringBootApplication
    @EnableTurbine
    public class TurbineApp {
        public static void main(String[] args) {
            SpringApplication.run(TurbineApp.class,args);
        }
    }

4.7 因为之前对【microcloud-provider-product-hystrix】模块进行了访问加密，所以需要设置放行方法，【mysrpingcloud-security】 修改WebSecurityConfiguration文件

package com.en.config;
    
    import org.springframework.context.annotation.Configuration;
    import org.springframework.security.config.annotation.authentication.builders.AuthenticationManagerBuilder;
    import org.springframework.security.config.annotation.web.builders.HttpSecurity;
    import org.springframework.security.config.annotation.web.builders.WebSecurity;
    import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
    import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
    import org.springframework.security.config.http.SessionCreationPolicy;
    import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
    
    @Configuration
    @EnableWebSecurity
    public class WebSecurityConfiguration extends WebSecurityConfigurerAdapter {
    
        @Override
        public void configure(AuthenticationManagerBuilder auth)
                throws Exception {
            auth.inMemoryAuthentication().passwordEncoder(new BCryptPasswordEncoder()).withUser("root").password(new BCryptPasswordEncoder().encode("root")).roles("USER").
                    and().withUser("admin").password(new BCryptPasswordEncoder().encode("root")).roles("USER", "ADMIN");
        }
    
        @Override
        protected void configure(HttpSecurity http) throws Exception {
    
    
            http.httpBasic().and().authorizeRequests().anyRequest()
                    .fullyAuthenticated();
            http.sessionManagement()
                    .sessionCreationPolicy(SessionCreationPolicy.STATELESS);
        }
    
        @Override
        public void configure(WebSecurity web) throws Exception {
            web.ignoring().antMatchers("/actuator/hystrix.stream","/turbine.stream") ;
        }
    
    }

4.8 启动注册中心、仪表盘、两个服务提供方、还有刚写的turbine模块。浏览器访问：[http://localhost:9001/hystrix][http_localhost_9001_hystrix]，输入监控地址[http://localhost:9101/turbine.stream][http_localhost_9101_turbine.stream]，分别多次调用服务提供方带有@HystrixCommand注解的方法：

[http://localhost:8084/product/getInfoById/1][http_localhost_8084_product_getInfoById_1]

[http://localhost:8090/users/get/enjoy][http_localhost_8090_users_get_enjoy]

可以看到现在仪表盘可以对多个服务提供方进行监控

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy_size_16_color_FFFFFF_t_70 3][]

源码自取：

[https://github.com/L1021204735/myspringcloud4][https_github.com_L1021204735_myspringcloud4]

[20200630225340577.png]: https://img-blog.csdnimg.cn/20200630225340577.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200630233945792.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy,size_16,color_FFFFFF,t_70
[20200630234017696.png]: https://img-blog.csdnimg.cn/20200630234017696.png
[http_localhost_9001_hystrix]: http://localhost:9001/hystrix
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200701212334574.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy,size_16,color_FFFFFF,t_70
[http_admin_root_localhost_8084_actuator_hystrix.stream]: http://localhost:8084/actuator/hystrix.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200701212555376.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy,size_16,color_FFFFFF,t_70
[http_localhost_9101_turbine.stream]: http://localhost:9101/turbine.stream
[http_localhost_8084_product_getInfoById_1]: http://localhost:8084/product/getInfoById/1
[http_localhost_8090_users_get_enjoy]: http://localhost:8090/users/get/enjoy
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20200705151619809.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzU2Njgy,size_16,color_FFFFFF,t_70
[https_github.com_L1021204735_myspringcloud4]: https://github.com/L1021204735/myspringcloud4