主頁 > 軟體設計 > 微服務架構 | 5.1 使用 Netflix Hystrix 斷路器

微服務架構 | 5.1 使用 Netflix Hystrix 斷路器

2022-01-30 07:42:21 軟體設計

目錄
  • 前言
  • 1. Hystrix 基礎知識
    • 1.1 Hystrix 斷路器強調呼叫
    • 1.2 兩大類別的 Hystrix 實作
    • 1.3 艙壁策略
    • 1.4 Hystrix 在遠程資源呼叫失敗時的決策程序
    • 1.5 當 Hystrix 斷路器打開后
    • 1.6 Hystrix 的所有配置
  • 2. 對服務使用 Hystrix 斷路器
    • 2.1 引入 pom.xml 依賴
    • 2.2 修改 bootstrap.yml 組態檔
    • 2.3 在主程式類上標注注解
    • 2.4 在業務類上使用 ＠HystrixCommand 注解（斷路器模式）
    • 2.5 定制斷路器（后備策略、艙壁策略）
    • 2.6 使用類級注解統一 Hystrix 配置
  • 3. 使用 HystrixConcurrencyStrategy 聯系執行緒背景關系
    • 3.1 Hystrix 的背景關系隔離
    • 3.2 自定義 Hystrix 井發策略類
    • 3.3 定義一個 Java Callable 類，將 UserContext 注入 Hystrix 命令中
    • 3.4 配置 Spring Cloud 以使用自定義 Hystrix 井發策略
  • 4. 使用 hystrixDashboard 實作服務監控
    • 4.1 引入 pom.xml 依賴
    • 4.2 修改 application.yml 組態檔
    • 4.3 在主程式類上標注注解
    • 4.4 配置被監控的服務
      • 1. 添加 pom.xml 依賴檔案
      • 2. 在主啟動類中指定監控路徑
    • 4.5 訪問圖形化界面
    • 4.6 查看監控圖
  • 最后

前言

參考資料：
《Spring Microservices in Action》
《Spring Cloud Alibaba 微服務原理與實戰》
《B站 尚硅谷 SpringCloud 框架開發教程 周陽》

Hystrix 是一個延遲和容災庫，旨在隔離遠程系統、服務和第三方庫的訪問點，停止級聯故障，并在故障不可避免的復雜分布式系統中實作彈性；

1. Hystrix 基礎知識

1.1 Hystrix 斷路器強調呼叫

  • Hystrix 斷路器沒有提供者與消費者的區別，它強調的是服務與資源之間的中間人，如：服務請求資料庫與服務內部呼叫；
  • 因此在服務消費者與服務提供者里，凡是涉及資料庫訪問與服務間呼叫都可以使用 Hystrix 斷路器；
  • 構建斷路器模式、后備模式和艙壁模式的實作需要對執行緒和執行緒管理有深入的理解；
  • Netflix 的 Hystrix 庫里封裝了執行緒操作，開發人員可以只需要關注業務開發與 Spring Cloud；

1.2 兩大類別的 Hystrix 實作

  • 使用 Hystrix 斷路器包裝所有服務中所有對資料庫的呼叫；
  • 使用 Hystrix 斷路器包裝所有服務之間的內部服務呼叫；

兩大類別的 Hystrix 實作

1.3 艙壁策略

艙壁策略

1.4 Hystrix 在遠程資源呼叫失敗時的決策程序

在遠程資源呼叫失敗時使用的決策程序

  • 快照時間窗：查看在 10 s 內發生的呼叫次數：
    • 請求總數閥值：如果呼叫次數少于在這個視窗內設定的最小呼叫次數，那么即使有幾個呼叫失敗，Hystrix 也不會采取行動；
    • 反之，進行下一步；
  • 查看整體故障的百分比：
    • 錯誤百分比閥值：如果故障的總體百分比超過閾值， Hystrix 將觸發斷路器，使將來幾乎所有的呼叫都失敗；
  • 當 Hystrix 斷路器被觸發時，它將嘗試啟動一個新的活動視窗：
    • 每隔 5s（可配置的）， Hystrix 會通過一個遠程呼叫， 如果呼叫成功， Hystrix將重置斷路器并重新開始讓呼叫通過， 如果呼叫失敗， Hystrix將保持斷路器斷開；

1.5 當 Hystrix 斷路器打開后

  • 再有請求呼叫的時候，將不會呼叫主邏輯，而是直接呼叫降級fallback，通過斷路器，實作了自動地發現錯誤并將降級邏輯切換為主邏輯，減少回應延遲的效果；
  • hystrix 會啟動一個休眠時間窗，在這個時間窗內，降級邏輯是臨時的成為主邏輯；
  • 當休眠時間窗到期，斷路器將進入半開狀態，釋放一次請求到原來的主邏輯上；
    • 如果此次請求正常回傳，那么斷路器將繼續閉合，主邏輯恢復；
    • 反之，斷路器繼續進入打開狀態，休眠時間窗重新計時；

1.6 Hystrix 的所有配置

在這里插入圖片描述
Hystrix 的默認配置

@HystrixCommand(fallbackMethod = "str_fallbackMethod",
        groupKey = "strGroupCommand",
        commandKey = "strCommand",
        threadPoolKey = "strThreadPool",

        commandProperties = {
                // 設定隔離策略，THREAD 表示執行緒池 SEMAPHORE：信號池隔離
                @HystrixProperty(name = "execution.isolation.strategy", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/THREAD"),
                // 當隔離策略選擇信號池隔離的時候，用來設定信號池的大小（最大并發數）
                @HystrixProperty(name = "execution.isolation.semaphore.maxConcurrentRequests", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/10"),
                // 配置命令執行的超時時間
                @HystrixProperty(name = "execution.isolation.thread.timeoutinMilliseconds", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/10"),
                // 是否啟用超時時間
                @HystrixProperty(name = "execution.timeout.enabled", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/true"),
                // 執行超時的時候是否中斷
                @HystrixProperty(name = "execution.isolation.thread.interruptOnTimeout", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/true"),
                // 執行被取消的時候是否中斷
                @HystrixProperty(name = "execution.isolation.thread.interruptOnCancel", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/true"),
                // 允許回呼方法執行的最大并發數
                @HystrixProperty(name = "fallback.isolation.semaphore.maxConcurrentRequests", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/10"),
                // 服務降級是否啟用，是否執行回呼函式
                @HystrixProperty(name = "fallback.enabled", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/true"),
                // 是否啟用斷路器
                @HystrixProperty(name = "circuitBreaker.enabled", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/true"),
                // 該屬性用來設定在滾動時間窗中，斷路器熔斷的最小請求數，例如，默認該值為 20 的時候，
                // 如果滾動時間窗（默認10秒）內僅收到了19個請求， 即使這19個請求都失敗了，斷路器也不會打開，
                @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/20"),
                // 該屬性用來設定在滾動時間窗中，表示在滾動時間窗中，在請求數量超過
                // circuitBreaker.requestVolumeThreshold 的情況下，如果錯誤請求數的百分比超過50,
                // 就把斷路器設定為 "打開" 狀態，否則就設定為 "關閉" 狀態，
                @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/50"),
                // 該屬性用來設定當斷路器打開之后的休眠時間窗， 休眠時間窗結束之后，
                // 會將斷路器置為 "半開" 狀態，嘗試熔斷的請求命令，如果依然失敗就將斷路器繼續設定為 "打開" 狀態，
                // 如果成功就設定為 "關閉" 狀態，
                @HystrixProperty(name = "circuitBreaker.sleepWindowinMilliseconds", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/5000"),
                // 斷路器強制打開
                @HystrixProperty(name = "circuitBreaker.forceOpen", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/false"),
                // 斷路器強制關閉
                @HystrixProperty(name = "circuitBreaker.forceClosed", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/false"),
                // 滾動時間窗設定，該時間用于斷路器判斷健康度時需要收集資訊的持續時間
                @HystrixProperty(name = "metrics.rollingStats.timeinMilliseconds", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/10000"),
                // 該屬性用來設定滾動時間窗統計指標資訊時劃分"桶"的數量，斷路器在收集指標資訊的時候會根據
                // 設定的時間窗長度拆分成多個 "桶" 來累計各度量值，每個"桶"記錄了一段時間內的采集指標，
                // 比如 10 秒內拆分成 10 個"桶"收集這樣，所以 timeinMilliseconds 必須能被 numBuckets 整除，否則會拋例外
                @HystrixProperty(name = "metrics.rollingStats.numBuckets", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/10"),
                // 該屬性用來設定對命令執行的延遲是否使用百分位數來跟蹤和計算，如果設定為 false, 那么所有的概要統計都將回傳 -1，
                @HystrixProperty(name = "metrics.rollingPercentile.enabled", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/false"),
                // 該屬性用來設定百分位統計的滾動視窗的持續時間，單位為毫秒，
                @HystrixProperty(name = "metrics.rollingPercentile.timeInMilliseconds", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/60000"),
                // 該屬性用來設定百分位統計滾動視窗中使用 “ 桶 ”的數量，
                @HystrixProperty(name = "metrics.rollingPercentile.numBuckets", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/60000"),
                // 該屬性用來設定在執行程序中每個 “桶” 中保留的最大執行次數，如果在滾動時間窗內發生超過該設定值的執行次數，
                // 就從最初的位置開始重寫，例如，將該值設定為100, 滾動視窗為10秒，若在10秒內一個 “桶 ”中發生了500次執行，
                // 那么該 “桶” 中只保留 最后的100次執行的統計，另外，增加該值的大小將會增加記憶體量的消耗，并增加排序百分位數所需的計算時間，
                @HystrixProperty(name = "metrics.rollingPercentile.bucketSize", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/100"),
                // 該屬性用來設定采集影響斷路器狀態的健康快照（請求的成功、 錯誤百分比）的間隔等待時間，
                @HystrixProperty(name = "metrics.healthSnapshot.intervalinMilliseconds", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/500"),
                // 是否開啟請求快取
                @HystrixProperty(name = "requestCache.enabled", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/true"),
                // HystrixCommand的執行和事件是否列印日志到 HystrixRequestLog 中
                @HystrixProperty(name = "requestLog.enabled", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/true"),
        },
        threadPoolProperties = {
                // 該引數用來設定執行命令執行緒池的核心執行緒數，該值也就是命令執行的最大并發量
                @HystrixProperty(name = "coreSize", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/10"),
                // 該引數用來設定執行緒池的最大佇列大小，當設定為 -1 時，執行緒池將使用 SynchronousQueue 實作的佇列，
                // 否則將使用 LinkedBlockingQueue 實作的佇列，
                @HystrixProperty(name = "maxQueueSize", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/-1"),
                // 該引數用來為佇列設定拒絕閾值， 通過該引數， 即使佇列沒有達到最大值也能拒絕請求，
                // 該引數主要是對 LinkedBlockingQueue 佇列的補充,因為 LinkedBlockingQueue
                // 佇列不能動態修改它的物件大小，而通過該屬性就可以調整拒絕請求的佇列大小了，
                @HystrixProperty(name = "queueSizeRejectionThreshold", value = "https://www.cnblogs.com/dlhjw/archive/2022/01/29/5"),
        }
)

2. 對服務使用 Hystrix 斷路器

2.1 引入 pom.xml 依賴

<!--拉取 Spring Cloud Hystrix 依賴項-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
  • 以下依賴是核心 Netflix Hystrix 庫，一般情況下不需要我們引入；
<dependency>
    <groupId>com.netflix.hystrix</groupId>
    <artifactId>hystrix-javanica</artifactId>
    <version>1.5.9</version>
</dependency>

2.2 修改 bootstrap.yml 組態檔

  • 如果需要用到 Feign 呼叫才需要進行配置；
feign: 
  hystrix:
    #開啟feign的hystrix支持,默認是false 
    enabled: true

2.3 在主程式類上標注注解

  • @EnableCircuitBreaker：表示激活使用服務降級相關策略；

  • @EnableHystrix：繼承了@EnableCircuitBreaker，并對其進行了在封裝；

  • 如果忘記將該注解添加到主程式類中，那么 Hystrix 斷路器不會處于活動狀態，在服務啟動時，也不會收到任何警告或錯誤訊息；

2.4 在業務類上使用 ＠HystrixCommand 注解（斷路器模式）

在 service 包下的業務類里；方法級注解；

@HystrixCommand
private Xxx getXxx(String xxxId) {
    return xxxService.getXxx(xxxId);
}
  • ＠HystrixCommand 注解將動態生成一個代理，該代理將包裝該方法，并通過專門用于處理遠程呼叫的執行緒池來管理對該方法的所有呼叫；
  • 當呼叫時間超過 1000 ms 時，斷路器將中斷對 getXxx()，并拋出r如下例外：
    • com.nextflix.hystrix.exception.HystrixRuntimeException；

2.5 定制斷路器（后備策略、艙壁策略）

  • 默認情況下，不帶屬性配置的 ＠HystrixCommand 注解，會將所有遠程服務呼叫都放在同一執行緒池下，可能會導致應用程式中出現問題；
@HystrixCommand(
        fallbackMethod="getYyy",  //【可選】艙壁策略，定義執行緒池的唯一名稱后備策略，如果 getXxx 呼叫失敗，那么就會呼叫該方法，注意兩個方法引數需保持一致
        threadPoolKey="xxxThreadPool",  //【可選】艙壁策略，定義執行緒池的唯一名稱艙壁策略，定義執行緒池的唯一名稱
        threadPoolProperties={
                @HystrixProperty(name="coreSize",value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/30"),  //執行緒池中執行緒的最大數量
                @HystrixProperty(name="maxQueueSize", value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/10")  //定義一個位于執行緒池前的佇列，對傳入的請求進行排隊
        },
        //通過 commandProperties 屬性來定制斷路器的行為
        commandProperties={
                @HystrixProperty(name="circuitBreaker.requestVolumeThreshold", value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/10"),  //斷路器觸發前 10s 內需要發生的連續呼叫數量
                @HystrixProperty(name="circuitBreaker.errorThresholdPercentage", value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/75"),  //在斷路器跳閘之前必須達到的呼叫失敗百分比
                @HystrixProperty(name="circuitBreaker.sleepWindowInMilliseconds", value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/7000"),  //斷路器跳閘之后， Hystrix 允許一個呼叫通過以便查看服務是否恢復健康之前 Hystrix 的休眠時間 
                
                @HystrixProperty(name="metrics.rollingStats.timeInMilliseconds", value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/15000"),  //Hystr ix 用來監視服務呼叫問題的視窗大小，其默認值為 10 000ms
                @HystrixProperty(name="metrics.rollingStats.numBuckets", value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/5"),  //定義的滾動視窗中收集統計資訊的次數
                
                //@HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/5000"), //設定斷路器超時時間
                @HystrixProperty(name="execution.isolation.strategy", value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/SEMAPHORE"),  //修改命令池的隔離設定
        }
)
private Xxx getXxx(String xxxId) {
    return xxxService.getXxx(xxxId);
}

private Yyy getYyy(String yyyId) {
    return yyyService.getYyy(yyyId);
}

屬性詳解：

  • threadPoolProperties：

    • maxQueueSize：如果將其值設定為 -1，則將使用 Java SynchronousQueue 來保存所有傳人的請求，同步佇列本質上會強制要求正在處理中的請求數量永遠不能超過執行緒池中可用執行緒的數量；
    • maxQueueSize：設定為大于 1 的值將使用 Java LinkedBlockingQueue；LinkedBlockingQueue 的使用允許開發人員即使所有執行緒都在忙于處理請求，也能對請求進行排隊；
    • maxQueueSize 屬性只能在執行緒池首次初始化時設定（例如，在應用程式啟動時），Hystrix 允許通過使用 queueSizeRejectionThreshold 屬性來動態更改佇列的大小，但只有在 maxQueueSize 屬性的值大于 0 時，才能設定此屬性；

  • commandProperties：

    • execution.isolation.thread.timeoutInMilliseconds：設定斷路器超時時間，在實際開發中應該把問題放在解決性能問題而不是增加默認超時，如果確實遇到一些比其他服務呼叫需要更長時間的服務呼叫，務必將這些服務呼叫隔離到單獨的執行緒池中；
    • metrics.rollingStats.numBuckets：其值需要被 metrics.rollingStats.timeInMilliseconds 整除，上例 Hystrix 使用 15s 的視窗，并將統計資料收集到長度為 3 s 的 5 個桶中，查的統計視窗越小且在視窗中保留的桶的數量越多，就越會加劇高請求服務的 CPU 利用率和記憶體使用率；
    • execution.isolation.strategy：斷路器執行時，有兩種不同的隔離策略；
      • THREAD（執行緒）：默認，保護呼叫的每個 Hystrix命令都在一個單獨的執行緒池中運行；
      • SEMAPHORE（信號量）：輕量級隔離，適用于服務量很大且正在使用異步 l/O 編程模型（假設使用的是像 Netty 這樣的異步 IO 容器）運行的情況；

  • 其他配置屬性詳情請見本篇《1.6 Hystrix 的所有配置》；

2.6 使用類級注解統一 Hystrix 配置

  • ＠DefaultProperties：相當于修改該類下 Hystrix 配置的默認值；
@DefaultProperties( 
    commandProperties={
         @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="https://www.cnblogs.com/dlhjw/archive/2022/01/29/10000")}
class  MyService{
    ...
}

3. 使用 HystrixConcurrencyStrategy 聯系執行緒背景關系

3.1 Hystrix 的背景關系隔離

  • 默認情況下， Hystrix 以 THREAD 隔離策略運行；
  • 這使每個 Hystrix 命令都在一個單獨的執行緒池中運行，該執行緒池不與父錢程共享它的背景關系；
  • 因此默認情況下，對被父執行緒呼叫并由 ＠HystrixComman 保護的方法而言，在父執行緒中設定為 ThreadLocal 值的值都是不可用的；
  • 解決方法：定義一種并發策略，能將附加的父執行緒背景關系注入由 由 Hystrix 命令管理的執行緒中；

3.2 自定義 Hystrix 井發策略類

//擴展基本的 Hystrix ConcurrencyStrategy 類
public class ThreadLocalAwareStrategy extends HystrixConcurrencyStrategy{
    private HystrixConcurrencyStrategy existingConcurrencyStrategy;

    //將已存在的并發策略傳入到構造器中
    public ThreadLocalAwareStrategy(HystrixConcurrencyStrategy existingConcurrencyStrategy) {
        this.existingConcurrencyStrategy = existingConcurrencyStrategy;
    }

    @Override
    public BlockingQueue<Runnable> getBlockingQueue(int maxQueueSize) {
        return existingConcurrencyStrategy != null
                ? existingConcurrencyStrategy.getBlockingQueue(maxQueueSize)
                : super.getBlockingQueue(maxQueueSize);
    }

    @Override
    public <T> HystrixRequestVariable<T> getRequestVariable(
            HystrixRequestVariableLifecycle<T> rv) {
        return existingConcurrencyStrategy != null
                ? existingConcurrencyStrategy.getRequestVariable(rv)
                : super.getRequestVariable(rv);
    }

    @Override
    public ThreadPoolExecutor getThreadPool(HystrixThreadPoolKey threadPoolKey,
                                            HystrixProperty<Integer> corePoolSize,
                                            HystrixProperty<Integer> maximumPoolSize,
                                            HystrixProperty<Integer> keepAliveTime, TimeUnit unit,
                                            BlockingQueue<Runnable> workQueue) {
        return existingConcurrencyStrategy != null
                ? existingConcurrencyStrategy.getThreadPool(threadPoolKey, corePoolSize,
                maximumPoolSize, keepAliveTime, unit, workQueue)
                : super.getThreadPool(threadPoolKey, corePoolSize, maximumPoolSize,
                keepAliveTime, unit, workQueue);
    }

    @Override
    public <T> Callable<T> wrapCallable(Callable<T> callable) {
         //注入 Callable 實作，用來設定 UserContext
        return existingConcurrencyStrategy != null
                ? existingConcurrencyStrategy
                .wrapCallable(new DelegatingUserContextCallable<T>(callable, UserContextHolder.getContext()))
                : super.wrapCallable(new DelegatingUserContextCallable<T>(callable, UserContextHolder.getContext()));
    }
}

3.3 定義一個 Java Callable 類，將 UserContext 注入 Hystrix 命令中

public final class DelegatingUserContextCallable<V> implements Callable<V> {
    private final Callable<V> delegate;
    private UserContext originalUserContext;
    //傳遞原始 Callable 類，自定義 Callable 將呼叫 Hystrix 保護的代碼與來自父執行緒的 UserContext
    public DelegatingUserContextCallable(Callable<V> delegate,
                                             UserContext userContext) {
        this.delegate = delegate;
        this.originalUserContext = userContext;
    }
    //call() 方法在被 @HystrixCommand 注解保護的方法之前呼叫
    public V call() throws Exception {
        //已設定 UserContext，存盤 UserContext 的 ThreadLocal 變數與運行受 Hystrix 保護的方法的執行緒相關聯
        UserContextHolder.setContext( originalUserContext );

        try {
            //在 Hystrix 保護的方法上呼叫 call() 方法
            return delegate.call();
        }
        finally {
            this.originalUserContext = null;
        }
    }

    public static <V> Callable<V> create(Callable<V> delegate,
                                         UserContext userContext) {
        return new DelegatingUserContextCallable<V>(delegate, userContext);
    }
}

3.4 配置 Spring Cloud 以使用自定義 Hystrix 井發策略

@Configuration
public class ThreadLocalConfiguration {
        //當構造配置物件時，它將自動裝配在現有的 HystrixConcurrencyStrategy 中
        @Autowired(required = false)
        private HystrixConcurrencyStrategy existingConcurrencyStrategy;

        @PostConstruct
        public void init() {
            // 保留現有的 Hystrix 插件的參考
            //因為要注冊一個新的并發策略，所以要獲取所有其他的 Hystrix 組件，然后重新設定 Hystrix 組件
            HystrixEventNotifier eventNotifier = HystrixPlugins.getInstance()
                    .getEventNotifier();
            HystrixMetricsPublisher metricsPublisher = HystrixPlugins.getInstance()
                    .getMetricsPublisher();
            HystrixPropertiesStrategy propertiesStrategy = HystrixPlugins.getInstance()
                    .getPropertiesStrategy();
            HystrixCommandExecutionHook commandExecutionHook = HystrixPlugins.getInstance()
                    .getCommandExecutionHook();

            HystrixPlugins.reset();

            //使用 Hystrix 插件注冊自定義的 Hystrix 并發策略（ThreadConcurrency Strategy）
            HystrixPlugins.getInstance().registerConcurrencyStrategy(new ThreadLocalAwareStrategy(existingConcurrencyStrategy));
            //重新注冊 Hystrix 插件使用的所有組件
            HystrixPlugins.getInstance().registerEventNotifier(eventNotifier);
            HystrixPlugins.getInstance().registerMetricsPublisher(metricsPublisher);
            HystrixPlugins.getInstance().registerPropertiesStrategy(propertiesStrategy);
            HystrixPlugins.getInstance().registerCommandExecutionHook(commandExecutionHook);
        }
}

4. 使用 hystrixDashboard 實作服務監控

  • Hystrix 提供了準實時的呼叫監控（Hystrix Dashboard），其會持續地記錄所有通過Hystrix發起的請求的執行資訊，并以統計報表和圖形的形式展示給用戶，包括每秒執行多少請求多少成功，多少失敗等；
  • Netflix通過 hystrix-metrics-event-stream 專案實作了對以上指標的監控；
  • Spring Cloud 也提供了 Hystrix Dashboard 的整合，對監控內容轉化成可視化界面；

4.1 引入 pom.xml 依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>

4.2 修改 application.yml 組態檔

主要是修改埠號；

server:
  port: 9001

4.3 在主程式類上標注注解

@EnableHystrixDashboard：表名啟用 Hystrix Dashboard 對呼叫進行監控；

4.4 配置被監控的服務

1. 添加 pom.xml 依賴檔案

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

2. 在主啟動類中指定監控路徑

@SpringBootApplication
@EnableEurekaClient //本服務啟動后會自動注冊進eureka服務中
@EnableCircuitBreaker//對hystrixR熔斷機制的支持
public class Application{
    public static void main(String[] args){
        SpringApplication.run(Application.class,args);
    }

/**
 *此配置是為了服務監控而配置，與服務容錯本身無關，springcloud升級后的坑
 *ServletRegistrationBean因為springboot的默認路徑不是"/hystrix.stream"，
 *只要在自己的專案里配置上下面的servlet就可以了
 */
@Bean
public ServletRegistrationBean getServlet() {
    HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
    ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
    registrationBean.setLoadOnStartup(1);
    registrationBean.addUrlMappings("/hystrix.stream");
    registrationBean.setName("HystrixMetricsStreamServlet");
    return registrationBean;
}

4.5 訪問圖形化界面

  • 使用介面：http://localhost:9001/hystrix

Hystrix 圖形化界面

4.6 查看監控圖

  • 監控圖示例：

監控圖示例

  • 監控圖圖例解釋：

監控圖圖例解釋1
監控圖圖例解釋2

  • 實心圈：有兩種含義：
    • 通過顏色的變化代表了實體的健康程度，它的健康度從：綠色 < 黃色 < 橙色 < 紅色 遞減；
    • 其大小也會根據實體的請求流量發生變化，流量越大該實心圓就越大；
    • 所以通過該實心圓的展示，就可以在大量的實體中快速的發現故障實體和高壓力實體；
  • 曲線：
    • 用來記錄2分鐘內流量的相對變化，可以通過它來觀察到流量的上升和下降趨勢；

最后

新人制作，如有錯誤，歡迎指出，感激不盡！
歡迎關注公眾號，會分享一些更日常的東西！
如需轉載，請標注出處！

轉載請註明出處，本文鏈接：https://www.uj5u.com/ruanti/423146.html

標籤：其他

上一篇：HTTP狀態碼1XX深入理解

下一篇：微服務架構 | 7.1 基于 OAuth2 的安全認證

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C＃(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • 面試突擊第一季，第二季，第三季

    第一季必考 https://www.bilibili.com/video/BV1FE411y79Y?from=search&seid=15921726601957489746 第二季分布式 https://www.bilibili.com/video/BV13f4y127ee/?spm_id_fro ......

    uj5u.com 2020-09-10 05:35:24 more
  • 第三單元作業總結

    1.前言 這應該是本學期最后一次寫作業總結了吧。總體來說，對作業的節奏也差不多掌握了，作業做起來的效率也更高了。雖然和之前的作業一樣，作業中都要用到新的知識，但是相比之前，更加懂得了如何利用工具以及資料。雖然之間卡過殼，但總體而言，這幾次作業還算完成的比較好。 2.作業程序總結 相比前兩個單元，此單 ......

    uj5u.com 2020-09-10 05:35:41 more
  • 北航OO（2020）第四單元博客作業暨課程總結博客

    北航OO（2020）第四單元博客作業暨課程總結博客 本單元作業的架構設計 在本單元中，由于UML圖具有比較清晰的樹形結構，因此我對其中需要進行查詢操作的元素進行了包裝，在樹的父節點中存盤所有孩子的參考。考慮到性能問題，我采用了快取機制，一次查詢后盡可能快取已經遍歷過的資訊，以減少遍歷次數。 本單元我 ......

    uj5u.com 2020-09-10 05:35:48 more
  • BUAA_OO_第四單元

    一、UML決議器設計 ? 先看下題目：第四單元實作一個基于JDK 8帶有效性檢查的UML(Unified Modeling Language)類圖，順序圖，狀態圖分析器 MyUmlInteraction，實際上我們要建立一個有向圖模型，UML中的物件（元素）可能與同級元素連接，也可與低級元素相連形成 ......

    uj5u.com 2020-09-10 05:35:54 more
  • 6.1邏輯運算子

    邏輯運算子 1. && 短路與 運算式1 && 運算式2 01.運算式1為true并且運算式2也為true 整體回傳為true 02.運算式1為false，將不會執行運算式2 整體回傳為false 03.只要有一個運算式為false 整體回傳為false 2. || 短路或 運算式1 || 運算式2 ......

    uj5u.com 2020-09-10 05:35:56 more
  • BUAAOO 第四單元 & 課程總結

    1. 第四單元：StarUml檔案決議 本單元采用了圖模型決議UML。 UML檔案可以抽象為圖、子圖、邊的邏輯結構。 在實作中，圖的節點包括類、介面、屬性，子圖包括狀態圖、順序圖等。 采用了三次遍歷UML元素的方法建圖，第一遍遍歷建點，第二、三次遍歷設定屬性、連邊，實作圖物件的初始化。這里借鑒了一些 ......

    uj5u.com 2020-09-10 05:36:06 more
  • 談談我對C# 多型的理解

    面向物件三要素：封裝、繼承、多型。 封裝和繼承，這兩個比較好理解，但要理解多型的話，可就稍微有點難度了。今天，我們就來講講多型的理解。 我們應該經常會看到面試題目：請談談對多型的理解。 其實呢，多型非常簡單，就一句話：呼叫同一種方法產生了不同的結果。 具體實作方式有三種。 一、多載 多載很簡單。 p ......

    uj5u.com 2020-09-10 05:36:09 more
  • Python 資料驅動工具：DDT

    背景 python 的unittest 沒有自帶資料驅動功能。 所以如果使用unittest，同時又想使用資料驅動，那么就可以使用DDT來完成。 DDT是 “Data-Driven Tests”的縮寫。 資料：http://ddt.readthedocs.io/en/latest/ 使用方法 dd. ......

    uj5u.com 2020-09-10 05:36:13 more
  • Python里面的xlrd模塊詳解

    那我就一下面積個問題對xlrd模塊進行學習一下： 1.什么是xlrd模塊？ 2.為什么使用xlrd模塊？ 3.怎樣使用xlrd模塊？ 1.什么是xlrd模塊？ ?python操作excel主要用到xlrd和xlwt這兩個庫，即xlrd是讀excel，xlwt是寫excel的庫。 今天就先來說一下xl ......

    uj5u.com 2020-09-10 05:36:28 more
  • 當我們創建HashMap時，底層到底做了什么？

    jdk1.7中的底層實作程序（底層基于陣列+鏈表） 在我們new HashMap()時，底層創建了默認長度為16的一維陣列Entry[ ] table。當我們呼叫map.put(key1,value1)方法向HashMap里添加資料的時候： 首先，呼叫key1所在類的hashCode()計算key1 ......

    uj5u.com 2020-09-10 05:36:38 more
最新发布
  • 【中介者設計模式詳解】C/Java/JS/Go/Python/TS不同語言實作

    * 中介者模式是一種行為型設計模式，它可以用來減少類之間的直接依賴關系，
    * 將物件之間的通信封裝到一個中介者物件中，從而使得各個物件之間的關系更加松散。
    * 在中介者模式中，物件之間不再直接相互互動，而是通過中介者來中轉訊息。 ......

    uj5u.com 2023-04-20 08:20:47 more
  • 露天煤礦現場調研和交流案例分享

    他們集團的資訊化公司及研究院在一個礦區正在做智能礦山的統一平臺的 試點，專案投資大概1億，包括了礦山的各方面的內容，顯示得我們這次交流有點多余。他們2年前開始做智能礦山的規劃，有很多煤礦行業專家的加持，他們的描述是非常完美，但是去年底應該上線的平臺，現在還沒有看到影子。他們確實有很多場景需求，但是被... ......

    uj5u.com 2023-04-20 08:20:25 more
  • 《社區人員管理》實戰案例設計&個人案例分享

    設計是一個讓人夢想成真程序，開始編碼、測驗、除錯之前進行需求分析和架構設計，才能保證關鍵方面都做正確 ......

    uj5u.com 2023-04-20 08:20:17 more
  • 軟體架構生態化-多角色交付的探索實踐

    作為一個技術架構師，不僅僅要緊跟行業技術趨勢，還要結合研發團隊現狀及痛點，探索新的交付方案。在日常中，你是否遇到如下問題 “ 業務需求排期長研發是瓶頸；非研發角色感受不到研發技改提效的變化；引入ISV 團隊又擔心質量和安全，培訓周期長“等等，基于此我們探索了一種新的技術體系及交付方案來解決如上問題。 ......

    uj5u.com 2023-04-20 08:20:10 more
  • 【中介者設計模式詳解】C/Java/JS/Go/Python/TS不同語言實作

    * 中介者模式是一種行為型設計模式，它可以用來減少類之間的直接依賴關系，
    * 將物件之間的通信封裝到一個中介者物件中，從而使得各個物件之間的關系更加松散。
    * 在中介者模式中，物件之間不再直接相互互動，而是通過中介者來中轉訊息。 ......

    uj5u.com 2023-04-20 08:19:44 more
  • 露天煤礦現場調研和交流案例分享

    他們集團的資訊化公司及研究院在一個礦區正在做智能礦山的統一平臺的 試點，專案投資大概1億，包括了礦山的各方面的內容，顯示得我們這次交流有點多余。他們2年前開始做智能礦山的規劃，有很多煤礦行業專家的加持，他們的描述是非常完美，但是去年底應該上線的平臺，現在還沒有看到影子。他們確實有很多場景需求，但是被... ......

    uj5u.com 2023-04-20 08:19:07 more
  • 《社區人員管理》實戰案例設計&個人案例分享

    設計是一個讓人夢想成真程序，開始編碼、測驗、除錯之前進行需求分析和架構設計，才能保證關鍵方面都做正確 ......

    uj5u.com 2023-04-20 08:18:57 more
  • 軟體架構生態化-多角色交付的探索實踐

    作為一個技術架構師，不僅僅要緊跟行業技術趨勢，還要結合研發團隊現狀及痛點，探索新的交付方案。在日常中，你是否遇到如下問題 “ 業務需求排期長研發是瓶頸；非研發角色感受不到研發技改提效的變化；引入ISV 團隊又擔心質量和安全，培訓周期長“等等，基于此我們探索了一種新的技術體系及交付方案來解決如上問題。 ......

    uj5u.com 2023-04-20 08:18:49 more
  • 05單件模式

    #經典的單件模式 public class Singleton { private static Singleton uniqueInstance; //一個靜態變數持有Singleton類的唯一實體。 // 其他有用的實體變數寫在這里 //構造器宣告為私有，只有Singleton可以實體化這個類! ......

    uj5u.com 2023-04-19 08:42:51 more
  • 【架構與設計】常見微服務分層架構的區別和落地實踐

    軟體工程的方方面面都遵循一個最基本的道理：沒有銀彈，架構分層模型更是如此，每一種都有各自優缺點，所以請根據不同的業務場景，并遵循簡單、可演進這兩個重要的架構原則選擇合適的架構分層模型即可。 ......

    uj5u.com 2023-04-19 08:42:41 more

Copyright © 2010-2020 有解無憂