2. 程式人生 > >sentinel之三種熔斷降級情況的驗證

sentinel之三種熔斷降級情況的驗證

阿新 • • 發佈：2019-01-03

熔斷降級是指當資源處於不穩定的情況下，在接下來的時間視窗之內，對該資源的呼叫都自動熔斷（預設行為是丟擲DegradeException）。
通常用三種方式來衡量資源是否處於穩定的狀態：

  • 平均響應時間 (DEGRADE_GRADE_RT)：當資源的平均響應時間超過閾值（DegradeRule 中的 count，以 ms 為單位）之後，資源進入準降級狀態。接下來如果持續進入 5 個請求，它們的 RT 都持續超過這個閾值，那麼在接下的時間視窗（DegradeRule 中的 timeWindow，以 s 為單位）之內，對這個方法的呼叫都會自動地返回（丟擲 DegradeException）。

  • 異常比例 (DEGRADE_GRADE_EXCEPTION_RATIO)：當資源的每秒異常總數佔通過量的比值超過閾值（DegradeRule 中的 count）之後，資源進入降級狀態，即在接下的時間視窗（DegradeRule 中的 timeWindow，以 s 為單位）之內，對這個方法的呼叫都會自動地返回。異常比率的閾值範圍是 [0.0, 1.0]，代表 0% - 100%。

  • 異常數 (DEGRADE_GRADE_EXCEPTION_COUNT)：當資源近 1 分鐘的異常數目超過閾值之後會進行熔斷。

注意：為了統計異常比例或異常數，需要通過 Tracer.trace(ex) 記錄業務異常。


下面對這三種情況做簡單的驗證

  • 匯入Maven依賴
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-core</artifactId>
    <version>1.3.0-GA</version>
</dependency>

點選這裡可查詢最新的sentinel-core版本
1、驗證平均響應時間

import com.alibaba.csp.sentinel.Entry;
 

import com.alibaba.csp.sentinel.SphU;
import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;
import com.alibaba.csp.sentinel.util.TimeUtil;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * 降級是在資源處於不穩定狀態時使用的，這些資源將在下一個定義的時間視窗內降級。
 * 有三種方法衡量資源是否穩定:
 * 平均響應時間 (DEGRADE_GRADE_RT)：當資源的平均響應時間超過閾值（DegradeRule 中的 count，以 ms 為單位）之後，
 * 資源進入準降級狀態。接下來如果持續進入 5 個請求，它們的 RT 都持續超過這個閾值，
 * 那麼在接下的時間視窗（DegradeRule 中的 timeWindow，以 s 為單位）之內，
 * 對這個方法的呼叫都會自動地返回（丟擲 DegradeException）
 * **異常比率，見 {@link ExceptionRatioDegradeDemo}.
 * **異常統計，見 {@link ExceptionCountDegradeDemo}.
 */
public class RtDegradeDemo {

    private static final String KEY = "平均響應時間";

    private static AtomicInteger pass = new AtomicInteger();
    private static AtomicInteger block = new AtomicInteger();
    private static AtomicInteger total = new AtomicInteger();

    private static volatile boolean stop = false;
    private static final int threadCount = 100;
    private static int seconds = 60;

    public static void main(String[] args) throws Exception {
        tick();
        initDegradeRule();// 設定資源降級規則

        for (int i = 0; i < threadCount; i++) {
            Thread entryThread = new Thread(new Runnable() {
                int j = 0;

                @Override
                public void run() {
                    while (true) {
                        Entry entry = null;
                        try {
                            TimeUnit.MILLISECONDS.sleep(5);
                            entry = SphU.entry(KEY);
                            // 令牌已獲得
                            pass.incrementAndGet();// 先+1,然後在返回值,相當於++i
                            // sleep 600 ms, as rt
                            TimeUnit.MILLISECONDS.sleep(600);
                        } catch (Exception e) {
                            // System.out.println("異常:"+e);
                            // 降級計數
                            block.incrementAndGet();// 先+1,然後在返回值,相當於++i
                        } finally {
                            // 記錄總數
                            total.incrementAndGet();// 先+1,然後在返回值,相當於++i
                            if (entry != null) {
                                entry.exit();
                            }
                        }
                    }
                }

            });
            entryThread.setName("working-thread");
            entryThread.start();
        }
    }

