服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - SpringCloud Hystrix的使用

SpringCloud Hystrix的使用

2021-09-08 10:27遇见_line Java教程

这篇文章主要介绍了SpringCloud Hystrix的使用,帮助大家更好的理解和学习使用SpringCloud,感兴趣的朋友可以了解下

 

简介

在分布式系统中,服务与服务之间依赖错综复杂,一种不可避免的情况就是某些服务将会出现失败。Hystrix是一个库,它提供了服务与服务之间的容错功能,主要体现在延迟容错和容错,从而做到控制分布式系统中的联动故障。Hystrix通过隔离服务的访问点,阻止联动故障,并提供故障的解决方案,从而提高了这个分布式系统的弹性。

面对的问题: 一个应用一般会依赖多个服务,每个服务由于网络不可靠,机房的不可靠等等不稳定的因素,总会导致服务的故障,如果我们不对这些故障做处理,就会进而导致整个系统的不可用。

服务雪崩:

SpringCloud Hystrix的使用

SpringCloud Hystrix的使用

一个正常的用户进入调用微服务A然后调用B在调用C然后离开,而当其中微服务C出现故障,导致用户停留
B,越来越多的用户进入,请求,停留B在最终导致B的资源被耗尽,不可用,进而A也慢慢不可用。这一系
列链式反应就像雪崩一样影响越来越大,称为"服务雪崩"

 

服务熔断

参考:www.zzvips.com/article/190136.html

应对雪崩效应的一种微服务链路保护机制

当调用链路的某个微服务不可用或者响应时间太长时,会进行服务熔断,不再有该节点微服务的调用,快速返回错误的响应信息。当检测到该节点微服务调用响应正常后,恢复调用链路。

在Spring Cloud中通过Hystrix实现。Hystrix会监控微服务间调用的状况,当失败的调用到一定阈值,缺省是5秒内20次调用失败,就会启动熔断机制。

服务熔断解决如下问题:

  1. 当所依赖的对象不稳定时,能够起到快速失败的目的;
  2. 快速失败后,能够根据一定的算法动态试探所依赖对象是否恢复

 

实践

项目搭建

根据 实验环境搭建中的项目copy建立一个新模块名为springcloud-provider-dept-hystrix。

导入依赖

?
1
2
3
4
5
<dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-hystrix</artifactId>
     <version>1.4.6.RELEASE</version>
</dependency>

使用

在Controller层,使用@HystrixCommand来实现熔断

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface HystrixCommand {
    String groupKey() default "";
    String commandKey() default "";
    String threadPoolKey() default ""
    String fallbackMethod() default "";
    HystrixProperty[] commandProperties() default {};
    HystrixProperty[] threadPoolProperties() default {};
    Class<? extends Throwable>[] ignoreExceptions() default {};
    ObservableExecutionMode observableExecutionMode() default ObservableExecutionMode.EAGER;
    HystrixException[] raiseHystrixExceptions() default {};
    String defaultFallback() default "";
}

在@HystrixCommand中有 defaultFallback() 指定默认的备用方法(default ""), fallbackMethod() 指定失败后进行的备用方法(default "")

当正常的方法调用失败后(5秒内20次调用失败),认为是出故障了就进行熔断,快速返回错误信息(调用备选方法)。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
@RestController
public class DeptController {
    @Autowired
    private DeptImpl deptimpl;
    @RequestMapping("/dev/{id}")
    @HystrixCommand(fallbackMethod = "HystrixGet")//指明备用方法
    public Dept DeptqueryByID(@PathVariable("id") Long id) {
        Dept dept = deptimpl.queryByID(id);
        System.out.println(dept);
        if (dept==null) {
            throw new RuntimeException("id--->" + id + "用户不存在");
        }
        return dept;
    }
    public Dept HystrixGet(@PathVariable("id") Long id) {
        Dept dept=new Dept();
        dept.setDeptnumber(id.intValue());
        dept.setDname("id"+id+"用户不存在");
        dept.setD_source("no~~~~~~");
        return dept;
    }
 
}

