前言
分布式应用程序面临着一些问题,会出现服务雪崩。多个微服务间调用的时候,假设微服务A调用微服务B,微服务B调用微服务C,即扇出。如果扇出的链路上某个微服务的调用响应时间过长或不可用,对微服务A的调用就会占用越来越多的系统资源,进而引起系统的崩溃,即雪崩效应。
而Spring Cloud Hystrix的出现便可以解决这种情况,Hystrix是一个用于处理分布式系统的延迟和容错的开源库,在分布式系统中,许多依赖不可避免调用失败,如超时、异常等,Hystrix能够保证在一个依赖出问题的情况下,不会导致整体服务失败,避免级联鼓掌,以提高分布式系统的弹性。
Hystrix主要功能
一、Hystrix 断路器
一种开关装置,当某个服务单元发生鼓掌后,通过断路器的故障监控(类似熔断保险丝),向调用方返回一个符合预期的、可处理的备选响应(FallBack),而不是长时间的等待或抛出无法处理的异常,这样就保证了服务调用方的线程不会长时间、不必要占用,从而避免了故障在分布式系统中的蔓延,乃至雪崩。
二、服务熔断
一般是某个服务故障或者异常引起,类似现实世界中的保险丝,当某个异常条件被触发,直接熔断整个服务,而不是一直等到此服务超时。
三、服务降级
降级,一般是从整体负荷考虑,当某个服务熔断之后,服务器将不再被调用,此时客户端可以自己准备一个本地的fallback回调,返回一个缺省值。
四、服务限流
服务限流依赖于服务熔断,当系统资源不够,不足以应对大量请求,即系统资源与访问量出现矛盾的时候,我们为了保证优先的资源能够正常服务,因此对系统按照预设的规则进行流量限制或功能限制。
推荐文章 架构设计之「服务限流」
五、接近实时监控
除了隔离依赖服务的调用以外,Hystrix还提供了准实时的调用监控(Hystrix DashBoard),Hystrix会持续地记录所有通过Hystrix发起的请求的执行信息,并以统计报表和图形的形式展现给用户。如每秒执行多少请求,多少成功,多少失败等。
搭建Hystrix项目模块
一、创建服务提供者的Hystrix 模块 -- microservicecloud-provider-dept-hystrix-8001
在之前 服务提供者模块的基础上,继续添加Hystrix模块。
1.引入pom.xml的依赖
<!-- hystrix -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
2.修改配置文件application.yml
将instance-id的值修改了。
eureka:
client: #客户端注册进eureka服务列表内
service-url:
defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
instance:
instance-id: microservicecloud-dept8001-hystrix #自定义hystrix相关的服务名称信息
prefer-ip-address: true #访问路径可以显示IP地址
lease-renewal-interval-in-seconds: 5 # 租约续订间隔时间(默认30秒),如下所示每间隔 5s 向服务端发送一次心跳,证明自己依然"存活"
lease-expiration-duration-in-seconds: 10 # 租约到期时间(默认90秒),如下所示,告诉服务端如果我 10s 之内没有给你发心跳,就代表我"死"了,将我踢出掉
3.修改 提供者模块的controller 接口,并添加对应注解
@HystrixCommand 以及出现服务不可用的情况下,会调用自定义的方法processHystrix_Get
@RestController
public class DeptController
{
@Autowired
private DeptService service = null;
@RequestMapping(value = "/dept/get/{id}", method = RequestMethod.GET)
//一旦调用服务方法失败并抛出了错误信息后,会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法
@HystrixCommand(fallbackMethod = "processHystrix_Get")
public Dept get(@PathVariable("id") Long id)
{
Dept dept = this.service.get(id);
if (null == dept) {
throw new RuntimeException("该ID:" + id + "没有没有对应的信息");
}
return dept;
}
public Dept processHystrix_Get(@PathVariable("id") Long id)
{
return new Dept().setDeptno(id).setDname("该ID:" + id + "没有没有对应的信息,null--@HystrixCommand")
.setDb_source("no this database in MySQL");
}
}
4.效果演示
输入不存在的id
二、服务调用失败处理--修改API层代码
1.添加一个实现了FallbackFactory接口的类DeptClientServiceFallbackFactory
处理消费者调用提供者失败的情况。
@Component // 不要忘记添加,不要忘记添加
public class DeptClientServiceFallbackFactory implements FallbackFactory<DeptClientService>
{
@Override
public DeptClientService create(Throwable throwable)
{
return new DeptClientService() {
@Override
public Dept get(long id)
{
return new Dept().setDeptno(id).setDname("该ID:" + id + "没有没有对应的信息,Consumer客户端提供的降级信息,此刻服务Provider已经关闭")
.setDb_source("no this database in MySQL");
}
@Override
public List<Dept> list()
{
return null;
}
@Override
public boolean add(Dept dept)
{
return false;
}
};
}
}
2. 修改已经有的DeptClientService接口注解
添加服务调用失败,错误处理类DeptClientServiceFallbackFactory
//@FeignClient(value = "MICROSERVICECLOUD-DEPT")
@FeignClient(value = "MICROSERVICECLOUD-DEPT",fallbackFactory=DeptClientServiceFallbackFactory.class)
public interface DeptClientService
{
@RequestMapping(value = "/dept/get/{id}", method = RequestMethod.GET)
public Dept get(@PathVariable("id") long id);
}
3.修改消费者服务-microservicecloud-consumer-dept-feign的配置文件application.yml
如果消费者服务不添加这个配置属性,无法走服务熔断的功能。
feign:
hystrix:
enabled: true
4. 演示效果
(1)消费端调用提供者服务,处理未查询到的结果
(2)停掉提供者服务,消费端调用提供者服务时,服务出现熔断,降级,调用指定的方法
小结
服务降级,使用AOP织入,熔断解耦,整体资源快不够了,忍痛将某些服务先关掉,待度过难关,再开启回来。服务降级处理是在客户端实现完成的,与服务端没有关系。
感谢您的访问!