    /**
     * 當資源的平均響應時間超過閾值（DegradeRule 中的 count，以 ms 為單位）之後，資源進入準降級狀態。
     * 接下來如果持續進入 5 個請求，它們的 RT 都持續超過這個閾值，
     * 那麼在接下的時間視窗（DegradeRule 中的 timeWindow，以 s 為單位）之內，
     * 對這個方法的呼叫都會自動地返回（丟擲 DegradeException）。
     */
    private static void initDegradeRule() {
        List<DegradeRule> rules = new ArrayList<DegradeRule>();
        DegradeRule rule = new DegradeRule();
        rule.setResource(KEY);// 設定資源名，資源名是限流規則的作用物件
        rule.setCount(10);// 設定平均響應時間閾值為10ms
        rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);// 設定降級模式，根據平均響應時間降級
        rule.setTimeWindow(10);// 設定降級的時間，以s為單位
        rules.add(rule);
        DegradeRuleManager.loadRules(rules);
    }

    private static void tick() {
        Thread timer = new Thread(new TimerTask());
        timer.setName("sentinel-timer-task");
        timer.start();
    }

    static class TimerTask implements Runnable {
        @Override
        public void run() {
            long start = System.currentTimeMillis();
            System.out.println("統計開始......");
            long oldTotal = 0;
            long oldPass = 0;
            long oldBlock = 0;

            SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String nowTime = "";

            while (!stop) {
                try {
                    TimeUnit.SECONDS.sleep(1);
                } catch (InterruptedException e) {
                }

                long globalTotal = total.get();
                long oneSecondTotal = globalTotal - oldTotal;
                oldTotal = globalTotal;

                long globalPass = pass.get();
                long oneSecondPass = globalPass - oldPass;
                oldPass = globalPass;

                long globalBlock = block.get();
                long oneSecondBlock = globalBlock - oldBlock;
                oldBlock = globalBlock;

                nowTime = formatter.format(new java.util.Date(TimeUtil.currentTimeMillis()));
                System.out.println(nowTime + ", total:" + oneSecondTotal + ", pass:" + oneSecondPass + ", block:" + oneSecondBlock);

                if (seconds-- <= 0) {
                    stop = true;
                }
            }

            long cost = System.currentTimeMillis() - start;
            System.out.println("耗時:" + cost + " ms");
            System.out.println("總計數:" + total.get() + ", 通過數:" + pass.get() + ", 降級數:" + block.get());
            System.out.println("統計結束！");
            System.exit(0);
        }
    }

}

執行結果如下：

