SpringCloudHystrix線程池不足怎么辦

這篇文章主要介紹了SpringCloudHystrix線程池不足怎么辦,具有一定借鑒價值,感興趣的朋友可以參考下,希望大家閱讀完這篇文章之后大有收獲,下面讓小編帶著大家一起了解一下。

站在用戶的角度思考問題,與客戶深入溝通,找到順河網(wǎng)站設(shè)計與順河網(wǎng)站推廣的解決方案,憑借多年的經(jīng)驗,讓設(shè)計與互聯(lián)網(wǎng)技術(shù)結(jié)合,創(chuàng)造個性化、用戶體驗好的作品,建站類型包括:成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣、域名注冊、網(wǎng)站空間、企業(yè)郵箱。業(yè)務(wù)覆蓋順河地區(qū)。

現(xiàn)象:

昨天突然線上很多接口獲取失敗,通過 kibana發(fā)現(xiàn)大量異常,具體異常信息:

...into fallback. Rejected command because thread-pool queueSize is at rejection threshold.

異常代碼出處:

@FeignClient(name = "api", fallbackFactory = LoadBalancingFallbackFactory.class)public interface LoadBalancingFeignClient {  @PostMapping(value = "/api/loadBalancing/server")  Result currentServer();}@Slf4j@Componentpublic class LoadBalancingFallbackFactory implements FallbackFactory<LoadBalancingFeignClient> {  @Override  public LoadBalancingFeignClient create(Throwable throwable) {    final String msg = throwable.getMessage();    return () -> {      log.error("loadBalancingFeignClient currentServer into fallback. {}", msg);      return Result.error();    };****  }}

原因:

看到這里已經(jīng)很明顯了,是由于hystrix線程池不夠用,直接熔斷導(dǎo)致的。項目apollo配置:

hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds = 3500hystrix.threadpool.default.maxQueueSize = 60hystrix.threadpool.default.queueSizeRejectionThreshold = 40

hystrix參數(shù)簡析:

maxQueueSize:線程池大小,默認為-1,創(chuàng)建的隊列是SynchronousQueue,如果設(shè)置大于0則根據(jù)其大小創(chuàng)建LinkedBlockingQueue。

queueSizeRejectionThreshold:動態(tài)控制線程池隊列的上限,即使maxQueueSize沒有達到,達到queueSizeRejectionThreshold該值后,請求也會被拒絕,默認值5

相關(guān)源碼:

hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/strategy/concurrency/HystrixContextScheduler.java

private class HystrixContextSchedulerWorker extends Worker {    private final Worker worker;    private HystrixContextSchedulerWorker(Worker actualWorker) {      this.worker = actualWorker;    }    @Override    public void unsubscribe() {      worker.unsubscribe();    }    @Override    public boolean isUnsubscribed() {      return worker.isUnsubscribed();    }    @Override    public Subscription schedule(Action0 action, long delayTime, TimeUnit unit) {      if (threadPool != null) {        if (!threadPool.isQueueSpaceAvailable()) {          throw new RejectedExecutionException("Rejected command because thread-pool queueSize is at rejection threshold.");        }      }      return worker.schedule(new HystrixContexSchedulerAction(concurrencyStrategy, action), delayTime, unit);    }    @Override    public Subscription schedule(Action0 action) {      if (threadPool != null) {        if (!threadPool.isQueueSpaceAvailable()) {          throw new RejectedExecutionException("Rejected command because thread-pool queueSize is at rejection threshold.");        }      }      return worker.schedule(new HystrixContexSchedulerAction(concurrencyStrategy, action));    }  }

解決辦法:

適當(dāng)調(diào)大Hystrix線程隊列參數(shù)動態(tài)水平擴容服務(wù)優(yōu)化下游服務(wù),減少服務(wù)響應(yīng)時間

感謝你能夠認真閱讀完這篇文章,希望小編分享的“SpringCloudHystrix線程池不足怎么辦”這篇文章對大家有幫助,同時也希望大家多多支持創(chuàng)新互聯(lián),關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,更多相關(guān)知識等著你來學(xué)習(xí)!

當(dāng)前標(biāo)題:SpringCloudHystrix線程池不足怎么辦
瀏覽地址:http://muchs.cn/article38/jchepp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供品牌網(wǎng)站設(shè)計網(wǎng)站排名、網(wǎng)站維護、微信公眾號靜態(tài)網(wǎng)站、標(biāo)簽優(yōu)化

廣告

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

網(wǎng)站建設(shè)網(wǎng)站維護公司