Hystrix概述

Hystrix：它是一个服务熔断，服务降级的非常好的解决方案。

服务降级当服务里面某一个方法出现柱塞。大量请求进来。会影响运行很快的方法。当服务器压力剧增的情况下，根据实际业务情况及流量，对一些服务和页面有策略的不处理或换种简单的方式处理，从而释放服务器资源以保证核心交易正常运作或高效运作。可以通过服务降级功能临时屏蔽某个出错的非关键服务，并定义降级后的返回策略。在网站并发高时，可以暂时屏蔽一些对业不影响的服务，如广告服务。

容错机制：在消费者端把A服务器屏蔽。再去请求，此时发现不会做远程调用，直接返回了null。

服务熔断：类似于这有用的保险丝，如果并发太大，可以熔断。

集群容错：在集群调用失败时，Dubbo 提供了多种容错方案，缺省为 failover 重试。

集群容错模式

Failover Cluster

失败自动切换，当出现失败，重试其它服务器。通常用于读操作，但重试会带来更长延迟。可通过 retries=“2” 来设置重试次数(不含第一次)。

重试次数配置如下：

<dubbo:service retries="2" />
或
<dubbo:reference retries="2" />
或
<dubbo:reference>
  <dubbo:method name="getUserAddressList" retries="2" />
</dubbo:reference>

Failfast Cluster

快速失败，只发起一次调用，失败立即报错。通常用于非幂等性的写操作，比如新增记录。

Failsafe Cluster

失败安全，出现异常时，直接忽略。通常用于写入审计日志等操作。

Failback Cluster

失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。

Forking Cluster

并行调用多个服务器，只要一个成功即返回。通常用于实时性要求较高的读操作，但需要浪费更多服务资源。可通过 forks=“2” 来设置最大并行数。

Broadcast Cluster

广播调用所有提供者，逐个调用，任意一台报错则报错 [2]。通常用于通知所有提供者更新缓存或日志等本地资源信息。

集群模式配置

按照以下示例在服务提供方和消费方配置集群模式：

<dubbo:service cluster="failsafe" />
<dubbo:reference cluster="failsafe" />

整合hystrix

Hystrix 旨在通过控制那些访问远程系统、服务和第三方库的节点，从而对延迟和故障提供更强大的容错能力。Hystrix具备拥有回退机制和断路器功能的线程和信号隔离，请求缓存和请求打包，以及监控和配置等功能。

1、配置spring-cloud-starter-netflix-hystrix

SpringBoot官方提供了对Hystrix的集成，直接在pom.xml里加入依赖：

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

2、然后在Application类上增加@EnableHystrix来启用hystrix starter：

@EnableDubbo//开启注解的dubbo功能
@SpringBootApplication
@EnableHystrix
public class BootEgoUserServiceProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(BootEgoUserServiceProviderApplication.class, args);

    }
}

3、配置Provider端

在Dubbo的Provider上增加@HystrixCommand配置，这样子调用就会经过Hystrix代理。

@Service//暴露服务
public class UserServiceImpl implements UserService{
    public static List<UserAddress> address=new ArrayList<>();
    static {
        address.add(new UserAddress(1, "湖北省武汉市东湖高新区", "aaa"));
        address.add(new UserAddress(2, "湖北省武汉市洪山区", "bbb"));
    }
    @HystrixCommand
    @Override
    public List<UserAddress> getUserAddressList(String userId) {
        System.out.println("UserServiceImpl----20082-3");
        //讲道理要是去数据库里面去查询的
        if(Math.random()>0.5) {
            throw new RuntimeException();
        }
        return address;
    }
}

4、配置Consumer端

对于Consumer端，则可以增加一层method调用，并在method上配置@HystrixCommand。当调用出错时，会走到fallbackMethod = "reliable"的调用里。

5、启动类

@SpringBootApplication
@EnableDubbo //启动dubbo
@EnableHystrix
public class BootEgoOrderServiceConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(BootEgoOrderServiceConsumerApplication.class, args);
    }
}

6、消费类

@Service
public class OrderServiceImpl implements OrderService {
    @Reference
    UserService userService;
    
    //如果出错就调用hello方法
    @HystrixCommand(fallbackMethod="hello")
    @Override
    public List<UserAddress> initOrder(String userId) {
        System.out.println("用户id："+userId);
        //1、查询用户的收货地址
        List<UserAddress> addressList = userService.getUserAddressList(userId);
        return addressList;
    }

    //出错之后的回调方法
    public List<UserAddress> hello(String userId) {
        return Arrays.asList(new UserAddress(3, "出错啦", "1"));
    }
}