欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringCloud之Hystrix的詳細使用

 更新時間：2022年01月24日 17:17:20   作者：sky~  
熔斷機制是應對雪崩效應的一種微服務鏈路保護機制,當扇出鏈路的某個微服務出錯不可用或者響應時間太長,會進行服務的降級,進而熔斷該節(jié)點微服務的調(diào)用,快速返回錯誤的相應信息，本文重點給大家介紹SpringCloud Hystrix使用，感興趣的朋友一起看看吧

1.概念

服務降級：服務器繁忙，請稍后再試，不讓客戶端等待，并立即返回一個友好的提示（一般發(fā)生在 程序異常，超時，服務熔斷觸發(fā)服務降級，線程池、信號量 打滿也會導致服務降級）
服務熔斷 ： 達到最大服務訪問后，直接拒絕訪問，然后調(diào)用服務降級的方法并返回友好提示（如保險絲一樣）
服務限流 ： 秒殺等高并發(fā)操作，嚴禁一窩蜂的過來擁擠，排隊進入，一秒鐘N個，有序進行

***一.服務降級***

2.不使用Hystrix的項目

大致的Service和Controller層如下

***************Controller*****************
package com.sky.springcloud.controller;

import com.sky.springcloud.service.PaymentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@RestController
@Slf4j
public class PaymentController {
    @Resource
    private PaymentService paymentService;
    @Value("${server.port}")
    private String serverport;
    @GetMapping("/payment/hystrix/ok/{id}")
    public String paymentInfo_Ok(@PathVariable("id") Integer id){
        String result = paymentService.paymentInfo_ok(id);
        log.info("*****"+ result);
        return result;
    }
    @GetMapping("/payment/hystrix/timeout/{id}")
    public String paymentInfo_TimeOut(@PathVariable("id") Integer id){
        String result = paymentService.payment_Info_TimeOut(id);
}
*******************Service******************** 
package com.sky.springcloud.service;
import org.springframework.stereotype.Service;
import java.util.concurrent.TimeUnit;
@Service
public class PaymentServiceImpl implements PaymentService{
    @Override
    public String paymentInfo_ok(Integer id) {
        return "線程池：" + Thread.currentThread().getName() + "paymentInfo_Ok. id:" + id + "\t" + "~~~~~";
    public String payment_Info_TimeOut(Integer id) {
       try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "線程池：" + Thread.currentThread().getName() + "paymentInfo_TimeOut. id:" + id + "\t" + "~~~~~";

在這種情況時,當通過瀏覽器訪問 TimeOut這個方法,會三秒后返回結果,而當訪問 OK 這個方法時,會直接返回結果(但是這是在訪問量很少的時候,一旦訪問量過多,訪問OK時也會出現(xiàn)延遲,這里可以使用Jmeter模擬兩萬個訪問量,如下)

在這里插入圖片描述

在這里插入圖片描述

使用 Jmeter 模擬后,再去訪問OK,會明顯出現(xiàn)加載的效果

3. 使用Hystrix

在主啟動類添加注解
@EnableHystrix

package com.sky.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
@SpringBootApplication
@EnableEurekaClient //啟用Eureka
@EnableHystrix     //啟用Hystrix
public class Payment8001 {
    public static void main(String[] args) {
        SpringApplication.run(Payment8001.class,args);
    }
}

在原有的基礎上,在Service層加上如下注解

 @HystrixCommand(fallbackMethod = "payment_Info_TimeOutHandler",//當服務降級時,調(diào)用payment_Info_TimeOutHandler方法
                  commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",
            value = "3000")//設置時間為3秒,超過三秒就為時間超限
*****************改后的Service*******************
package com.sky.springcloud.service;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;
@Service
public class PaymentServiceImpl implements PaymentService{
    @Override
    public String paymentInfo_ok(Integer id) {
        return "線程池：" + Thread.currentThread().getName() + "paymentInfo_Ok. id:" + id + "\t" + "~~~~~";
    }

    @HystrixCommand(fallbackMethod = "payment_Info_TimeOutHandler",commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "3000")
    })
    public String payment_Info_TimeOut(Integer id) {
      try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
      // int a = 10 / 0;
        return "線程池：" + Thread.currentThread().getName() + "paymentInfo_TimeOut. id:" + id + "\t" + "~~~~~";
    }
    public String payment_Info_TimeOutHandler(Integer id){
        return "線程超時或異常 " + Thread.currentThread().getName();
    }
}

如上Service所示,如果再次訪問TimeOut需要等待五秒,但是Hystrix設置的超時時間為三秒,所以當三秒后沒有結果就會服務降級,從而調(diào)用TimeOutHandler這個指定 的方法來執(zhí)行(或者有程序出錯等情況也會服務降級)

4. 全局的Hystrix配置

@DefaultProperties(defaultFallback = “Gloub_Test”)

package com.sky.springcloud.service;

import com.netflix.hystrix.contrib.javanica.annotation.DefaultProperties;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.stereotype.Service;
@Service
@DefaultProperties(defaultFallback = "Gloub_Test")
public class PaymentServiceImpl implements PaymentService{
    @Override
    @HystrixCommand
    public String paymentInfo_ok(Integer id) {
        int a = 10 / 0;
        return "線程池：" + Thread.currentThread().getName() + "paymentInfo_Ok. id:" + id + "\t" + "~~~~~";
    }
    @HystrixCommand(fallbackMethod = "payment_Info_TimeOutHandler",commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "3000")
    })
    public String payment_Info_TimeOut(Integer id) {
   /*     try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }*/
        return "線程池：" + Thread.currentThread().getName() + "paymentInfo_TimeOut. id:" + id + "\t" + "~~~~~";
    public String payment_Info_TimeOutHandler(Integer id){
        return "線程超時或異常 " + Thread.currentThread().getName();
    public String Gloub_Test(){
        return "走了全局的";
}

如上Service所示,加了@HystrixCommand的方法里,
如果沒指定fallbackMethod 就會默認去找全局的defaultFallback
這里 當paymentInfo_ok 方法出錯時,會調(diào)用Gloub_Test方法
當payment_Info_TimeOut出錯時,會調(diào)用payment_Info_TimeOutHandler方法

 ***二.服務熔斷***

1.熔斷機制概述

熔斷機制是應對雪崩效應的一種微服務鏈路保護機制,當扇出鏈路的某個微服務出錯不可用或者響應時間太長,會進行服務的降級,進而熔斷該節(jié)點微服務的調(diào)用,快速返回錯誤的相應信息.當檢測到該節(jié)點微服務調(diào)用相應正常后,恢復調(diào)用鏈路.

2.項目中使用

在上面的基礎上,改寫Service和Controller(添加以下代碼)

//是否開啟服務熔斷(斷路器)
 @HystrixProperty(name = "circuitBreaker.enabled",value = "true"),
 //服務請求的次數(shù) 
 @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"),
 //時間的窗口期
 @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"),
 //當失敗率達到多少后發(fā)生熔斷
 @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60"), 

******************Service*****************
    @HystrixCommand(fallbackMethod = "paymentCircuitBreaker_fallback",
                    commandProperties = {
                    @HystrixProperty(name = "circuitBreaker.enabled",value = "true"),
                    @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"),
                    @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"),
                    @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60"),
                    })
    public String PaymentCircuitBreaker(@PathVariable("id") Integer id){
        if(id<0){
            throw new RuntimeException("********** id不能為負");
        }
        String serialNumber = IdUtil.simpleUUID();
        return Thread.currentThread().getName() + "\t" + serialNumber;
    }
    public String paymentCircuitBreaker_fallback(@PathVariable("id") Integer id){
        return  "id 不能為負:" + id;
************Controller********************
    @GetMapping("/payment/circuit/{id}")
        String result = paymentService.PaymentCircuitBreaker(id);
        log.info(result + "***********");
        return result;

如上所示,當訪問paymentCircuitBreaker時,如果id小于零則會有一個運行錯誤,這時候就會通過服務降級來調(diào)用paymentCircuitBreaker_fallback方法,當錯誤的次數(shù)達到60%的時候(自己設的),就會出現(xiàn)服務熔斷,這個時候再訪問id大于零的情況,也會發(fā)生服務降級,因為開起了服務熔斷,需要慢慢的恢復正常.

到此這篇關于SpringCloud之Hystrix的詳細使用的文章就介紹到這了,更多相關SpringCloud Hystrix使用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

相關文章

  • Java 延遲隊列的常用的實現(xiàn)方式

    Java 延遲隊列的常用的實現(xiàn)方式

    這篇文章主要介紹了Java 延遲隊列的常用的實現(xiàn)方式，幫助大家更好的理解和學習使用Java，感興趣的朋友可以了解下
    2021-04-04
  • Spring?Boot+Vue實現(xiàn)Socket通知推送的完整步驟

    Spring?Boot+Vue實現(xiàn)Socket通知推送的完整步驟

    最近工作中涉及消息通知功能的開發(fā),所以下面這篇文章主要給大家介紹了關于Spring?Boot+Vue實現(xiàn)Socket通知推送的完整步驟,文中通過實例代碼以及圖文介紹的非常詳細,需要的朋友可以參考下
    2023-04-04
  • Java集合-HashMap

    Java集合-HashMap

    這篇文章主要介紹了Java集合HashMap，也叫散列表，是一種非常重要的數(shù)據(jù)結構，應用場景及其豐富，許多緩存技術（比如memcached）的核心其實就是在內(nèi)存中維護一張大的哈希表，下面來看看文章的具體內(nèi)容吧，需要的小伙伴也可參考一下
    2022-01-01
  • Java多線程中的原子類屬性說明

    Java多線程中的原子類屬性說明

    這篇文章主要介紹了Java多線程中的原子類屬性說明,對多線程訪問同一個變量,我們需要加鎖,而鎖是比較消耗性能的,JDk1.5之后,新增的原子操作類提供了一種用法簡單、性能高效、線程安全地更新一個變量的方式,需要的朋友可以參考下
    2023-10-10
  • spring cloud如何修復zuul跨域配置異常的問題

    spring cloud如何修復zuul跨域配置異常的問題

    最近的開發(fā)過程中,使用spring集成了spring-cloud-zuul，在配置zuul跨域的時候遇到了問題，下面這篇文章主要給大家介紹了關于spring cloud如何修復zuul跨域配置異常的問題，需要的朋友可以參考借鑒，下面來一起看看吧。
    2017-09-09
  • Java元組類型javatuples使用實例

    Java元組類型javatuples使用實例

    這篇文章主要介紹了Java元組類型javatuples使用實例,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2019-11-11
  • Java基礎之詳細總結五種常用運算符

    Java基礎之詳細總結五種常用運算符

    在通常代碼邏輯處理中,我們常常都會使用到運算符,今天我們就詳細了解一下運算符的使用以及分類.運算符是對常量或者變量進行操作的符號,它分為算術運算符,賦值運算符,比較運算符,邏輯運算符以及位運算符.需要的朋友可以參考下
    2021-05-05
  • Java與SpringBoot對redis的使用方式

    Java與SpringBoot對redis的使用方式

    這篇文章主要介紹了Java與SpringBoot對redis的使用方式，文章圍繞主題展開詳細的內(nèi)容介紹，具有一定的參考價值，需要的朋友可以參考一下
    2022-08-08
  • 使用IDEA打jar包的詳細圖文教程

    使用IDEA打jar包的詳細圖文教程

    JAR文件是一種壓縮文件,與常見的ZIP壓縮文件兼容,被稱為JAR包,下面這篇文章主要給大家介紹了關于使用IDEA打jar包的相關資料,文中通過圖文介紹的非常詳細,需要的朋友可以參考下
    2022-08-08
  • JavaSE面試題之this與super關鍵字的區(qū)別詳解

    JavaSE面試題之this與super關鍵字的區(qū)別詳解

    this關鍵字用于引用當前對象的引用,super關鍵字用于引用父類對象的引用,下面這篇文章主要給大家介紹了關于JavaSE面試題之this與super關鍵字區(qū)別的相關資料,需要的朋友可以參考下
    2023-12-12

最新評論