hystrix服務(wù)降級方法使用介紹

更新時間：2022年09月01日 16:38:20 作者：一個風輕云淡

什么是服務(wù)降級？當服務(wù)器壓力劇增的情況下，根據(jù)實際業(yè)務(wù)情況及流量，對一些服務(wù)和頁面有策略的不處理或換種簡單的方式處理，從而釋放服務(wù)器資源以保證核心交易正常運作或高效運作

當一個服務(wù)端的業(yè)務(wù)響應(yīng)的時間過長的時候或者業(yè)務(wù)處理邏輯處理異常，不應(yīng)該等待，應(yīng)該給出一種處理方法

超時導致服務(wù)器變慢(轉(zhuǎn)圈) --->超時不再等待

出錯(宕機或程序運行出錯) --->出錯要有兜底

pom文件依賴：

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

主啟動類需要加注解：

@EnableHystrix

yml文件設(shè)置：

feign:
hystrix:
enabled: true

feign:hystrix:enabled: true的作用，官網(wǎng)解釋“Feign將使用斷路器包裝所有方法”，也就是將@FeignClient標記的那個service接口下所有的方法進行了hystrix包裝（類似于在這些方法上加了一個@HystrixCommand），這些方法會應(yīng)用一個默認的超時時間為1s

情況1

  /**
     * 超時訪問，演示降級
     * @param id
     * @return
     */
    @HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler",commandProperties = {
            @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="3000")
    })
    public String paymentInfo_TimeOut(Integer id)
    {
        int second = 5;
        try { TimeUnit.SECONDS.sleep(second); } catch (InterruptedException e) { e.printStackTrace(); }
        return "線程池:"+Thread.currentThread().getName()+"paymentInfo_TimeOut,id: "+id+"\t"+"O(∩_∩)O，耗費秒: "+second;
    }
    public String paymentInfo_TimeOutHandler(Integer id){
        return "/(ㄒoㄒ)/調(diào)用支付接口超時或異常：\t"+ "\t當前線程池名字" + Thread.currentThread().getName();
    }

@HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler",

commandProperties ={@HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",

value="3000")

})

@HystrixCommand：需要進行降級處理的業(yè)務(wù)處理方法的標注注解

fallbackMethod ：發(fā)生時間過長的時候或運行錯誤的時候需要調(diào)用的方法

@HystrixProperty：相關(guān)參數(shù)設(shè)置，如上就是設(shè)置超時時間，超過了3s就調(diào)用方法

情況2：每個業(yè)務(wù)方法對應(yīng)一個兜底的方法，代碼膨脹，統(tǒng)一和自定義的分開

@RestController
@Slf4j
@DefaultProperties(defaultFallback = "payment_Global_FallbackMethod")
public class PaymentHystirxController
{
    @GetMapping("/consumer/payment/hystrix/timeout/{id}")
    @HystrixCommand //加了@DefaultProperties屬性注解，并且沒有寫具體方法名字，就用統(tǒng)一全局的
    public String paymentInfo_TimeOut(@PathVariable("id") Integer id)
    {
        String result = paymentHystrixService.paymentInfo_TimeOut(id);
        return result;
    }
    public String paymentTimeOutFallbackMethod(@PathVariable("id") Integer id)
    {
        return "paymentTimeOutFallbackMethod,對方系統(tǒng)繁忙，請10秒鐘后再次嘗試/(ㄒoㄒ)/";
    }
    public String payment_Global_FallbackMethod()
    {
        return "Global異常處理信息，請稍后再試，/(ㄒoㄒ)/~~";
    }
}

@DefaultProperties(defaultFallback = "payment_Global_FallbackMethod")

defaultFallback ：指定默認改控制類的所有標注了@HystrixCommand的控制方法降級處理都是名字為payment_Global_FallbackMethod

如果需要針對處理的，可以添加fallbackMethod 參數(shù)和情況1一樣處理掉

情況3：和業(yè)務(wù)邏輯混一起？？？混亂

說明：當引發(fā)降級處理的時候，也可能是因為服務(wù)內(nèi)部程序發(fā)生了錯誤或調(diào)用的服務(wù)宕機，這個時候就需要給客戶處理的不再是“業(yè)務(wù)繁忙”而是“內(nèi)部程序錯誤”

案列：現(xiàn)在有80服務(wù)調(diào)用8001端口的業(yè)務(wù)，但8001端口的服務(wù)突然出現(xiàn)宕機；80端口使用feign處理8001端口的調(diào)用

@Component
@FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT",
fallback = PaymentFallbackService.class)
public interface PaymentHystrixService
{
    @GetMapping("/payment/hystrix/ok/{id}")
    String paymentInfo_OK(@PathVariable("id") Integer id);
    @GetMapping("/payment/hystrix/timeout/{id}")
    String paymentInfo_TimeOut(@PathVariable("id") Integer id);
}

@FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT",

fallback = PaymentFallbackService.class)

value：是8001端口的服務(wù)名稱

fallback ：是該接口的實現(xiàn)類，也就是在80端口調(diào)用8001端口服務(wù)發(fā)生錯誤的時候需要進行的方法

@Component //必須加 //必須加 //必須加
public class PaymentFallbackService implements PaymentHystrixService
{
    @Override
    public String paymentInfo_OK(Integer id) {
        return "服務(wù)調(diào)用失敗，提示來自：cloud-consumer-feign-order80";
    }
    @Override
    public String paymentInfo_TimeOut(Integer id) {
        return "服務(wù)調(diào)用失敗，提示來自：cloud-consumer-feign-order80";
    }
}

補充：

說明：現(xiàn)在有80端口控制類調(diào)用了8001端口業(yè)務(wù)處理類，但在8001端口這個服務(wù)也設(shè)置了服務(wù)降級，假設(shè)為5s超時處理，而80這邊設(shè)置的服務(wù)降級為3s超時處理，現(xiàn)在業(yè)務(wù)響如果超過了3s，那么應(yīng)該響應(yīng)的是80端口這邊的服務(wù)降級處理

到此這篇關(guān)于hystrix服務(wù)降級方法使用介紹的文章就介紹到這了,更多相關(guān)hystrix服務(wù)降級內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: