Spring Hystrix未在内部方法上触发

Question

我正在尝试将Hystrix断路器包含在一个spring boot应用程序中。我的应用程序是一个标准的spring boot 1.4.1，带有spring-cloud-hystrix v1.2.0应用程序，其中有一个控制器类，它用一个“聚合”方法调用一个服务类。此方法使用内部私有方法在内部调用两个服务。

这是我的服务类：

@Service
public class AggregationService {

    @Autowired
    Service1 service1Client;

    @Autowired
    Service2 service2Client;

    private static final String QUERY = "query";
    private static final Logger log = LogManager.getLogger();
    private final ObjectMapper objectMapper = new ObjectMapper();

    //@HystrixCommand(
    //    fallbackMethod = "emptyResult",
    //    groupKey = "aggregation-service",
    //    commandKey = "aggregate")
    public AggregationResponse aggregate(final AggregationParams params)
            throws ApiException, IOException {

        final String query = queryExplain(params);
        final WrapperQueryBuilder wrappedQuery = QueryBuilders.wrapperQuery(query);
        final SearchResponse aggregationResult = searchAggregation(params, wrappedQuery);

        return toDtoResponse(aggregationResult.getAggregations().get(params.getAggregationField().name().toLowerCase()));
    }

    @HystrixCommand(
        fallbackMethod = "emptyAggregationResult",
        groupKey = "aggregation-service",
        commandKey = "searchAggregation")
    private SearchResponse searchAggregation(final AggregationParams params, final WrapperQueryBuilder query) {

        return ... do something with service 2 ....
    }

    //    @HystrixCommand(
    //        fallbackMethod = "rethrowTimeoutException",
    //        groupKey = "aggregation-service",
    //        commandKey = "query-for-aggregation",
    //        ignoreExceptions = TimeoutException.class)
    private String queryExplain(final AggregationParams params) throws ApiException, IOException {
        final String queryAsString = ... do something with service 1 ....
    }

    private String rethrowTimeoutException(final AggregationParams params, final Throwable e) {
        log.error("On Hystrix fallback because of ", e);
        return null;
    }

    private SearchResponse emptyAggregationResult(final AggregationParams params, final WrapperQueryBuilder query, final Throwable e) {
        log.error("On Hystrix fallback because of ", e);
        return null;
    }

}

我的控制器方法是：

 @GetMapping("{field}")
    @ResponseStatus(HttpStatus.OK)
    public AggregationResponse aggregate(... some params ...) throws ApiException, IOException {

... omissis ....

        return aggregationService.aggregate(params);

我的配置类有以下注释：

@Configuration
@EnableHystrix

hystrix.command.searchAggregation.execution.isolation.thread.timeoutInMilliseconds=1
hystrix.command.searchAggregation.circuitBreaker.errorThresholdPercentage=10
hystrix.command.queryExplain.execution.isolation.thread.timeoutInMilliseconds=1
hystrix.command.queryExplain.circuitBreaker.errorThresholdPercentage=10
hystrix.command.default.execution.timeout.enabled=true

Answer 1

Javanica使用HystrixCommandAspect方面来检测用HystrixCommand注释注释的方法，并且定义的切入点似乎只影响公共方法。

更新：有一个与此特定问题相关的bug报告。