sentinel使用方式求助（并发访问时熔断规则失效？）

[ChengHoHang]

Hi Sentinel Team.

问题描述

并发访问同一资源时达到熔断状态，但下一次请求时并没有熔断，测试代码如下所示

        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // 创建熔断规则，具体参数如下
        DegradeRule degradeRule = new DegradeRule("test")
                .setGrade(RuleConstant.DEGRADE_GRADE_RT)
                .setCount(10)                       // 慢调用临界RT，10ms
                .setTimeWindow(10)           // 熔断时长  10s
                .setMinRequestAmount(3)  // 最小请求数3，若窗口内统计超过 SlowRatioThreshold * 3个请求则进入熔断窗口10s
                .setStatIntervalMs(5000)      // 慢调用统计时长时间窗口   5s
                .setSlowRatioThreshold(1);  // 慢调用比例
        DegradeRuleManager.loadRules(Collections.singletonList(degradeRule));

       // 3个请求都超时，这时应该触发熔断了
        for (int i = 0; i < 3; i++) {
            Sleeper task = new Sleeper(20);
            executorService.submit(task);
        }

        // wait slow-task done
        Thread.sleep(50);

        // should be blocked
        Sleeper sleeper = new Sleeper(20);

        // 实际报错了，sleeper能拿到sph
        Assert.assertFalse(sleeper.call());

sleeper 内部实现

    @AllArgsConstructor
    public static class Sleeper implements Callable<Boolean> {

        private int sleepMills;

        @Override
        public Boolean call() throws Exception {
            Entry entry = null;
            try {
                entry = SphU.entry("test");
                Thread.sleep(sleepMills);
                return true;
            } catch (BlockException e) {
                log.error("", e);
                return false;
            } finally {
                if (entry != null) {
                    entry.exit();
                }
            }
        }
    }

---

如果sleeper串行访问，那又没问题，下面的单元测试跟sentinel的单测逻辑差不多com.alibaba.csp.sentinel.slots.block.degrade.circuitbreaker.ResponseTimeCircuitBreakerTest#testMaxSlowRatioThreshold

        DegradeRule degradeRule = new DegradeRule("test")
                .setGrade(RuleConstant.DEGRADE_GRADE_RT)
                .setCount(10)
                .setTimeWindow(10)
                .setMinRequestAmount(3)
                .setStatIntervalMs(5000)
                .setSlowRatioThreshold(1);
        DegradeRuleManager.loadRules(Collections.singletonList(degradeRule));

        for (int i = 0; i < 3; i++) {
            new Sleeper(20).call();
        }

        // wait slow-task done
        Thread.sleep(50);

       // 串行调用后，下一次调用就block
        Sleeper sleeper = new Sleeper(20);
        Assert.assertFalse(sleeper.call());

麻烦大佬看下，是我的使用方式有问题还是其他原因导致的，thanks

[sczyh30]

可以持续跑一下 demo 哈，并发初次访问时效果会有延迟

[ChengHoHang]

再多问一句，延迟时间大概是跟什么相关的？
实际在生产环境遇到个情况，有少数方法调用时长达到60s，是因为获取db连接超时，在60s后才会释放资源entry.exit

会不会是因为释放资源操作并没有在滑动窗口内被调用（统计），从而sentinel并不能判断该资源实际需要被熔断呢