您好,登錄后才能下訂單哦!
現(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 @Component public 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 = 3500 hystrix.threadpool.default.maxQueueSize = 60 hystrix.threadpool.default.queueSizeRejectionThreshold = 40
hystrix參數(shù)簡析:
maxQueueSize:線程池大小,默認(rèn)為-1,創(chuàng)建的隊列是SynchronousQueue,如果設(shè)置大于0則根據(jù)其大小創(chuàng)建LinkedBlockingQueue。
queueSizeRejectionThreshold:動態(tài)控制線程池隊列的上限,即使maxQueueSize沒有達到,達到queueSizeRejectionThreshold該值后,請求也會被拒絕,默認(rèn)值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)); } }
解決辦法:
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持億速云。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。