統計開始......
2018-12-10 16:42:26, total:2387, pass:104, block:2288
2018-12-10 16:42:27, total:15446, pass:0, block:15442
2018-12-10 16:42:28, total:17507, pass:0, block:17506
2018-12-10 16:42:29, total:17939, pass:0, block:17940
2018-12-10 16:42:30, total:17731, pass:0, block:17730
2018-12-10 16:42:31, total:17800, pass:0, block:17800
2018-12-10 16:42:32, total:17973, pass:0, block:17975
2018-12-10 16:42:33, total:17814, pass:0, block:17812
2018-12-10 16:42:34, total:18000, pass:0, block:18000
2018-12-10 16:42:35, total:17832, pass:0, block:17832
2018-12-10 16:42:36, total:14944, pass:100, block:14944
2018-12-10 16:42:37, total:9700, pass:4, block:9600
2018-12-10 16:42:38, total:18063, pass:0, block:18059
2018-12-10 16:42:39, total:17828, pass:0, block:17828
2018-12-10 16:42:40, total:18000, pass:0, block:18000
2018-12-10 16:42:41, total:17800, pass:0, block:17800
2018-12-10 16:42:42, total:17900, pass:0, block:17900
2018-12-10 16:42:43, total:17800, pass:0, block:17800
2018-12-10 16:42:44, total:17890, pass:0, block:17890
2018-12-10 16:42:45, total:17908, pass:0, block:17908
2018-12-10 16:42:46, total:17868, pass:0, block:17871
2018-12-10 16:42:47, total:7830, pass:100, block:7827
2018-12-10 16:42:48, total:16856, pass:4, block:16752
2018-12-10 16:42:49, total:17963, pass:0, block:17965
2018-12-10 16:42:50, total:17541, pass:0, block:17539
2018-12-10 16:42:51, total:17600, pass:0, block:17600
2018-12-10 16:42:52, total:17770, pass:0, block:17770
2018-12-10 16:42:53, total:17400, pass:0, block:17400
2018-12-10 16:42:54, total:17753, pass:0, block:17755
2018-12-10 16:42:55, total:17642, pass:0, block:17640
2018-12-10 16:42:56, total:17796, pass:0, block:17796
2018-12-10 16:42:57, total:17884, pass:0, block:17887
2018-12-10 16:42:58, total:6872, pass:104, block:6769
2018-12-10 16:42:59, total:17720, pass:0, block:17716
2018-12-10 16:43:00, total:17889, pass:0, block:17892
2018-12-10 16:43:01, total:17611, pass:0, block:17608
2018-12-10 16:43:02, total:17851, pass:0, block:17851
2018-12-10 16:43:03, total:17900, pass:0, block:17900
2018-12-10 16:43:04, total:17800, pass:0, block:17800
2018-12-10 16:43:05, total:17800, pass:0, block:17800
2018-12-10 16:43:06, total:17900, pass:0, block:17900
2018-12-10 16:43:07, total:17800, pass:0, block:17800
2018-12-10 16:43:08, total:11600, pass:100, block:11600
2018-12-10 16:43:09, total:12876, pass:4, block:12772
2018-12-10 16:43:10, total:17896, pass:0, block:17896
2018-12-10 16:43:11, total:17981, pass:0, block:17983
2018-12-10 16:43:12, total:17819, pass:0, block:17817
2018-12-10 16:43:13, total:17800, pass:0, block:17800
2018-12-10 16:43:14, total:17976, pass:0, block:17977
2018-12-10 16:43:15, total:17707, pass:0, block:17708
2018-12-10 16:43:16, total:17881, pass:0, block:17883
2018-12-10 16:43:17, total:17832, pass:0, block:17828
2018-12-10 16:43:18, total:17900, pass:0, block:17900
2018-12-10 16:43:19, total:6974, pass:104, block:6892
2018-12-10 16:43:20, total:17497, pass:0, block:17476
2018-12-10 16:43:21, total:17666, pass:0, block:17665
2018-12-10 16:43:22, total:18000, pass:0, block:18000
2018-12-10 16:43:23, total:17900, pass:0, block:17900
2018-12-10 16:43:24, total:17800, pass:0, block:17800
2018-12-10 16:43:25, total:17894, pass:0, block:17894
2018-12-10 16:43:26, total:17765, pass:0, block:17765
耗時:61080 ms
總計數:1014072, 通過數:624, 降級數:1013448
統計結束！

Process finished with exit code 0

2、驗證異常比例

