第三章：（4）高可用 之 集群容错&整合 Hystrix（服务熔断）

一、集群容错

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

　　各节点关系：

　　1、这里的 Invoker 是 Provider 的一个可调用 Service 的抽象，Invoker 封装了 Provider 地址及 Service 接口信息；
　　2、Directory 代表多个 Invoker，可以把它看成 List ，但与 List 不同的是，它的值可能是动态变化的，比如注册中心推送变更；
　　3、Cluster 将 Directory 中的多个 Invoker 伪装成一个 Invoker，对上层透明，伪装过程包含了容错逻辑，调用失败后，重试另一个；
　　4、Router 负责从多个 Invoker 中按路由规则选出子集，比如读写分离，应用隔离等；
　　5、LoadBalance 负责从多个 Invoker 中选出具体的一个用于本次调用，选的过程包含了负载均衡算法，调用失败后，需要重选

　　集群容错模式

　　　　Failover Cluster

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

　　　　重试次数配置如下：

<dubbo:service retries="2" />

或

<dubbo:reference retries="2" />

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

　　　　　　提示：该配置为缺省配置。

　　　　Failfast Cluster

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

　　　　Failsafe Cluster

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

　　　　Failback Cluster

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

　　　　Forking Cluster

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

　　　　Broadcast Cluster

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

　　　　　　现在广播调用中，可以通过 broadcast.fail.percent 配置节点调用失败的比例，当达到这个比例后，BroadcastClusterInvoker 将不再调用其他节点，直接抛出异常。 broadcast.fail.percent 取值在 0～100 范围内。默认情况下当全部调用失败后，才会抛出异常。 broadcast.fail.percent 只是控制的当失败后是否继续调用其他节点，并不改变结果(任意一台报错则报错)。broadcast.fail.percent 参数 在 dubbo2.7.10 及以上版本生效。

　　　　　　Broadcast Cluster 配置 broadcast.fail.percent。

　　　　　　broadcast.fail.percent=20 代表了当 20% 的节点调用失败就抛出异常，不再调用其他节点。

@reference(cluster = "broadcast", parameters = {"broadcast.fail.percent", "20"})

　　　　提示：2.1.0开始支持。

　　集群模式配置：

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

<dubbo:service cluster="failsafe" />

　　 或

<dubbo:reference cluster="failsafe" />

二、整合 Hystrix

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

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

　　　　（1）在服务提供者和服务消费者中引入依赖

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

        <dependency>
            <groupId>org.springframework.cloudgroupId>
            <artifactId>spring-cloud-starter-netflix-hystrixartifactId>
            <version>1.4.4.RELEASEversion>
        dependency>

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

@EnableHystrix   //开启服务容错
@EnableDubbo  //开启基于注解的 dubbo 功能
@SpringBootApplication
public class BootUserServiceProviderApplication {

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

}

　　2、配置 Provider 端

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

@Service(version = "1.0.0")
public class HelloServiceImpl implements HelloService {
    
    //方法出现了异常就会进行容错
    @HystrixCommand(commandProperties = {
     @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),
     @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "2000") })
    @Override
    public String sayHello(String name) {
        // System.out.println("async provider received: " + name);
        // return "annotation: hello, " + name;
        throw new RuntimeException("Exception to show hystrix enabled.");
    }
}

　　3、配置 Consumer 端

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

@Service
public class OrderServiceImpl implements OrderService {

    @Reference(version = "1.0.0")
    UserService userService;

    //指定出错的回调方法
    @HystrixCommand(fallbackMethod = "hello")
    @Override
    public List initOrder(String userId) {
        System.out.println("用户ID：" + userId);
        //1.查询用户的收货地址
        List userAddressList = userService.getUserAddressList(userId);
        System.out.println("userAddressList = " + userAddressList);

        userAddressList.forEach(t -> System.out.println(t.getUserAddress()));
        System.out.println("调用完成！");
        return userAddressList;
    }

    //出错的时候来调用这个方法
    public List hello(String userId) {

        //模拟数据等等...
        return Collections.emptyList();
    }
}