Hystrix官方已停止維護(hù)，官方推薦使用Resilience4j來(lái)替代Hystrix實(shí)現(xiàn)服務(wù)治理，今天我們看看如何使用Resilience4j。

創(chuàng)新互聯(lián)公司是一家集網(wǎng)站建設(shè),永清企業(yè)網(wǎng)站建設(shè),永清品牌網(wǎng)站建設(shè),網(wǎng)站定制,永清網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷(xiāo),網(wǎng)絡(luò)優(yōu)化,永清網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力。可充分滿足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專(zhuān)業(yè)、時(shí)尚、前沿，時(shí)刻以成就客戶成長(zhǎng)自我，堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。

介紹

1、一款受 Hystrix 啟發(fā)的輕量量級(jí)且易于使用的容錯(cuò)庫(kù)
2、針對(duì) Java 8 與函數(shù)式編程設(shè)計(jì)
3、github地址：https://github.com/resilience4j/resilience4j
4、核心組件：

如何基于Resilience4j實(shí)現(xiàn)斷路器

斷路器

1、Resilience4j的circuitbreaker組件實(shí)現(xiàn)了斷路器功能，他是基于內(nèi)存的斷路器，采用
ConcurrentHashMap來(lái)實(shí)現(xiàn)的。

2、斷路器的功能主要是處理熔斷，當(dāng)客戶端調(diào)用服務(wù)端出現(xiàn)問(wèn)題時(shí)進(jìn)行攔截，直接返回，不再發(fā)送請(qǐng)求給服務(wù)端，減少下游服務(wù)的沖擊。

實(shí)驗(yàn)環(huán)境

1、基于Eureka的服務(wù)注冊(cè)和發(fā)現(xiàn)
2、提供服務(wù)的waiter-service
3、客戶端調(diào)用customer-service

關(guān)鍵代碼

1、啟動(dòng)waiter-service和customer-service服務(wù)，分別注冊(cè)到Eureka,這里不再介紹，可以參考之前的博客。

2、waiter-service作為服務(wù)提供方，不涉及到配置代碼

3、關(guān)鍵代碼在客戶端customer-service

3.1、斷路器的配置：application.properties
規(guī)則取名為-order

resilience4j.circuitbreaker.backends.order.failure-rate-threshold=50
resilience4j.circuitbreaker.backends.order.wait-duration-in-open-state=5000
resilience4j.circuitbreaker.backends.order.ring-buffer-size-in-closed-state=5
resilience4j.circuitbreaker.backends.order.ring-buffer-size-in-half-open-state=3
resilience4j.circuitbreaker.backends.order.event-consumer-buffer-size=10

3.2、使用注解的方式實(shí)現(xiàn)斷路器

@GetMapping("/getCoffee1")
    @io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker(name = "order")
    public Coffee getCoffee1() {
        Coffee list = coffeeService.getById(1l);
        log.info("Read coffee: {} coffee", list);
        return list;
    }

3.3、使用注冊(cè)方式，實(shí)現(xiàn)斷路器，短路之后默認(rèn)返回空的list

private CircuitBreaker circuitBreaker;
    public CustomerController(CircuitBreakerRegistry registry) {
        circuitBreaker = registry.circuitBreaker("order");
    }
    @GetMapping("/getCoffee2")
    public List<Coffee> getCoffee2() {
        return Try.ofSupplier(
                CircuitBreaker.decorateSupplier(circuitBreaker,
                        () -> coffeeService.getAll()))
                .recover(CircuitBreakerOpenException.class, Collections.emptyList())
                .get();
    }

3.4、關(guān)閉waiter-service，模擬服務(wù)宕機(jī)，展示效果

連續(xù)請(qǐng)求3次，服務(wù)調(diào)用失敗

失敗超過(guò)50%，第4次觸發(fā)短路器打開(kāi)：

等待5秒鐘，斷路器嘗試重連：

創(chuàng)新互聯(lián)www.cdcxhl.cn，專(zhuān)業(yè)提供香港、美國(guó)云服務(wù)器，動(dòng)態(tài)BGP最優(yōu)骨干路由自動(dòng)選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證， 機(jī)房獨(dú)有T級(jí)流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確進(jìn)行流量調(diào)度，確保服務(wù)器高可用性。佳節(jié)活動(dòng)現(xiàn)已開(kāi)啟，新人活動(dòng)云服務(wù)器買(mǎi)多久送多久。

本文題目：服務(wù)治理-Resilience4j（熔斷）-創(chuàng)新互聯(lián)
網(wǎng)址分享：http://m.newbst.com/article18/cepggp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供動(dòng)態(tài)網(wǎng)站、面包屑導(dǎo)航、外貿(mào)網(wǎng)站建設(shè)、自適應(yīng)網(wǎng)站、品牌網(wǎng)站設(shè)計(jì)、定制網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)