Dubbo sentinel 哨兵熔断慢调用比例、异常比例、异常数

news2024/9/20 11:01:07

熔断报这个错误在调用程序中检测即可

页面配置熔断，配置在 consumer 消费端

慢调用比例规则

最大rt

比例阈值

熔断时长

最小请求数

统计时长

让流量一直降低发送

异常数量

设置30个异常数

Tps 异常数量未达到30个正常运行

设置1个效果直接连续熔断降级，所以最好设置大点，要不就用其他俩个，或根据业务好好分析下，这属于断的老彻底了

异常比例

设置比例

日志

结论

设置更具熔断比例如果异常比例未达到80% 继续正常发送

熔断报这个错误在调用程序中检测即可

SentinelBlockException: DegradeException

consumer 示例代码

package com.example;


import com.example.demo.dubbo.api.DemoService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.stereotype.Component;

import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

@SpringBootApplication
@EnableDubbo
public class Consumer {
    public static void main(String[] args) {
        SpringApplication.run(Consumer.class, args);
    }

    @Component
    static class DemoTask implements CommandLineRunner {
        private static final Logger logger = LoggerFactory.getLogger(DemoTask.class);

        @DubboReference
        private DemoService demoService;
        int cc = 0;
        @Override
        public void run(String... args) {
            Executors.newScheduledThreadPool(1)
                    .scheduleAtFixedRate(() -> {
                        logger.info("Start to call remote.");
                        for (int i = 0; i < 15; i++) {
                            try {
                                String result = demoService.sayHello("dubbo" +(++cc));
                                logger.info(cc+" Call Count:" + i + " Dubbo Remote Return ======> " + result);
                            } catch (RuntimeException ex) {
                                if (ex.getMessage().contains("SentinelBlockException: FlowException")) {
                                    logger.info(cc+" Call Count:" + i + " 已限流");
                                }else if (ex.getMessage().contains("SentinelBlockException: DegradeException")) {
                                    logger.info(cc+" Call Count:" + i + " 已降级");
                                } else {
                                    logger.error(cc+" Call Count:" + i + " Request Failed.", ex);
                                }
                            }
                        }
                    }, 0, 1000, TimeUnit.MILLISECONDS);
        }

    }
}

相关连续性章节在通分类博客下