SpringCloud那些事-Hystix

在微服务架构中存在多个直接调用的服务，这些服务若在调用时出现故障会导致连锁效应，可能会让整个系统变得不可用，这种情况叫做雪崩，Hystix 为了解决这个问题。

Hystix 使用自己的线程池，这样和主应用服务器线程池隔离，如果调用花费很长时间，会停止调用，不同的命令或命令组能够配置它们各自的线程池，可以隔离不同的服务。

Hystix 使用

引入依赖：

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

开启 Hystix ，启动类上加 @EnableCircuitBreaker

@EnableDiscoveryClient
@EnableCircuitBreaker
@SpringBootApplication
public class ConsumeApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumeApplication.class, args);
    }

}

或者可以使用 @SpringCloudApplication

@SpringCloudApplication
public class ConsumeApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumeApplication.class, args);
    }

}

//SpringCloudApplication 包含了它们3
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
@SpringBootApplication
@EnableDiscoveryClient
@EnableCircuitBreaker
public @interface SpringCloudApplication {
}

然后在消费者 consume 使用 @HystrixCommand

@RestController
public class ConsumeController {

    @Autowired
    private RestTemplate restTemplate;
    
    @GetMapping("/callhello")
    @HystrixCommand(fallbackMethod = "callHelloFailback")
    public String callHello(){
        String url = "http://user-service/user/hello";
       return restTemplate.getForObject(url,String.class);
    }

    public String callHelloFailback(){
        return "服务器繁忙";
    }
}

然后模拟服务提供端超时等情况，这里直接在 user-service 睡眠一会

@RequestMapping("/user")
public class UserController {

    @GetMapping("/hello")
    public String hello() throws InterruptedException {

        Thread.sleep(2000);

        return "hello";
    }
}

注意的是，Hystrix 超时时间默认是1000ms，如果 Ribbon 设置的超时时间小于或等于 Hystix的超时时间，那么重试机制将不会没有被触发，而是直接出发 Hystix。

Hystix 超时时间可以配置：

# 设置hystrix的超时时间为6000ms
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=6000