关于java:Spring-Cloud中Hystrix仪表盘学习笔记

13次阅读

共计 3060 个字符,预计需要花费 8 分钟才能阅读完成。

先简略介绍一下 Hystrix:
Hystrix 是由 Netflflix 开源的一个提早和容错库,因为隔离拜访近程零碎、服务或者第三方库,避免级联失败,从而晋升零碎的可用性与容错性。
Hystrix 次要通过以下几点实现提早和容错。

包裹申请:应用 HystrixCommand 包裹对依赖的调用逻辑。主动投递微服务⽅法(@HystrixCommand 增加 Hystrix 管制)——调用微服务跳闸机制:当某服务的错误率超过肯定的阈值时,Hystrix 能够跳闸,进行申请该服务一段时间。

资源隔离:Hystrix 为每个依赖都保护了一个小型的线程池(舱壁模式)(或者信号量)。如果该线程池已满,发往该依赖的申请就被立刻回绝,而不是排队期待,从而减速失败断定。

监控:Hystrix 能够近乎实时地监控运行指标和配置的变动,例如胜利、失败、超时、以及被回绝 的申请等。

回退机制:当申请失败、超时、被回绝,或当断路器关上时,执行回退逻辑。回退逻辑由开发人员自行提供,例如返回一个缺省值。

自我修复:断路器关上一段时间后,会主动进入“半开”状态。

Hystrix Dashboard(仪表盘)是一款针对 Hystrix 进行实时监控的工具,通过 Hystrix Dashboard 能够直观地看到各 Hystrix Command 的申请响应工夫,申请成功率等数据。在理论工作中我还没实际过,先记录一下学习笔记吧。

单体利用监控我的项目实际:

1、首先创立一个新的 springboot 工程,而后增加依赖:
<dependency>

<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
<version>2.2.7.RELEASE</version>

</dependency>

2、在启动类上增加注解:@EnableHystrixDashboard

3、我的项目启动后,在浏览器拜访,我这边我的项目地址是:http://localhost:8084/hystrix,而后就能够看到 Dashboard 的主页了:

下面能够看到仪表盘工程曾经创立好了,当初还须要有一个服务,让这个服务提供一个门路为 /actuator/hystrix.stream 接口,而后就能够应用 Hystrix 仪表盘来对该服务进行监控了。

4、创立一个新的工程项目,让其能提供 /actuator/hystrix.stream 接口,这里写个测试例子:
(1)创立新我的项目后,增加 hystrix 依赖:
<!–Spring Cloud 熔断器依赖 –>
<dependency>

<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>

</dependency>
<!–Spring Boot 服务监控查看监控依赖 –>
<dependency>

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

</dependency>

(2)批改配置文件
同时,我的项目的拜访入口也须要配置,配置 springboot 监控端点的拜访权限:

这个是用来裸露 endpoints 的,因为 endpoints 中会蕴含很多敏感信息,除了 health 和 info 两个反对间接拜访外,其余的默认不能间接拜访,能够指定(hystrix.stream)或者让它都能拜访(*):

SpringBoot 的监控端点拜访权限 - 指定拜访

management:
endpoints:

web:
  exposure:
    exclude: hystrix.stream

(3)批改启动类
为被监控的服务的启动类增加一个 Bean
@Bean
public ServletRegistrationBean hystrixMetricsStreamServlet() {

ServletRegistrationBean registration = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
registration.addUrlMappings("/actuator/hystrix.stream");
return registration;

}

(4)调用熔断接口:
这里我轻易写了一个近程调用接口,而后设置超时导致触发熔断:
近程服务提供者代码如下:
@RequestMapping(“/service/hello”)
public String hello() {

try {Thread.sleep(4000);
} catch (InterruptedException e) {e.printStackTrace();
}
// 进行业务解决(省略)return "服务提供者";

}

本地消费者代码如下:
/**

  • hystrix 超时工夫是 3.5 秒
  • @return
    */

@RequestMapping(“/web/hystrix”)
@HystrixCommand(fallbackMethod=”error”, ignoreExceptions= RuntimeException.class, commandProperties={@HystrixProperty(name=”execution.isolation.thread.timeoutInMilliseconds”, value=”3500″)})
public String hystrix () {

return restTemplate.getForEntity("http://01-SPRINGCLOUD-SERVICE-PROVIDER/service/hello", String.class).getBody();

}
public String error(Throwable throwable){

System.out.println(throwable.getMessage());
return "error";

}

(5)拜访入口:
通过门路的拜访入口:http://localhost:8082/actuato…

【留神】:这里间接拜访 /hystrix.stream 接口,会输入一连串的 ping:,解决形式是先调用一下这个我的项目工程里的触发熔断的接口。
后果如下:

通过 Dashboard 的主页输出完下面 3 个数据后,点击 Monitor Stream 按钮,能够看到呈现 Loading

这种状况跟下面的一样,这是因为熔断服务始终没有被拜访,所以没有监控的数据,也是须要调用一下这个我的项目工程里的触发熔断的接口。后果如下:

具体相干具体的形容:

【采坑留神】
如果拜访之后,页面呈现上面的提醒:

须要查看管制里的信息:
(1)如果呈现 404,检查一下监控地址填写是否正确;
(2)如果提醒 is not in the allowed,示意你没有配置运行拜访熔断监控页面的地址:
须要在 hystrix-dashBoard 配置文件中增加如下配置即可:
hystrix:
dashboard:

proxy-stream-allow-list: localhost

大抵内容就这些,而且是针对单体利用的监控,后续有其它问题再补充吧。

正文完
 0