springcloud-hystrix容错保护注解方式的使用

忘是亡心i 2022-06-05 00:55 220阅读 0赞

简单的搭建的流程：第一，eureka注册中心；第二，在eureka上注册的服务；第三，在eureka消费服务的客户端，hystrix，是在客户端上的使用，在调用端嵌入jar包，以jar包的方式使用hystrix，不需要额外的安装，在项目中添加如下依赖。

<dependency>
    	<groupId>org.springframework.cloud</groupId>
    	<artifactId>spring-cloud-starter-hystrix</artifactId>
    </dependency>

@EnableCircuitBreaker或@EnableHystrix开启hystrix的使用，由于这是在服务调用端的添加，因此一般还需要添加@EnableDiscoveryClient注解，还可以使用@SpringCloudApplication，进去这个注解可以发现这个注解包括以下注解，所以@SpringCloudApplication注解可以使用hystrix

@Target({ElementType.TYPE})
    @Retention(RetentionPolicy.RUNTIME)
    @Documented
    @Inherited
    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableCircuitBreaker
    public @interface SpringCloudApplication {
    }

hystrix提供5部分的服务，分别是降级、隔离、熔断器、异常和缓存，对于缓存，个人认为是鸡肋的功能，在这里不做说明。在网上看到很多使用代码的方式进行降级等操作，个人认为并不好，这些属于非功能的业务使用注解的方式会更好，因此在这里主要介绍注解的方式。  
降级：

/**
             * 同步的方式实现
             * @return
             */
            @HystrixCommand(fallbackMethod = "fallback")
            public String consumer() {
                return restTemplate.getForObject("http://COMPUTE-SERVICE/add?a=10&b=20", String.class);
            }
    		
    		/**
             * 异步的方式实现
             * @return
             */
            @HystrixCommand(
                    commandProperties = {
                            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value ="40000"),
                    }
            )
            public Future<String> consumerA(){
                return new AsyncResult<String>() {
                    @Override
                    public String invoke() {
                        return restTemplate.getForObject("http://COMPUTE-SERVICE/add?a=10&b=20", String.class);
                    }
                };
            }
    		
    	public String fallback() {
                return "fallbck";
            }

有两种实现的方式，一种同步一种异步，当服务调用失败的时候，便会直接调用fallback方法，异步需要调用端按照以下方式处理才能获取相关数据

Future<String> result = consumerService.consumerA();
            return result.get();

降级处理的时候可以连续降级，fallback方法是可以继续使用HystrixCommand命令指定降级方法，直到处理完毕   
隔离：

/**
             * @return
             */
            @HystrixCommand(
                    //表示所属的group，一个group共用线程池,默认使用类名作为一个组,
    				//同一个分组，使用相同的线程池，线程池的个数按照最小的定义限定，所以线程池定义一次就可以了，再次使用的时候直接定义分组
                    //同一个分组，不同的线程池，按照不同的线程池来限定
                    groupKey = "GroupOne",
                    //线程池的名称
                    threadPoolKey = "groupOnePoolE",
                    fallbackMethod = "fallbackTest",
                    commandProperties = {
                            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value ="20000"),
                    },
                    //以下这些值，在分组的情况下有效
                    threadPoolProperties = {
                            //核心线程数
                            @HystrixProperty(name = "coreSize", value = "3"),
                            //超过队列的个数会直接失败
                            @HystrixProperty(name = "maxQueueSize", value = "10"),
                            //队列小于最大值，拒绝请求
                            @HystrixProperty(name = "queueSizeRejectionThreshold", value = "3")
                            //总结：请求数目大于核心线程数+队列的拒绝数的时候就会失败，配置降级方法的时候，不会失败直接调用降级方法
                            //默认的情况下，以service的名称作为线程池的名称，使用HystrixCommand默认情况下coreSize为10，maxQueueSize使用LinkedBlockingQueue动态拓展，queueSizeRejectionThreshold默认大小值5
                    }
            )
            public String consumerPN() {
                try{
                    Thread.sleep(10000);
                }catch (Exception e){
    
    
                }
                return restTemplate.getForObject("http://COMPUTE-SERVICE/add?a=10&b=20", String.class);
            }
    
    
            public String fallbackTest(){
                return "十次用户请求并发后，超过设置会触发这个降级，否则会出现失败页面";
            }

熔断器：

@HystrixCommand(
                    commandProperties = {
                            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value ="11000"),
                            //是否开启熔断器
                            @HystrixProperty(name = "circuitBreaker.enabled", value ="true"),
                            //请求的失败数目超过这个之后，就会打开熔断器
                            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value ="5"),
                            //熔断器工作时间，默认5秒，超过这个时间便会放流量进去
                            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value ="50000"),
                            //出错率超过75%，启动熔断器，默认50%
                            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value ="75"),
                    }
            )
            public String fuse() {
                try{
                    Thread.sleep(10000);
                }catch (Exception e){
    
    
                }
                return restTemplate.getForObject("http://COMPUTE-SERVICE/add?a=10&b=20", String.class);
            }

异常：

/**
             * 以下方式抛出RuntimeException异常的时候不会降级，而是直接按照异常进行处理，将异常抛给调用端
             * 如果没有在ignoreExceptions中添加RuntimeException，则会将异常按照降级方法进行处理
             * @return
             */
            @HystrixCommand(ignoreExceptions = {RuntimeException.class},fallbackMethod = "fallback")
            public String consumerAT() {
                String result = null;
                try {
                    result = restTemplate.getForObject("http://add?a=10&b=20", String.class);
                }catch (Exception e){
                    throw new RuntimeException();
                }
                return result;
            }