0503-Hystrix保護應用-feign的hystrix支持

1、概述

1.一、基礎【示例一】

　　若是Hystrix在類路徑上而且feign.hystrix.enabled = true，Feign將用斷路器包裝全部方法。還能夠返回com.netflix.hystrix.HystrixCommand。這可以讓您使用響應模式（調用.toObservable（）或.observe（）或異步使用（調用.queue（））。

　　要以每一個客戶端爲基礎禁用Hystrix支持，請建立一個具備「prototype」範圍。

　　在Spring Cloud Dalston發佈以前，若是Hystrix在類路徑上，Feign默認狀況下會將全部方法封裝在斷路器中。 Spring Cloud Dalston改變了這種默認行爲，以支持選擇加入方式。

@Configuration
public class FooConfiguration {
    @Bean
    @Scope("prototype")
    public Feign.Builder feignBuilder() {
        return Feign.builder();
    }
}

1.二、Fallbacks【示例1、示例二】

　　Hystrix支持回退的概念：當電路斷開或出現錯誤時執行的默認代碼路徑。要爲給定的@FeignClient啓用回退，請將fallback屬性設置爲實現回退的類名稱。您還須要將您的實現聲明爲Spring bean。

@FeignClient(name = "hello", fallback = HystrixClientFallback.class)
protected interface HystrixClient {
    @RequestMapping(method = RequestMethod.GET, value = "/hello")
    Hello iFailSometimes();
}

static class HystrixClientFallback implements HystrixClient {
    @Override
    public Hello iFailSometimes() {
        return new Hello("fallback");
    }
}

1.三、回退觸發器的緣由fallbackFactory屬性[示例三]

　　若是須要訪問做爲回退觸發器的緣由，則可使用@FeignClient中的fallbackFactory屬性。　　

　　爲指定的客戶端接口定義一個回退工廠。回退工廠必須產生回退類的實例，這些實例實現由FeignClient註釋的接口。

　　若是同時設置fallback和fallbackfactory不能夠有衝突，fallback生效，fallbackfactory不能使用，fallbackFactory 是fallback的一個升級版，註釋fallback設置便可

@FeignClient(name = "hello", fallbackFactory = HystrixClientFallbackFactory.class)
protected interface HystrixClient {
    @RequestMapping(method = RequestMethod.GET, value = "/hello")
    Hello iFailSometimes();
}

@Component
static class HystrixClientFallbackFactory implements FallbackFactory<HystrixClient> {
    @Override
    public HystrixClient create(Throwable cause) {
        return new HystrixClient() {
            @Override
            public Hello iFailSometimes() {
                return new Hello("fallback; reason was: " + cause.getMessage());
            }
        };
    }
}

 查看FallbackFactory

public interface FallbackFactory<T> {

  /**
   * Returns an instance of the fallback appropriate for the given cause
   *
   * @param cause corresponds to {@link com.netflix.hystrix.AbstractCommand#getExecutionException()}
   * often, but not always an instance of {@link FeignException}.
   */
  T create(Throwable cause);

  /** Returns a constant fallback after logging the cause to FINE level. */
  final class Default<T> implements FallbackFactory<T> {
    // jul to not add a dependency
    final Logger logger;
    final T constant;

    public Default(T constant) {
      this(constant, Logger.getLogger(Default.class.getName()));
    }

    Default(T constant, Logger logger) {
      this.constant = checkNotNull(constant, "fallback");
      this.logger = checkNotNull(logger, "logger");
    }

    @Override
    public T create(Throwable cause) {
      if (logger.isLoggable(Level.FINE)) {
        logger.log(Level.FINE, "fallback due to: " + cause.getMessage(), cause);
      }
      return constant;
    }

    @Override
    public String toString() {
      return constant.toString();
    }
  }
}

View Code

注意事項：在Feign中實施回退以及Hystrix回退的工做方式存在限制。目前，com.netflix.hystrix.HystrixCommand和rx.Observable的方法不支持回退。 

2、示例區

示例1、feign使用hystrix

示例參看：https://github.com/bjlhx15/spring-cloud/tree/master/microservice-comsumer-movie-feign-with-hystrix

一、增長引用

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

二、增長配置啓用

feign.hystrix.enabled=true

三、啓動類增長註解

@EnableCircuitBreaker

四、增長UserFeignClient業務接口，並配置fallback 

@FeignClient(name = "microservice-provider-user", fallback = HystrixClientFallback.class)
public interface UserFeignClient {
    // @GetMapping("/sample/{id}")
    @RequestMapping(method = RequestMethod.GET, value = "/sample/{id}")
    public User findById(@PathVariable("id") Long id);
}

五、增長HystrixClientFallback類

@Component
public class HystrixClientFallback implements UserFeignClient {
    @Override
    public User findById(Long id) {
        User user = new User();
        user.setId(0L);
        return user;
    }
}

示例2、如何禁用單個FegionClient的Hystrix的支持

參考代碼：https://github.com/bjlhx15/spring-cloud/tree/master/microservice-comsumer-movie-feign-customizing-without-hystrix

一、設置一遍如同上面

二、新增一個業務接口FeignClient2

@FeignClient(name = "xxxx", url = "http://localhost:8761/", configuration = Configuration2.class,fallback = FeignClient2Fallback.class)
public interface FeignClient2 {
    @RequestMapping(value = "/eureka/apps/{serviceName}")
    public String findServiceInfoFromEurekaByServiceName(@PathVariable("serviceName") String serviceName);
}

三、使用fallback 

@Component
public class FeignClient2Fallback implements FeignClient2 {
    @Override
    public String findServiceInfoFromEurekaByServiceName(String serviceName) {
        return "haha";
    }
}

四、使用的配置類

@Configuration
public class Configuration2 {
    @Bean
    public BasicAuthRequestInterceptor basicAuthRequestInterceptor() {
        return new BasicAuthRequestInterceptor("user", "a123");
    }

 @Bean @Scope("prototype") public Feign.Builder feignBuilder() { return Feign.builder(); }
}

能夠看到這裏主要增長了feignBuilder建立

示例3、 回退觸發器的緣由fallbackFactory屬性

參考代碼：

一、基本配置略

二、配置UserFeignClient 

@FeignClient(name = "microservice-provider-user",  fallbackFactory = HystrixClientFallbackFactory.class)
public interface UserFeignClient {
    // @GetMapping("/sample/{id}")
    @RequestMapping(method = RequestMethod.GET, value = "/sample/{id}")
    public User findById(@PathVariable("id") Long id);
}

注意：配置了fallbackFactory ，若是同時設置fallback和fallbackfactory不能夠有衝突，只能設置一個，fallbackFactory 是fallback的一個升級版

三、fallbackFactory 的類設置HystrixClientFallbackFactory

@Component
public class HystrixClientFallbackFactory implements FallbackFactory<UserFeignClient> {
    private static final Logger logger = LoggerFactory.getLogger(HystrixClientFallbackFactory.class);

    @Override
    public UserFeignClient create(Throwable arg0) {
        HystrixClientFallbackFactory.logger.info("fallback reason was:{}", arg0.getMessage());
        return new UserFeignClientWithFactory() {
            @Override
            public User findById(Long id) {
                User user = new User();
                user.setId(-1L);
                return user;
            }
        };
    }
}

四、UserFeignClientWithFactory設置

public interface UserFeignClientWithFactory extends UserFeignClient {

}