HystrixCommand 动态配置

需求： @HystrixCommand 的commandProperties 属性需要动态的配置，比如根据传递的参数，动态的配置每个url 请求的 execution.isolation.thread.timeoutInMilliseconds属性。(本文没有使用Hystrix Rx 响应式模式)

实现：

需求其实很简单，记录下自己探索过程。                                                                

首先：先补充下基本的知识， 我们得知道熔断器circuitBreaker 的基本状态，下面是图来自于vertx 状态转换之间的关系（作者是vertx 官网其中一本书，具体的忘记了），很具体的分析，请查阅详细的资料。这里就只介绍一个半开启的状态（half-open state). 在半开启的状态下，允许下一次熔断器的调用实际调用如果成功，熔断器将复位并返回到关闭状态（closed staus），回归正常的模式；但是如果这次调用失败，则熔断器返回到熔断状态（open status），直到下次半开状态.  我们可以通过设（setResetTimeout设置）来设置多久之后，进入half-open 的状态。因为不了解状态转换的小伙伴们，会吃惊的遇到一种情况：请求的服务好了之后，code仍然执行到fallback method里面去。原因是此时的状态仍是closed state。需要等待一段时间（setResetTimeout）的时间，状态变成half-open state时候，才allow you 重新尝试访问服务。这种状态管理是为了保护当前的service，特别是遇到很大的流量的时候。好了下面看看，我是怎么解决这么简单的问题的。

其次：需要补充的是，HystrixCommand 这个东西呢是从过拦截器来做的，也就是spring 的AOP，一开始我不知道，这个就是解决动态配置的关键所在: HystrixCommandAspect

第一步：最容易让我想到的就是extend模式，这种方式得mysimpleObject extend HystrixCommand。通过 super(Setter.withGroupKey(HystrixCommandKey.Factory.asKey("ExampleGroup")).andcommandPropertiesDefaults(HystrixCommandProperties.Setter().withExecutionTimeoutMilliSeconds(500))), 这是不是很酷？

然后重写 run 和fallback方法，执行restTemplate调用服务。 调用的时候就简简单单的new mysimpleObject（参数传递）.execute 一下，就会执行 run里面的方法，当出现熔断的情况下，会执行fallback里面的逻辑。可问题来了，这个东西不适用，因为首先 run（） 函数不能传递参数，其次是要为每种情况下都得extend HystrixCommand， 没有通用性。所以写写就放弃了，虽然可以使用范型等。

第二步：还记得HystrixCommand的本质是什么东西吗？ AOP！ 好了，那就简单了，那我大展一下AOP的本事，所以我刷刷下了差不多下面的代码（不是全部，只是关键的步骤）：

/**

* point cut

*/

@Pointcut("@annotation(com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand)")

public void hystrixCommandAnnotationPointcut() {

}

/**

* reset the hystrix command properties : request timeout

* @param joinPoint

* @throws Throwable

*/

@Before("hystrixCommandAnnotationPointcut()")

public void customizeHystrixCommandProperties(final JoinPoint joinPoint)throws Throwable {

Method method = AopUtils.getMethodFromTarget(joinPoint);

HystrixCommand hystrixCommand = method.getAnnotation(HystrixCommand.class);

HystrixProperty[] hystrixProperties = hystrixCommand.commandProperties();

for (HystrixProperty hystrixProperty : hystrixProperties){

if("execution.isolation.thread.timeoutInMilliseconds".equals(hystrixProperty.name())){

InvocationHandler invocationHandler = Proxy.getInvocationHandler(hystrixProperty);

        Field field = invocationHandler.getClass().getDeclaredField("memberValues");

        field.setAccessible(true);

        Map memberValues = (Map) field.get(invocationHandler);

        memberValues.put("value", “6000”);

    }

}

看见了吧，@HystrixCommand里面的属性和字段都可以这样的拦截然后重写，好了，很兴奋。动态的值从哪里传呢？那当然是函数的参数了Object[] args = joinPoint.getArgs(); 这样就可以把参数都搞到手了，我就可以随心的动态的改变参数。

第三步：好了，我第二步写完了，开始测试，奇怪的事情来了：

（1）@HystrixCommand 这个熔断器根本就没有执行，一点反应都没有

（2）更不用说 fallbackMethod了，fallback 当然也不会执行。

解决（1）很简单，你不知道的话就是一个坑，知道就很简单，小伙伴们想一想，拦截器？ 嗯！ 本质是拦截器，那好，把 @HystrixCommand 放到了私有方法上，能起到作用吗？ 我看看了自己的idea， 不对啊，我已经标志是public method了，为什么呢？ 因为@HystrixCommand加到了共有方法里面调用的方法上面（其实就是私有方法，拦截器是拦截不到的）。 所以解决办法就是将 @HystrixCommand 放到公有方法上面

那么当run的时候，立刻出现了（2）的问题。为什么？ exception： fallbackMethod 找不到。解决办法是：在fallbackMethod加上参数和@HystrixCommand 注解的那个方法参数必须一致！）

好了，我问题都解决了，需求也实现了，可以顺利的run一把了。但是当我访问https的时候，毫无疑问，证书出现问题了， exception类型都是ssl。那顺便说一下ssl是如何解决的， 我使用的是restTemplate，所以配置一下restTemplate 就没有问题了，具体的代码如下：

public static HttpClientinitSsl(){

/**defualt http client without ssl **/

    CloseableHttpClient httpclient = HttpClients.custom().build();

    Properties prop =new Properties();

    try {

/**load the properties **/

        prop.load(HttpSslUtil.class.getClassLoader().getResourceAsStream(HTTPS_SSL_PATH));

        KeyStore keyStore  = KeyStore.getInstance(KeyStore.getDefaultType());

        KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());

        File KeyFile  =new  File(HttpSslUtil.class.getClassLoader().getResource(prop.getProperty(KEY_CERT_PATH)).getFile());

        keyStore.load(new FileInputStream(KeyFile), prop.getProperty(KEY_STORE_PASS).toCharArray());

        File trustFile =new File(HttpSslUtil.class.getClassLoader().getResource(prop.getProperty(trust_CERT_PATH)).getFile());

        trustStore.load(new FileInputStream(trustFile), prop.getProperty(TRUST_STORE_PASS).toCharArray());

        SSLConnectionSocketFactory socketFactory =new SSLConnectionSocketFactory(

new SSLContextBuilder()

.loadTrustMaterial(trustStore, new TrustSelfSignedStrategy())

.loadKeyMaterial(keyStore, prop.getProperty(KEY_STORE_PASS).toCharArray())

.build(),

                NoopHostnameVerifier.INSTANCE);

        httpclient = HttpClients.custom().setSSLSocketFactory(socketFactory).build();

    }catch (Exception ex) {

log.error("ssl init failed, https does not support", ex);

    }

return httpclient;

}

好了，问题了解决了，下次介绍一下 springboot 的@Conditional On Properties, 如何根据@Conditional 自动装载不同的beans