Spring Cloud项目之断路器集群监控Hystrix Dashboard

2022-09-30 07:40:38

微服务(Microservices Architecture)是一种架构风格，一个大型复杂软件应用由一个或多个微服务组成。系统中的各个微服务可被独立部署，各个微服务之间是松耦合的。每个微服务仅关注于完成一件任务并很好地完成该任务。在所有情况下，每个任务代表着一个小的业务能力。Spring Cloud是一个基于Spring Boot实现的云应用开发工具，它为基于JVM的云应用开发中涉及的配置管理、服务发现、断路器、智能路由、微代理、控制总线、全局锁、决策竞选、分布式会话和集群状态管理等操作提供了一种简单的开发方式。

这里我们将叙述Spring Cloud中的断路器监控Hystrix Dashboard，在此之前我们需要了解一下Spring Cloud的基本组件。详情可了解https://www.souyunku.com/categories/。

Hystrix Dashboard在微服务架构中为例保证程序的可用性，防止程序出错导致网络阻塞，出现了断路器模型。断路器的状况反应了一个程序的可用性和健壮性，它是一个重要指标。Hystrix Dashboard是作为断路器状态的一个组件，提供了数据监控和友好的图形化界面。

准备项目：

1. eureka-service：eureka注册中心，端口：8761，用于服务注册与发现；

2. eureka-provider_1：服务提供者1，端口：8071，用于提供服务；

3. eureka-provider_2：服务提供者2，端口：8072，用于提供服务；

4. ribbon-consumer-hystrix-dashboard：带有断路器、监控面板的消费者，端口：9000，用于消费服务、提供断路器和监控界面。

1-3个项目可参考https://www.souyunku.com/自行创建，或者从下文附件中下载。我们详细讲下ribbon-consumer-hystrix-dashboard项目的构建;

一、构建ribbon-consumer-hystrix-dashboard ：

1.添加pom依赖：

2.启动类：

 /*

  * 开启服务负载均衡

  *

  * @EnableDiscoveryClient向服务注册中心注册

  * 并且向程序的ioc注入一个bean: restTemplate

  * 并通过@LoadBalanced注解表明这个restRemplate开启负载均衡的功能。

  */

 //通过 @EnableHystrix 开启 Hystrix 断路器监控，这个是必须的，并且需要在程序中声明断路点@HystrixCommand

 //加上@EnableHystrixDashboard注解，开启HystrixDashboard

 @EnableHystrixDashboard

 @EnableHystrix

 @EnableDiscoveryClient

 @SpringBootApplication

 public class RibbonConsumerApplication_2 {

     @LoadBalanced

     @Bean

     RestTemplate restTemplate() {

         return new RestTemplate();

     }

     public static void main(String[] args) {

         SpringApplication.run(RibbonConsumerApplication_2.class, args);

         //将存放该项目注册信息的接口url写入本地文件

     }

 }

3. 控制层：

 /**

  * 消费提供者方法

  * 描述:调用提供者的 `home` 方法

  **/

 @RestController

 public class ConsumerController {

     @Autowired

     private RestTemplate restTemplate;

     //创建了熔断器的功能 ,并指定了defaultStores熔断方法

     //@HystrixCommand 声明短路点，表明该方法为hystrix包裹，

     //可以对依赖服务进行隔离、降级、快速失败、快速重试等等hystrix相关功能

     //fallbackMethod 降级方法

     //commandProperties 普通配置属性，可以配置HystrixCommand对应属性，例如采用线程池还是信号量隔离、熔断器熔断规则等等

     //ignoreExceptions 忽略的异常，默认HystrixBadRequestException不计入失败

     //groupKey() 组名称，默认使用类名称

     //commandKey 命令名称，默认使用方法名

     @HystrixCommand(fallbackMethod = "defaultStores")

     @GetMapping(value = "/hello")

     public String hello() {

         return restTemplate.getForEntity("http://eureka-provider/", String.class).getBody();

     }

     //熔断方法直接返回了一个字符串， "feign + hystrix ,提供者服务挂了"

     public String defaultStores() {

         return "Ribbon + hystrix ,提供者服务挂了";

     }

 }

4. 安全控制，访问/hystrix路径要进行登录认证（可以不设置）

 @Configuration

 //@EnableWebSecurity

 public class SecurityConfiguration extends WebSecurityConfigurerAdapter{

     @Override

     protected void configure(final HttpSecurity http) throws Exception {

         http.httpBasic()

             .and()

             .authorizeRequests()

             .antMatchers("/hystrix")

             .authenticated();

     }

     @Autowired

     public void configureGlobal(AuthenticationManagerBuilder auth) throws Exception {

         auth

             .inMemoryAuthentication()

                 .withUser("root").password("123").roles("USER");//设置用户名密码

     }

 }

二、启动步骤：

1.启动注册中心：eureka-service