import com.alibaba.csp.sentinel.Entry;
import com.alibaba.csp.sentinel.SphU;
import com.alibaba.csp.sentinel.Tracer;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;
import com.alibaba.csp.sentinel.util.TimeUtil;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * 降級是在資源處於不穩定狀態時使用的，這些資源將在下一個定義的時間視窗內降級。
 * 有三種方法衡量資源是否穩定:
 * 異常比率:當異常計數/秒與成功的比率qps大於或等於閾值時，對資源的訪問將被阻塞在即將到來的時間視窗。
 * **異常統計，見 {@link ExceptionCountDegradeDemo}.
 * **平均響應時間, 見 {@link RtDegradeDemo}.
 */
public class ExceptionRatioDegradeDemo {
    private static final String KEY = "異常比率";

    private static AtomicInteger total = new AtomicInteger();
    private static AtomicInteger pass = new AtomicInteger();
    private static AtomicInteger block = new AtomicInteger();
    private static AtomicInteger bizException = new AtomicInteger();

    private static volatile boolean stop = false;
    private static final int threadCount = 1;
    private static int seconds = 60 + 40;

    public static void main(String[] args) throws Exception {
        tick();
        initDegradeRule();// 設定資源降級規則

        for (int i = 0; i < threadCount; i++) {
            Thread entryThread = new Thread(new Runnable() {
                @Override
                public void run() {
                    int count = 0;
                    while (true) {
                        count++;
                        Entry entry = null;
                        try {
                            Thread.sleep(20);
                            entry = SphU.entry(KEY);
                            // 獲得令牌表示通過
                            pass.addAndGet(1);// 先+n,然後在返回值
                            if (count % 2 == 0) {
                                // 業務程式碼引發異常
                                throw new RuntimeException("throw runtime exception");
                            }
                        } catch (BlockException e) {
                            // 降級計數
                            block.addAndGet(1);// 先+n,然後在返回值
                        } catch (Throwable t) {
                            // 記錄業務異常
                            bizException.incrementAndGet();// 先+1,然後在返回值,相當於++i
                            // 為了統計異常比例或異常數，需要通過 Tracer.trace(ex) 記錄業務異常。
                            Tracer.trace(t);
                        } finally {
                            // 記錄總數
                            total.addAndGet(1);// 先+n,然後在返回值
                            if (entry != null) {
                                entry.exit();
                            }
                        }
                    }
                }

            });
            entryThread.setName("working-thread");
            entryThread.start();
        }

    }

    /**
     * 當資源的每秒異常總數佔通過量的比值超過閾值（DegradeRule 中的 count）之後，
     * 資源進入降級狀態，即在接下的時間視窗（DegradeRule 中的 timeWindow，以 s 為單位）之內，對這個方法的呼叫都會自動地返回。
     * 異常比率的閾值範圍是 [0.0, 1.0]，代表 0% - 100%。
     */
    private static void initDegradeRule() {
        List<DegradeRule> rules = new ArrayList<DegradeRule>();
        DegradeRule rule = new DegradeRule();
        rule.setResource(KEY);// 設定資源名，資源名是限流規則的作用物件
        // 將限制異常比率設定為0.1
        rule.setCount(0.5);// 異常比率的閾值範圍是 [0.0, 1.0]，代表 0% - 100%。
        rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);// 設定降級模式，根據異常比率降級
        rule.setTimeWindow(10);// 設定降級的時間，以s為單位
        rules.add(rule);
        DegradeRuleManager.loadRules(rules);
    }

    private static void tick() {
        Thread timer = new Thread(new TimerTask());
        timer.setName("sentinel-timer-task");
        timer.start();
    }

    static class TimerTask implements Runnable {
        @Override
        public void run() {
            long start = System.currentTimeMillis();
            System.out.println("統計開始......");
            long oldTotal = 0;
            long oldPass = 0;
            long oldBlock = 0;
            long oldBizException = 0;

            SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String nowTime = "";

            while (!stop) {
                try {
                    TimeUnit.SECONDS.sleep(1);
                } catch (InterruptedException e) {
                }
                long globalTotal = total.get();
                long oneSecondTotal = globalTotal - oldTotal;
                oldTotal = globalTotal;

                long globalPass = pass.get();
                long oneSecondPass = globalPass - oldPass;
                oldPass = globalPass;

                long globalBlock = block.get();
                long oneSecondBlock = globalBlock - oldBlock;
                oldBlock = globalBlock;

                long globalBizException = bizException.get();
                long oneSecondBizException = globalBizException - oldBizException;
                oldBizException = globalBizException;

                nowTime = formatter.format(new java.util.Date(TimeUtil.currentTimeMillis()));
                System.out.println(nowTime + ", oneSecondTotal:" + oneSecondTotal
                        + ", oneSecondPass:" + oneSecondPass
                        + ", oneSecondBlock:" + oneSecondBlock
                        + ", oneSecondBizException:" + oneSecondBizException);
                if (seconds-- <= 0) {
                    stop = true;
                }
            }
            long cost = System.currentTimeMillis() - start;
            System.out.println("耗時:" + cost + " ms");
            System.out.println("總計數:" + total.get() + ", 通過數:" + pass.get()
                    + ", 降級數:" + block.get() + ", 業務異常數:" + bizException.get());
            System.out.println("統計結束！");
            System.exit(0);
        }
    }
}

