demo(三)eurekaribbonhystrix----服务降级熔断

news2024/11/28 20:53:54

一、介绍：

1、雪崩：多个微服务之间调用的时候，假如微服务A调用微服务B和微服务C，微服务B和微服务C又调用其他的微服务，这就是所谓的"扇出"。如果扇出的链路上某个微服务的调用响应的时间过长或者不可用，对微服A的调用就会占用越来越多的系统资源，进而引起系统崩溃，即"雪崩效应"。对于高流量的应用来说，单一的后端依赖可能会导致所有的服务器上的所有资源都在几秒钟内饱和。比失败更糟糕的是，这些应用程序还可能导致服务之间的延迟增加，备份队列，线程和其他系统资源紧张，导致整个系统发生更多的级联故障。这些都表示需要对故障和延迟进行隔离和管理，以便单个依赖关系的失败，不能取消整个应用程序或系统。所以，通常当一个模块下的某个实例失败后，这时候这个模块依然还会接收流量，然后这个有问题的模块还调用了其他的模块，这样就会发生级联故障，或者叫雪崩。

2、hystrix概念：

①Hystrix是一个用于处理分布式系统的延迟和容错的开源库，可以保证一个服务出现故障时，不会导致整个系统出现雪崩效应，以提高分布式系统弹性；

②作为“断路器”，在一个服务出现故障时，可以通过短路器监控，返回一个可以处理的响应结果，保证服务调用线程不会长时间被占用，避免故障蔓延。

3、作用：

（1）服务降级：

服务出现故障时，给故障服务降级到事先准备好的故障处理结果，将此结果返回给服务消费者，如：客户端访问服务1，服务1调用服务2，服务2出现故障，Hystrix服务降级，返回一个可以处理的结果给服务1，服务1再以友好的错误界面返回给客户端。

主要通过@HystriCommand注解方法实现，其中有两个关键参数，

fallbackMethod：指定服务降级后调用方法，降级方法出参入参一定要和controller方法一致；

commandProperties：相关参数。

（2）服务熔断：参数设置

①circuitBreaker.enabled：是否开启熔断；

②circuitBreaker.requestVolumeThreshold：当前服务失败几次后开启断路，默认20次；

③circuitBreaker.sleepWindowInMilliseconds：设置断路时间，过了该时间后会尝试恢复，在断路时间内，即使请求正确也会走降级方法；

熔断类型

①熔断打开打开后，在此时间内不会对该服务进行调用，而是直接访问降级方法。通过设置熔断时间，当达到该时间后，会尝试恢复该服务。

②熔断关闭熔断关闭代表服务正常，不会干扰正常服务调用。

③熔断半开熔断半开时，请求可以访问服务，若请求正常访问，则熔断会关闭；若请请求不正常，继续熔断，调用降级方法。

4、使用介绍：

（1）pom依赖：

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

（2）@EnableCircuitBreaker类注解：项目启动类加上此注解，表示开启Hystrix。

二、服务降级demo：服务提供者、服务消费者都可以进行自身降级。在之前的基础上：

1、myspringcloud-eureka-client服务提供者组件降级：

（1）加上pom依赖

（2）加上@EnableCircuitBreaker注解

@SpringBootApplication
@EnableEurekaClient
@MapperScan("com.demo.cloud.dao")
@EnableCircuitBreaker
public class MyEurekaClientApplication {
    public static void main(String args[]){
        SpringApplication.run(MyEurekaClientApplication.class,args);
    }
}

（3）接口降级：

package com.demo.cloud.controller;

@RequestMapping("/test")
@RestController
public class TestApiController {

    @Value("${server.port}")
    private String currPort;


    @HystrixCommand(fallbackMethod = "TimeoutHandler", commandProperties = {
            //2秒钟以内就是正常的业务逻辑
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "2000")
    })
    @GetMapping("timeout")
    public String timeout() {
        try {
            //睡眠3秒
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "服务提供者正常返回";
    }

    //降级后方法，上面方法出问题,我来处理，返回一个出错信息
    public String TimeoutHandler() {
        return "我是服务提供者，当前不可用，请稍后再试";
    }
}

此时访问localhost:2222/myService/test/timeout

2、服务消费者myspringcloud-eureka-ribbon组件降级：步骤和上面差不多，不重复了，看接口降级

 @RequestMapping("/findByUserName")
    @HystrixCommand(fallbackMethod = "TimeoutHandler", commandProperties = {
            //2秒钟以内就是正常的业务逻辑
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "2000")
    })
    public UserDTO findByUserName(String username){
        try {
            //睡眠3秒
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        HashMap<String,String> paramMap = new HashMap<>();
        paramMap.put("username",username);
        UserDTO userDTO = restTemplate.getForObject(REST_URL_PREFIX+"/user/findByUserName?username={username}",UserDTO.class,paramMap);
        return userDTO;
    }

    //降级后方法，上面方法出问题,我来处理，返回一个出错信息
     public UserDTO TimeoutHandler(String username) {
        System.out.println("我是服务消费者，当前不可用，请稍后再试");
        return null;
    }