Bulkhead

Bulkhead一般用于服務(wù)調(diào)用客戶端，用于限定對(duì)特定的服務(wù)的并發(fā)請(qǐng)求數(shù)量，起到一下作用：
1、防?下游依賴被并發(fā)請(qǐng)求沖擊
2、防?發(fā)?連環(huán)故障

創(chuàng)新互聯(lián)建站網(wǎng)站建設(shè)10余年堅(jiān)持，服務(wù)企業(yè)網(wǎng)站設(shè)計(jì)、成都響應(yīng)式網(wǎng)站建設(shè)等網(wǎng)站建設(shè)服務(wù)。1000多家企業(yè)的合作經(jīng)驗(yàn)，幫助我們?yōu)榉?wù)企業(yè)不斷提升價(jià)值。為企業(yè)建設(shè)開發(fā)網(wǎng)站和維護(hù)，主推個(gè)性化定制型網(wǎng)站設(shè)計(jì)

1、配置規(guī)則“order”

//允許大的并發(fā)數(shù)量
resilience4j.bulkhead.backends.order.max-concurrent-call=1
//阻塞線程的大時(shí)間量
resilience4j.bulkhead.backends.order.max-wait-time=5

2、注解方式使用

@PostMapping("/order")
    @io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker(name = "order")
    @io.github.resilience4j.bulkhead.annotation.Bulkhead(name = "order")
    public CoffeeOrder createOrder() {
        NewOrderRequest orderRequest = NewOrderRequest.builder()
                .customer("Li Lei")
                .items(Arrays.asList("capuccino"))
                .build();
        CoffeeOrder order = coffeeOrderService.create(orderRequest);
        log.info("Order ID: {}", order != null ? order.getId() : "-");
        return order;
    }

3、使用配置注冊(cè)方式

private CircuitBreaker circuitBreaker;
    private Bulkhead bulkhead;

      //構(gòu)造方法
    public CustomerController(CircuitBreakerRegistry circuitBreakerRegistry,
                              BulkheadRegistry bulkheadRegistry) {
        circuitBreaker = circuitBreakerRegistry.circuitBreaker("order");
        bulkhead = bulkheadRegistry.bulkhead("order");
    }

    @GetMapping("/menu")
    public List<Coffee> readMenu() {
        return Try.ofSupplier(
                Bulkhead.decorateSupplier(bulkhead,
                        CircuitBreaker.decorateSupplier(circuitBreaker,
                                () -> coffeeService.getAll())))
                .recover(CircuitBreakerOpenException.class, Collections.emptyList())
                .recover(BulkheadFullException.class, Collections.emptyList())
                .get();
    }

RateLimiter

RateLimiter用于限制特定時(shí)間段內(nèi)的執(zhí)?次數(shù)，一般用于服務(wù)提供方，保護(hù)自己不受到?jīng)_擊。

1、配置限流策略-“order”

//一個(gè)限制周期內(nèi)可訪問(wèn)次數(shù)
resilience4j.ratelimiter.limiters.order.limit-for-period=3
//限制周期,每個(gè)周期之后，速率限制器將重置回limitForPeriod值
resilience4j.ratelimiter.limiters.order.limit-refresh-period-in-millis=30000
//線程等待允許執(zhí)行時(shí)間
resilience4j.ratelimiter.limiters.order.timeout-in-millis=1000
//開啟時(shí)間訂閱
resilience4j.ratelimiter.limiters.order.subscribe-for-events=true
//開啟監(jiān)控監(jiān)控
resilience4j.ratelimiter.limiters.order.register-health-indicator=true

2、使用注解方式

@PostMapping(path = "/", consumes = MediaType.APPLICATION_JSON_VALUE,
            produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
    @ResponseStatus(HttpStatus.CREATED)
    @io.github.resilience4j.ratelimiter.annotation.RateLimiter(name = "order")
    public CoffeeOrder create(@RequestBody NewOrderRequest newOrder) {
        log.info("Receive new Order {}", newOrder);
        Coffee[] coffeeList = coffeeService.getCoffeeByName(newOrder.getItems())
                .toArray(new Coffee[]{});
        return orderService.createOrder(newOrder.getCustomer(), coffeeList);
    }

3、使用配置注冊(cè)方式

private RateLimiter rateLimiter;
    //構(gòu)造方法
    public CoffeeOrderController(RateLimiterRegistry rateLimiterRegistry) {
        rateLimiter = rateLimiterRegistry.rateLimiter("order");
    }

    @GetMapping("/{id}")
    public CoffeeOrder getOrder(@PathVariable("id") Long id) {
        CoffeeOrder order = null;
        try {
            order = rateLimiter.executeSupplier(() -> orderService.get(id));
            log.info("Get Order: {}", order);
        } catch (RequestNotPermitted e) {
            log.warn("Request Not Permitted! {}", e.getMessage());
        }
        return order;
    }

創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(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)已開啟，新人活動(dòng)云服務(wù)器買多久送多久。

文章名稱：服務(wù)治理-Resilience4j（限流）-創(chuàng)新互聯(lián)
轉(zhuǎn)載注明：http://chinadenli.net/article34/dgpese.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供定制網(wǎng)站、服務(wù)器托管、虛擬主機(jī)、用戶體驗(yàn)、網(wǎng)站策劃、網(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)