Hystrix Dashboard 可视化监控熔断数据

朱雀 2021-12-10 13:15 373阅读 0赞

## 一、背景 ##

Hystrix 在下游服务异常的时候熔断对下游服务的调用，在实际应用中，我们需要知道服务被熔断的实时情况， 有助于发现问题，决解问题。  
在本次demo搭建中， 会有服务提供方（waiter）、服务消费方（consumer） 、Hystrix Dashboard 监控服务 。环境完全搭建完成后， 我们可以通过Hystrix Dashboard 监控服务的web界面，获取到服务请求被熔断的情况。  
注意：在本示例中， 使用 consul 作为注册中心， 如果你的本地，没有运行consul 注册中心， 请参考：[https://jingyan.baidu.com/article/ca41422f732f961eaf99ed5f.html][https_jingyan.baidu.com_article_ca41422f732f961eaf99ed5f.html]

## 二、服务端 ##

**2.1 pom主要依赖**

<properties>
    		<java.version>1.8</java.version>
    		<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
    </properties>
    	
    <dependencyManagement>
    		<dependencies>
    			<dependency>
    				<groupId>org.springframework.cloud</groupId>
    				<artifactId>spring-cloud-dependencies</artifactId>
    				<version>${spring-cloud.version}</version>
    				<type>pom</type>
    				<scope>import</scope>
    			</dependency>
    		</dependencies>
    </dependencyManagement>
    
        	<dependency>
     			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</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-consul-discovery</artifactId>
    		</dependency>

**2.2 配置文件**

application.properties

#0表示服务器随机端口
    server.port=0
    #consul  地址
    spring.cloud.consul.host=localhost
    #consul  端口
    spring.cloud.consul.port=8500
    spring.cloud.consul.discovery.prefer-ip-address=true

bootstrap.properties

#服务名称
    spring.application.name=waiter-service

**2.3 代码配置**

@PostMapping("/successKey")
        @ResponseBody
        public  String  getSuccessKey(){
            return  "hello wrold!  you have Key !";
        }
    
        @PostMapping("/pay")
        @ResponseBody
        public  String  pay(){
            return  "OK！ you pay  success ！";
        }

## 三、消费方 ##

**3.1 pom主要依赖**

<properties>
    		<java.version>1.8</java.version>
    		<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
    </properties>
    	
    <dependencyManagement>
    		<dependencies>
    			<dependency>
    				<groupId>org.springframework.cloud</groupId>
    				<artifactId>spring-cloud-dependencies</artifactId>
    				<version>${spring-cloud.version}</version>
    				<type>pom</type>
    				<scope>import</scope>
    			</dependency>
    		</dependencies>
    </dependencyManagement>
    
        	<dependency>
     			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</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-consul-discovery</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    		</dependency>

**3.2 配置文件**

application.properties

#表示服务器端口
    server.port=8090
    #consul  地址
    spring.cloud.consul.host=localhost
    #consul  端口
    spring.cloud.consul.port=8500
    spring.cloud.consul.discovery.prefer-ip-address=true
    #暴露所有接口
    management.endpoint.health.show-details=always
    feign.client.config.default.connect-timeout=500
    feign.client.config.default.read-timeout=500
    #启用hystrix熔断功能
    feign.hystrix.enabled=true

bootstrap.properties

#服务名称
    spring.application.name=customer-service

**3.3 代码配置**  
1）启动类上注释@EnableCircuitBreaker 表示启动断路器

@SpringBootApplication
    @Slf4j
    @EnableDiscoveryClient
    @EnableFeignClients
    @EnableCircuitBreaker
    public class CustomerServiceApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(CustomerServiceApplication.class, args);
    	}
    
    	@Bean
    	public CloseableHttpClient httpClient() {
    		return HttpClients.custom()
    				.setConnectionTimeToLive(30, TimeUnit.SECONDS)
    				.evictIdleConnections(30, TimeUnit.SECONDS)
    				.setMaxConnTotal(200)
    				.setMaxConnPerRoute(20)
    				.disableAutomaticRetries()
    				.setKeepAliveStrategy(new CustomConnectionKeepAliveStrategy())
    				.build();
    	}
    }