在启动类上添加@EnableCircuitBreaker开启熔断支持

?
1
2
3
4
5
6
7
8
@SpringBootApplication
@EnableEurekaClient
@EnableCircuitBreaker//开启熔断支持
public class HApplication {
    public static void main(String[] args) {
        SpringApplication.run(HApplication.class,args);
    }   
}

 

服务降级

即在服务器压力剧增的情况下,关闭一些很少被调用的服务,腾出一些资源,保证正常运行。

如淘宝双十一关闭退款通道。

 

实践

在原本的FeignClient指明fallbackFactory

?
1
2
3
4
5
6
7
8
9
10
11
@FeignClient(value = "PROVIDER-NAME",fallbackFactory = SerciceFallbackFactory.class)
public interface DeptClientService {
    @RequestMapping(value = "/dev/add")
    boolean add(Dept dept);
 
    @RequestMapping(value = "/dev/{id}")
    Dept queryByID(@PathVariable("id") Long id );
 
    @PostMapping(value = "/dev/list")
    List<Dept> queryAll();
}

定义自己的FallbackFactory

报错注意import feign.hystrix.FallbackFactory;

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
import feign.hystrix.FallbackFactory;
@Component
public class SerciceFallbackFactory implements FallbackFactory {
 
    public DeptClientService create(Throwable cause) {
        return new DeptClientService() {
            public boolean add(Dept dept) {
                return false;
            }
            //定义返回的错误信息
            public Dept queryByID(Long id) {
                Dept dept = new Dept();
                dept.setD_source("服务降级");
                dept.setDname("fail");
                dept.setDeptnumber(-1);
                return dept;
            }
 
            public List<Dept> queryAll() {
                return null;
            }
        };
    }
}

在客户端的配置文件中添加

?
1
2
3
4
#开启降级
feign:
  hystrix:
    enabled: true

结果:在我们关闭服务端后再次访问服务时

SpringCloud Hystrix的使用

 

服务熔断与服务降级的区别

  • 服务熔断是在服务端进行的,而服务降级是在客户端进行的
  • 服务熔断的原因:发生故障,服务降级:为整体负荷考虑,保证核心业务的运行

 

服务监控 Dashboard

 

建立项目

导入依赖

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
 
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
    <version>1.4.6.RELEASE</version>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
    <version>1.4.6.RELEASE</version>
</dependency>

配置文件

?
1
2
3
4
5
6
7
server:
  port: 9001
hystrix:
  dashboard:
# Hystrix Dashboard会通过proxyUrl解析到host部分,然后通过配置的proxyStreamAllowList。判定是否允许被访问
    proxy-stream-allow-list: "localhost"
   

开启监控支持

?
1
2
3
4
5
6
7
8
@SpringBootApplication
@EnableHystrixDashboard//开启
@EnableDiscoveryClient
public class DashboardApplication {
    public static void main(String[] args) {
        SpringApplication.run(DashboardApplication.class,args);
    }
}

运行后访问:http://localhost:9001/hystrix

SpringCloud Hystrix的使用

根据提示在spingcloud-provider-dept-hystrix服务端添加bean

?
1
2
3
4
5
6
@Bean
    public ServletRegistrationBean hystrixMetricsStreamServlet(){
        ServletRegistrationBean servlet = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
        servlet.addUrlMappings("/actuator/hystrix.stream");
        return servlet;
    }

运行后访问 http://localhost:8081/actuator/hystrix.stream 可以获得一些服务的信息

注意: 需要调用一次标注有 @HystrixCommand 方法才会有数据显示,只会监控有 @HystrixCommand 的方法

SpringCloud Hystrix的使用

我们也可以通过在http://localhost:9001/hystrix 输入

SpringCloud Hystrix的使用

按下按钮开启对该服务的监控

SpringCloud Hystrix的使用

SpringCloud Hystrix的使用

以上就是SpringCloud Hystrix的使用的详细内容,更多关于SpringCloud Hystrix的资料请关注服务器之家其它相关文章!

原文链接:https://juejin.cn/post/6951311432801583112

延伸 · 阅读

精彩推荐