5. 断路器hystrix dashboard turbine （2刷）

喜欢ヅ旅行 2022-09-07 14:50 35阅读 0赞

# hystrix使用 #

## feign中使用 hystrix ##

feign:
      hystrix:
        enabled: true #必须配置

@Component
    public class EurekaClientHystrix implements EurekaClientFeign{ 
    
    }

*  使用feign配置了，这些，即可进行回退
 *  Feign 的起步依赖中已经包含Hystrix依赖，所以只要在配置文件中开启Hystrix的功能就可以

## hystrix 的引用和配置 ##

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

@EnableFeignClients #同理开启了 feign也不用开 hystrix了，最好都开启吧
    
    @EnableHystrix #开始hystrix

## 1. hystrix的单独使用 ##

### 引用网飞公司的 ###

*  引用其他的， HystrixCommand注解找不到

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

*  主类 记得开启 hystrix

### 配置ribbon ###

@Configuration
    public class RibbonConfig { 
    
        @Bean
        @LoadBalanced
        RestTemplate restTemplate() { 
            return new RestTemplate();
        }
    }

### service 单独使用 + 回退方法 ###

@Service
    public class RibbonService { 
    
        @Autowired
        RestTemplate restTemplate;
    
        @HystrixCommand(fallbackMethod = "hiError")
        public String hi(String name) { 
            return restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class);
        }
    
        public String hiError (String name){ 
            return "Hi," + name + ", sorry, error!";
        }
    }

*  亲测，回退可行。

## 2. feign 的重试 与回退 ##

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

### feign主方法 ###

@FeignClient(value = "eureka-client",configuration = FeignConfig.class,fallback = HiHystrix.class)
    public interface EurekaClientFeign { 
    
        @GetMapping(value = "/hi")
        String sayHiFromClientEureka(@RequestParam(value = "name") String name);
    }

### 重试和回退配置 ###

@Component
    public class HiHystrix implements EurekaClientFeign { 
        @Override
        public String sayHiFromClientEureka(String name) { 
               return "hi,"+name+",sorry,error!";
        }
    }

@Configuration // 必须标明为配置类
    public class FeignConfig { 
    
        /** * 在该类中注入Retryer的Bean ，覆盖掉默认的Retryer的Bean，从而达到自定义配置的目的。 * 例如Feign 默认的配置在请求失败后， 重试次数为0 ，即不重试（ Retry er.NEVER_RETRY ）。 * 更改为 FeignClient请求失败后重试测试： 重试间隔为100毫秒，最大重试时间为1秒，重试次数5次。 * @return */
        @Bean
        public Retryer feignRetryer() { 
            return new Retryer.Default(100, SECONDS.toMillis(1), 5);
        }
    
    }

*  测试的结果为 重试2次

feign:
      hystrix:
        enabled: true
        
        
    @EnableFeignClients
    @EnableHystrix   #可以不开起

# Hystrix Dashboard 监控断路器 #

## 引用pom依赖 ##

<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>
    
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
    		</dependency>

## 开启 hystrix 和 dashboard ##

@EnableFeignClients
    @EnableHystrixDashboard
    @EnableHystrix

## 进行访问 ##

http://localhost:8765/hystrix.stream 这是stream 的访问地址，这种很傻，dashboard也 和 hystrix 写一起。

最好 dashboard是单独一个项目。填入怎样的 hystrix.stream 就怎样监控

http://localhost:8765/hystrix 这是Dashboard的地址

填入第一个stream 地址，delay延迟为2000，title为test

## 不清楚用处，大概是指出：hystrix.stream给 serveletRegistrationBean ##

*  http://localhost:9002/actuator/beans 配置了yaml后，可访问
 *  始终没搞明白

@Component
    public class HystrixStreamServlet { 
    
        @Bean
        public ServletRegistrationBean getServlet() { 
            HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
            ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
            registrationBean.setLoadOnStartup(1);
            registrationBean.addUrlMappings("/hystrix.stream");
            registrationBean.setName("HystrixMetricsStreamServlet");
            return registrationBean;
        }
    }

## feign中使用 dashboard ##

<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-openfeign</artifactId>
    		</dependency>
    
    //在引入 上面的3个依赖，feign中 自带的 hystrix不是起步依赖，所以要引用。

# turbine 聚合监控 #

## 引入pom ##

<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-turbine</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-actuator</artifactId>
    		</dependency>

## yaml 配置 ##

spring:
      application.name: service-turbine
    server:
      port: 8769
    
      # 1. cluster-name-expression指定集群名称，默认表达式appName；此时：turbine.app-config需要配置想要监控的应用名称
      # 2. 当cluster-name-expression: default时，turbine.aggregator.cluster-config可以不写，因为默认就是default
      # 3. 当cluster-name-expression: metadata['cluster']时，假设想要监控的应用配置了eureka.instance.metadata-map.cluster: ABC，则需要配置，同时turbine.aggregator.cluster-config: ABC
    turbine:
      combine-host-port: true
      app-config: eureka-ribbon-client,eureka-feign-client
      cluster-name-expression: new String("default")
      aggregator:
        cluster-config: default
      instanceUrlSuffix: /hystrix.stream # 这里必须设置，否则默认程序会读取/actuator/hystrix.stream
    
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/

## 开启 并测试 ##

@EnableTurbine
    @EnableHystrixDashboard

http://localhost:8765/hystrix 访问任意一个dashboard

http://localhost:8769/turbine.stream 访问turbine

在dashboard中填入 turbine.stream

访问：http://localhost:8764/hi 和 http://localhost:8765/hi 让流存在

即可看到 dashboard 聚合了多个数据