Java中断路器的Hystrix配置

Question

public class HystrixCommandNextGen extends HystrixCommand<ScriptContext> {

    private ScriptContext scriptctx;
    private ScriptFactory scriptFactory;
    private ScriptContext responseContext = null;

    private Logger logger = LoggerFactory.getLogger(HystrixCommandNextGen.class);

    public HystrixCommandNextGen(ScriptContext scriptctx, ScriptFactory scriptFactory) {
        super(
            Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("Thread_Pool"))
            .andCommandKey(HystrixCommandKey.Factory.asKey(scriptctx.getExecutionData(ExecutionParam.SCRIPTNAME)))
        );
        this.scriptctx = scriptctx;
        this.scriptFactory = scriptFactory;

        HystrixCommandProperties.Setter().withCircuitBreakerEnabled(true);
        HystrixCommandProperties.Setter().withCircuitBreakerRequestVolumeThreshold(150);
    }

    @Override
    protected ScriptContext run() throws Exception {
        scriptFactory.execute(scriptctx);
        return scriptctx;
    }

    @Override
    protected ScriptContext getFallback() {
        logger.error("FI is not responding: Error occurred in the execution of " + getClass().getSimpleName());
        return scriptctx;
    }
}

Answer 1

Hystrix使用Archaius进行配置管理。Archaius库允许在运行时动态重新加载属性值。有关如何配置Archaius的文档如下：https://github.com/netflix/Archaius/wiki/users-guide

如果希望用代码配置Hystrix，可以使用Archaius ConfigurationManager类，如下所示：

ConfigurationManager.getConfigInstance().setProperty(
  "hystrix.command.HystrixCommandKey.execution.isolation.thread.timeoutInMilliseconds", 
  500);

请注意，属性名称字符串的HystrixCommandKey部分实际上是使用setter的.andCommandKey（）方法设置的断路器的名称。因此，如果将命令键设置为“mycommand”，超时的属性键实际上是“hystrix.command.mycommand.execution.isolation.thread.timeoutinmilliseconds”