Hystrix原理之核心类HystrixCommandAspect

上一篇文章介绍了HystrixCommand。除了@HystrixCommand。还有一个@HystrixCollapser的注解用于请求合并操作，但是需要与@HystrixCommand`结合使用，如下的例子：

@HystrixCollapser(batchMethod = "getInstanceBuServiceIds")
public Future<Instance> getInstanceByServiceIds(String serviceId) {
	return null;
}
    
@HystrixCommand
public List<Instance> getInstanceBuServiceIds(List<String> serviceIds){
 	List<Instance> instances = new ArrayList<>();
        
 	for(String s : serviceIds){
  		instances.add(new Instance(s, DEFAULT_HOST, DEFAULT_PORT));
  	}
	return instances;
}

请注意，批量操作的方法必须被@HystrixCommand注解。

HystrixCommandAspect

被注解的方法将会被HystrixCommand包装执行，在Hystrix中通过aspectj切面的方式来将注解的方法进行封装调用的。

//HystrixCommandAspect

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

public void hystrixCommandAnnotationPointcut() {
}

@Pointcut("@annotation(com.netflix.hystrix.contrib.javanica.annotation.HystrixCollapser)")
public void hystrixCollapserAnnotationPointcut() {
}

@Around("hystrixCommandAnnotationPointcut() || hystrixCollapserAnnotationPointcut()")
public Object methodsAnnotatedWithHystrixCommand(final ProceedingJoinPoint joinPoint) throws Throwable {
	...
  	// 通过工厂的方式构建metaHolder
  	MetaHolderFactory metaHolderFactory = META_HOLDER_FACTORY_MAP.get(HystrixPointcutType.of(method));
  	MetaHolder metaHolder = metaHolderFactory.create(joinPoint); //1
  	HystrixInvokable invokable = HystrixCommandFactory.getInstance().create(metaHolder);
  	ExecutionType executionType = metaHolder.isCollapserAnnotationPresent() ?
        	metaHolder.getCollapserExecutionType() : metaHolder.getExecutionType();

  	Object result;
   	try {
     	if (!metaHolder.isObservable()) {
    		result = CommandExecutor.execute(invokable, executionType, metaHolder);
      	} else {
         	result = executeObservable(invokable, executionType, metaHolder);
     	}
  	} catch (HystrixBadRequestException e) {
   		throw e.getCause() != null ? e.getCause() : e;
 	} catch (HystrixRuntimeException e) {
    	throw hystrixRuntimeExceptionToThrowable(metaHolder, e);
  	}
  	return result;
}

上面的代码主要具备如下的过程：

1. 通过MetaHolderFactory构建出被注解方法中用于构建HystrixCommand的所需要的必要信息集合类MetaHolder；
2. 根据MetaHolder通过HystrixCommandFactory构建出合适的HystrixCommand；
3. 委托CommandExecutor执行HystrixCommand，得到结果。