執行結果如下：

統計開始......
2018-12-10 17:02:04, oneSecondTotal:37, oneSecondPass

相關推薦

sentinel之三種熔斷降級情況的驗證

熔斷降級是指當資源處於不穩定的情況下，在接下來的時間視窗之內，對該資源的呼叫都自動熔斷（預設行為是丟擲DegradeException）。 通常用三種方式來衡量資源是否處於穩定的狀態： 平均響應時間 (DEGRADE_GRADE_RT)：當資源的平均響應時間超過閾值（Degra

Hystrix之四種觸發fallback情況的驗證

使用Hystrix時，下面的情況會觸發fallback： 非HystrixBadRequestException異常：當丟擲HystrixBadRequestException時，呼叫程式可以捕獲異常，此時不會觸發fallback，而其他異常則會觸發fallback，呼叫程式將獲

sentinel流量控制和熔斷降級執行流程之原始碼分析

前言： 　sentinel是阿里針對服務流量控制、熔斷降級的框架，如何使用官方都有很詳細的文件，下載它的原始碼包 裡面對各大主流框都做了適配按理，本系列文章目的 主要通過原始碼分析sentinel流量控制和熔斷降級的流程 提前準備好sentinel控制檯 如有下載原始碼啟動sentinel dashboard

圖像處理之三種常見雙立方插值算法

log views 實現 ack oar 過程 線表 const filter http://blog.csdn.net/jia20003/article/details/40020775 圖像處理之三種常見雙立方插值算法 雙立方插值計算涉及到16個像素點，其中(i’, j

SQL Server 基本操作之三種增加法

一次 增刪改查 sql 數據的操作 插入 table 增長 類型 val 前言：　　 　　數據庫操作避免不了對數據的操作，操作方法大同小異，萬變不離其宗，今就寫一下各種花式操作的根本增刪改查四種操作,今天我們就來說一下增加操作的三種方法 正文： 　　增加操作是對數據庫進

JavaScript中BOOLEAN類型之三種情景代碼舉例

flag art 代碼 解讀 track .org lan 對象 alert <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w

集合框架之三種叠代的能否刪除

-- 16px size ren 中修改 exce .get rem cat 一:普通for循環的刪除 1 // 普通for循環,通過索引刪除,刪除後索引要-- 2 for (int i = 0; i < list.size(); i++) { 3

picturebox加載圖片的三種方法與網站驗證碼的抓取

地址 ins 狀態機 加載 put itl title eof ner 第一種：（此方法比較笨） 在頁面上隱藏幾個需要改變頁面上圖片的picturebox，比如下面的picFrom 在需要改變圖片的方法處先定義： System.Resources.ResourceMa

Mybatis逆向工程之三種實現方法