2）CircuitBreakerService 用于演示基于接口类的fallback

@FeignClient(name = "waiter-service", contextId = "circuitBreaker",
            qualifier = "circuitBreakerService",fallback = FallbackCircuitBreakerService.class)
    // 如果用了Fallback，不要在接口上加@RequestMapping，path可以用在这里
    public interface CircuitBreakerService {
        @PostMapping("/waiter/successKey")
        String  getSuccessKey();
    
    }

3） CircuitBreakerService 接口异常时候，fallback类FallbackCircuitBreakerService

@Component
    public class FallbackCircuitBreakerService implements  CircuitBreakerService{
        @Override
        public String  getSuccessKey(){
            return  "Fall BackMock Return";
        }
    
    }

4）PayService 用于演示基于方法的fallback

@FeignClient(name = "waiter-service", contextId = "pay")
    // 如果用了Fallback，不要在接口上加@RequestMapping，path可以用在这里
    public interface PayService {
        @PostMapping("/waiter/pay")
        String  pay();
    }

5）CustomerController http 入口

@RestController
    @RequestMapping("/customer")
    @Slf4j
    public class CustomerController {
          @Autowired
        private CircuitBreakerService circuitBreakerService ;
        @Autowired
        private PayService  payService;
    
        @PostMapping("/pay" )
        //关联fallback方法
        @HystrixCommand(fallbackMethod = "methodFall")
        public Object pay(){
            return payService.pay();
        }
    
        @GetMapping("/key")
        public Object getKey(){
            return circuitBreakerService.getSuccessKey();
        }
    
        /**
         * 用于方法fallback
         * @return
         */
        public Object methodFall(){
            return "waiter barker method fallback";
        }
    }

## 四、Hystrix Dashboard 监控服务 ##

**4.1 pom主要依赖**

<properties>
    		<java.version>1.8</java.version>
    		<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
    	</properties>
    	
      <dependencyManagement>
    		<dependencies>
    			<dependency>
    				<groupId>org.springframework.cloud</groupId>
    				<artifactId>spring-cloud-dependencies</artifactId>
    				<version>${spring-cloud.version}</version>
    				<type>pom</type>
    				<scope>import</scope>
    			</dependency>
    		</dependencies>
    	</dependencyManagement>
    	
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    	</dependencies>

**4.2 配置文件**  
application.properties

#服务端口，因为需要对外访问，所以需要固定端口
    server.port=9090

**4.3 代码**  
@EnableHystrixDashboard 表示启用 Hystrix Dashboard  
启动类：

@SpringBootApplication
    @EnableHystrixDashboard
    public class HystrixDashboardDemoApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(HystrixDashboardDemoApplication.class, args);
    	}
    
    }

**4.4 访问方式**

http://localhost:9090/hystrix

## 五、验证结果 ##

**5.1 在消费者端（consumer）找到 hystrix 数据流接口**  
找出所有endpoint：[http://localhost:8090/actuator][http_localhost_8090_actuator]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70]  
在endpoint 找到hystrix 数据接口  
[http://localhost:8090/actuator/hystrix.stream][http_localhost_8090_actuator_hystrix.stream]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 1]  
**5.2 在Hystrix Dashboard 输入需要监控的hystrix 数据接口url**  
[http://localhost:8090/actuator/hystrix.stream][http_localhost_8090_actuator_hystrix.stream]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 2]  
**5.3 在页面查看接口熔断状态**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 3]  
**注意：如果消费者服务，没有对应的情况， 这个展示数据有可能为空或不显示**

[https_jingyan.baidu.com_article_ca41422f732f961eaf99ed5f.html]: https://jingyan.baidu.com/article/ca41422f732f961eaf99ed5f.html
[http_localhost_8090_actuator]: http://localhost:8090/actuator
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70]: /images/20211210/0bcfecfe27184d13bcc952ff1d780768.png
[http_localhost_8090_actuator_hystrix.stream]: http://localhost:8090/actuator/hystrix.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 1]: /images/20211210/f6e33c0c031b45deb63b74ed672efe21.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 2]: /images/20211210/88efd37aac014cba9f16e0caaf89633c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 3]: /images/20211210/c8b90101697c469dad69a0c47af30e69.png