Spring Cloud实战(三):微服务错误处理与延迟处理-Hystrix
Hystrix是为了提高微服务的健壮性而生的,它能起到如下作用:1. 控制与保护微服务的延迟与失败问题,尤其是通过网络访问依赖的微服务导致的延迟与错误传播问题;2. 阻止连锁的服务调用失败问题;3. 快速失败与快速恢复;4. 优雅的降级(降低服务质量)与反馈;5. 实时监控、告警与控制;简单点说,因为一个用户请求需要调用多个微服务,那么只要有一个微服务出现问题,那么整个请求都必然
·
Hystrix是为了提高微服务的健壮性而生的,它能起到如下作用:
1. 控制与保护微服务的延迟与失败问题,尤其是通过网络访问依赖的微服务导致的延迟与错误传播问题;
2. 阻止连锁的服务调用失败问题;
3. 快速失败与快速恢复;
4. 优雅的降级(降低服务质量)与反馈;
5. 实时监控、告警与控制;
简单点说,因为一个用户请求需要调用多个微服务,那么只要有一个微服务出现问题,那么整个请求都必然受到影响,这也是短板效应,Hystrix就是为了尽可能将这种影响降到最低(不可能消除)。
1. 错误处理
为了降低业务密集性的服务受到影响,我们有必要为此服务提供备用处理手段,这也是Hystrix最常用的应用场景,具体应用步骤如下:
- 在Spring Boot程序中启用@EnableCircuitBreaker注解,如下:
@EnableEurekaClient
@EnableCircuitBreaker
@SpringBootApplication
@Import({ServiceConfigs.class, MvcConfigs.class})
public class MiranaAssetApplication extends SpringBootServletInitializer {
/**
* 添加自身的配置信息
* @param application
* @return
*/
@Override
protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
return application.sources(MiranaAssetApplication.class);
}
public static void main(String[] args) {
SpringApplication.run(MiranaAssetApplication.class, args);
}
}
- 在微服务端(Eureka客户端)添加Hystrix依赖如下:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
- 在服务接口上添加HystrixCommand注解,并指向备份方法,如下:
@Override
@HystrixCommand(fallbackMethod = "findAllDefault")
public List<Asset> findAll() {
throw new RuntimeException("内部错误");
}
/**
* 备份的处理方法
*/
public List<Asset> findAllDefault() {
return assets.values().asList();
}
现在如果测试我们的Controller,你会发现,调用findAll方法虽然失败了,但是会返回findAllDefault方法的执行结构。
2. 延时处理
如果任务的耗时较长,例如上述代码的finfAll()方法耗时十秒,那么也会自动切换到备份的处理方法,如下:
@HystrixCommand(fallbackMethod = "findAllDefault")
public List<Asset> findAll() {
try {
// 自动进行超时处理
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return null;
}
在异常处理中,除了支持同步调用,还是异步调用Future
响应式任务
参考文档
更多推荐
已为社区贡献2条内容
所有评论(0)