Hystrix 服务降级-后备模式 实现思路

服务降级

Hystrix 提供了服务降级功能。
有些场景下当调用服务失败时，不应该产生一个Exception 异常给用户。而是采用执行备用策略。

比如：假如一个购物网站，它可以监控用户的行为，并尝试向用户推荐其它可以购买的商品。通常来说，可以调用微服务来对用户过去的行为进行分析，并返回针对特定用户的推荐列表。但是如果调用这个服务失败。则启动后备策略来检索一个更通用的偏好列表，该列表可以是热门商品的列表或基于全部用户购买记录分析的结果。

Hystrix 服务降级示例

package com.jijs.fallback.test;

import java.util.concurrent.TimeUnit;

import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import com.netflix.hystrix.HystrixCommandProperties;

public class HystrixFallbackDemo extends HystrixCommand<String> {
    protected HystrixFallbackDemo() {
        super(Setter.withGroupKey(
                HystrixCommandGroupKey.Factory.asKey("HystrixFallback"))
                .andCommandPropertiesDefaults(
                        HystrixCommandProperties.Setter()
                        .withExecutionTimeoutInMilliseconds(1000)));
    }

    @Override
    protected String run() throws Exception {
        //执行超时
        TimeUnit.MILLISECONDS.sleep(2000);

        //执行异常
        //int i = 5 / 0;

        //主动抛出异常
        //throw new HystrixTimeoutException();
        
        return "ok";
    }

    @Override
    protected String getFallback() {
        return "fallback";
    }   

    public static void main(String[] args) {
        HystrixFallbackDemo t = new HystrixFallbackDemo();
        String result = t.execute();
        System.out.println(result);
    }
}

使用 Hystrix 实现一个后备策略，开发人员必须以下做几点。
1、继承 HystrixCommand 类。
2、在构造中定义 Hystrix 相关策略
3、重写 HystrixCommand 类的 run() 方法，写自己的核心业务。
4、重写 HystrixCommand 类的 getFallback() 方法，来实现后备策略。

使用 HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(1000) 设置调用执行 run() 方法的超时时间为1秒。

当执行 run() 方法时间超过1秒、执行run报错 或 抛出异常都会执行 getFallback () 方法。

自己动手实现 Hystrix 的后备策略

package com.jijs.fallback.test;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

public class FallbackDemo {

    public static void main(String[] args) {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        Task task = new Task();
        Future<String> f = executor.submit(task);

        String result;
        try {
            result = f.get(1000, TimeUnit.MILLISECONDS);    //执行超时时间1000
        } catch (Exception e) {
            //捕获所有的 Exception 异常，都执行 fallback方法。
            result = task.fallback();
        }
        System.out.println(result);

        executor.shutdown();
    }
}

class Task implements Callable<String> {

    public String call() throws Exception {
        //执行超时
        TimeUnit.MILLISECONDS.sleep(2000);

        //执行异常
        //int i = 5 / 0;

        //主动抛出异常
        //throw new HystrixTimeoutException();
        
        return "ok";
    }

    //后备方法
    public String fallback() {
        return "fallback";
    }
}

1、Hystrix 底层默认也是使用线程池来隔离不同的资源的。这里我们也模拟创建一个线程池。
2、然后将任务提交给线程池执行，因为任务实现了Callable 接口，所有我们可以使用 Future 来异步获取执行结果。
3、通过 Future.get(2000, TimeUnit.MILLISECONDS) 来指定 任务 执行的超时时间。
4、捕获异常，如果出现Exception的异常都执行 Task 的后备方法 fallback()。

从功能上来看，我们已经简单的实现了 Hystrix 的后备模式（超时、异常 等都可以执行后备方法）。