ntb roo obj tar ges detail 是否 href rip 1.逆向工程之原始方法 （1）下載兩個jar包：mysql-connector-java（6.x版本及以上的和5.x版本有所區別，主要是驅動和時區；詳情參見：https://blog.csdn.n

Java Web面試之三種實現Servlet方式

/*** * servlet是執行在伺服器端的一個Java程式: * 1.對請求做出相應的迴應 * 2.動態的生成html頁面 * * servlet的多種實現方式： * 1.實現Javax.servlet介面(實現5個抽象方法–一般只需要重寫service) * 2.繼承抽象類Generi

C之三種常用迴圈：while迴圈、do...while迴圈、for迴圈

**《戰國策·燕策二》：“此必令其言如迴圈，用兵如刺蜚繡。”往復迴旋。指事物周而復始地運動或變化。意思是轉了一圈又一圈，一次又一次地循回。**迴圈 ，是C語言程式設計裡非常重要的結構。使用迴圈，可以幫我們快速解決類似的、需要重複實現、處理的問題。以下分享學習C語言三種常見迴圈：while迴圈

Python C/S 網路程式設計（一）之 三種方法實現天氣預報小程式

1. 首先明白下協議棧和庫的概念： 協議棧（Protocol Stack）: 是指網路中各層協議的總和，其形象的反映了一個網路中檔案傳輸的過程：由上層協議到底層協議，再由底層協議到上層協議。 庫（Library）:主要用來解析要使用的網路通訊協議，包含Python內建標準庫

自定義progress之三種風格的圖片載入進度樣式

效果圖： 自定義CircleProgressView： public class CircleProgressView extends ProgressBar { private int mReachBarSize = DisplayUtil.dip2

Autofac學習之三種生命週期：InstancePerLifetimeScope、SingleInstance、InstancePerDependency

InstancePerLifetimeScope：同一個Lifetime生成的物件是同一個例項 SingleInstance：單例模式，每次呼叫，都會使用同一個例項化的物件；每次都用同一個物件； InstancePerDependency：預設模式，每次呼叫，都會重新

迴圈結構之三種迴圈比較

在迴圈次數的情況下更適合使用for迴圈 在不知道迴圈次數的情況下適合使用while或者do-while迴圈，如果有可能一次都不迴圈應考慮使用while迴圈，如果至少迴圈一次應考慮使用do-while迴圈 本質上，while，do-while和for迴圈之間是可

好玩的API呼叫之---三種翻譯API呼叫

好玩的API呼叫之—三種翻譯API呼叫 平時寫程式經常需要用到一些服務，像翻譯，天氣預報，星座什麼的，我一般都是用Python寫個爬蟲去提供這些服務的網站爬資料，但是有些網站對爬蟲有很多限制，一些關鍵字會定時更改，就像中國天氣網經常變更HTML標籤的cla

Java設計模式之三種工廠模式 -- 總是忘記，這次把你記下來！

}   interfaceIProduct1 {   public void show(); } interfaceIProduct2 {   public void show(); } classProduct1 implements IProduct1 {   public void show() {

Android之三種網路請求解析資料

一：AsyncTask解析資料 AsyncTask主要用來更新UI執行緒，比較耗時的操作可以在AsyncTask中使用。 AsyncTask是個抽象類，使用時需要繼承這個類，然後呼叫execute()方法。注意繼承時需要設定三個泛型Params，P

《Python網路爬蟲之三種資料解析方式？

引入 回顧requests實現資料爬取的流程 指定url 基於requests模組發起請求 獲取響應物件中的資料 進行持久化儲存 其實，在上述流程中還需要較為重要的一步，就是在持久化儲存之前需要進行指定資料解析。因

05.Python網路爬蟲之三種資料解析方式

一、正則解析   二、Xpath解析 -->   測試頁面資料 1 <html lang="en"> 2 <head> 3 <meta charset="UTF-8" /> 4 <