Hystrix熔断器的使用
SpringCloud--Hystrix(断路器)0、什么是服务雪崩多个微服务之间调用的时候,假设微服务A调用微服务B和微服务C,微服务B和微服务C又调用其它的微服务,这就是所谓的“扇出”。如果扇出的链路上某个微服务的调用响应时间过长或者不可用,对微服务A的调用就会占用越来越多的系统资源,进而引起系统崩溃,所谓的“雪崩效应”。1、什么是hystrix?Hystrix是...
·
0、什么是服务雪崩
多个微服务之间调用的时候,假设微服务A调用微服务B和微服务C,微服务B和微服务C又调用其它的微服务,这就是所谓的“ 扇出”。如果扇出的链路上某个微服务的调用响应时间过长或者不可用,对微服务A的调用就会占用越来越多的系统资源,进而引起系统崩溃,所谓的“雪崩效应”。1、什么是hystrix?
Hystrix是一个用户处理分布式系统的延迟和容错的开源库,在分布式系统里,许多依赖不可避免的会调用失败,比如超时、异常等,Hystrix能够保证在一个依赖出问题的情况下,不会导致整体服务失败,避免级联故障,以提高分布式系统的弹性。“断路器”本身是一种开关装置,当某个服务单元发生故障之后, 通过断路器的故障监控(类似熔断保险丝),向调用方向返回一个符
合预期的、可处理的备选相应(FallBack),而不是长时间的等待或者跑出调用方法无法处理的异常,这样就保证了服务调用方的线程不会被长时间、不必要地占用,从而避免了故障在分布式系统中的蔓延,乃至血崩。
2、它能做什么?
服务降级
整体资源快不够了,忍痛将某些服务先关掉,待度过难过,再开启回来。
服务熔断
熔断机制是应对雪崩效应的一种微服务链路保护机制。当扇出链路的某个微服务不可用或者响应时间太长,会进行服务的降级,进而熔断该节点微服务的调用,快速返回“错误”的响应信息
。当检测到该节点的微服务调用响应正常之后恢复调用链路。默认5秒内调用20次失败就会启动熔断机制。注解为:@HystrixCommand。
服务限流
接近实时的监控 等
3、怎么用(在服务提供者端)
1、pom加入依赖
<!-- hystrix -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
2、配置yml
server port8001 mybatis config-location classpath mybatis/mybatis.cfg.xml # mybatis配置文件所在路径 type-aliases-package com.atguigu.springcloud.entities # 所有Entity别名类所在包 mapper-locations # mapper映射文件 classpath:mybatis/mapper/**/*.xml spring application name microservicecloud-dept datasource type com.alibaba.druid.pool.DruidDataSource # 当前数据源操作类型 driver-class-name org.gjt.mm.mysql.Driver # mysql驱动包 url jdbc mysql //localhost 3306/cloudDB01 # 数据库名称 username root password xuex dbcp2 min-idle 5 # 数据库连接池的最小维持连接数 initial-size 5 # 初始化连接数 max-total 5 # 最大连接数 max-wait-millis 200 # 等待连接获取的最大超时时间 eureka client#客户端注册进eureka服务列表内 service-url # defaultZone: http://localhost:7001/eureka defaultZone http //eureka7001.com 7001/eureka/,http //eureka7002.com 7002/eureka/,http //eureka7003.com 7003/eureka/ instance instance-id microservicecloud-dept8001-hystrix prefer-ip-address true #访问路径可以显示IP地址 info app.name atguigu-microservicecloud company.name www.atguigu.com build.artifactId $project.artifactId$ build.version $project.version$
3、在Controller类可能出错的方法添加注解
(value = "/dept/get/{id}", method = RequestMethod.GET) (fallbackMethod = "processHystrix_Get") //一旦服务出错,会调用回到方法processHystrix_Get() public Dept get( ("id") Long id) { Dept dept = this.service.get(id); if(dept == null) { throw new RuntimeException("该ID:"+id+"没有查询到数据"); } return dept; } public Dept processHystrix_Get( ("id") Long id) { return new Dept().setDeptno(id).setDname("该id:"+id+"没有对应信息,null--@HystrixCommand") .setDb_source("no this database in Mysql"); }
4、最后修改主启动类,开启熔断器
//服务注册 //服务发现 //对hystrix熔断器的支持 public class DeptProvicer8001_App { public static void main(String[] args) { SpringApplication.run(DeptProvicer8001_App.class, args); } }
更多推荐
已为社区贡献2条内容
所有评论(0)