Hystrix CircuitBreakerSleepWindowInMilliseconds未按预期工作问题咨询

嘿，我帮你把这段Hystrix命令类的代码整理成规范格式，同时修正了里面的小错误，方便你测试和查看：

整理后的Hystrix命令类代码 #

public class CommandOne extends HystrixCommand<String> {
    private MyExternalService service;
    public static int runCount = 0;

    // 修正：构造函数名称与类名保持一致，同时修正拼写错误MyExternalServoce -> MyExternalService
    public CommandOne(MyExternalService service) {
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("AAA"))
                .andThreadPoolPropertiesDefaults(
                        HystrixThreadPoolProperties.Setter()
                                .withMetricsRollingStatisticalWindowInMilliseconds(10000))
                // 原代码的"andC..."应该是后续命令属性配置，这里补充了常见的断路器规则示例
                .andCommandPropertiesDefaults(
                        HystrixCommandProperties.Setter()
                                .withCircuitBreakerErrorThresholdPercentage(50)
                                .withCircuitBreakerRequestVolumeThreshold(20)));
        this.service = service;
    }

    @Override
    protected String run() throws Exception {
        runCount++;
        // 调用外部服务的业务逻辑
        return service.someMethod();
    }

    // 可选：实现降级方法，断路器打开时会执行此逻辑
    @Override
    protected String getFallback() {
        return "Fallback response from CommandOne";
    }
}

关键说明 #

• 构造函数修正：原代码里构造函数名称和类名不匹配，还存在MyExternalServoce的拼写错误，已经统一修正
• 线程池统计配置：withMetricsRollingStatisticalWindowInMilliseconds(10000)设置了线程池指标的滚动统计窗口为10秒，Hystrix会在这个周期内收集线程池的使用数据
• 静态计数runCount：可以用来统计命令的执行次数，测试时能通过这个值快速判断断路器是否触发（比如断路器打开后，runCount会停止增长，转而执行降级逻辑）
• 补充断路器规则：原代码未写完的andC...部分，我补充了常见的断路器触发阈值配置——当10秒内请求数≥20，且失败率达到50%时，断路器会打开，你可以根据测试需求调整这些参数

内容的提问来源于stack exchange，提问作者Sviatlana