Spring Cloud Hystrix 線程池隊列配置(踩坑)
背景：
有一次在生產環(huán)境，突然出現了很多筆還款單被掛起，后來排查原因，發(fā)現是內部系統調用時出現了Hystrix調用異常。在開發(fā)過程中，因為核心線程數設置的比較大，沒有出現這種異常。放到了測試環(huán)境，偶爾有出現這種情況，后來在網上查找解決方案，網上的方案是調整maxQueueSize屬性就好了，當時調整了一下，確實有所改善。可沒想到在生產環(huán)境跑了一段時間后卻又出現這種了情況，此時我第一想法就是去查看maxQueueSize屬性，可是maxQueueSize屬性是設置值了。當時就比較納悶了，為什么maxQueueSize屬性不起作用，后來通過查看官方文檔發(fā)現Hystrix還有一個queueSizeRejectionThreshold屬性，這個屬性是控制隊列最大閾值的，而Hystrix默認只配置了5個，因此就算我們把maxQueueSize的值設置再大，也是不起作用的。兩個屬性必須同時配置
先看一下正確的Hystrix配置姿勢。
application.yml：
hystrix: threadpool: default: coreSize: 200 #并發(fā)執(zhí)行的最大線程數，默認10 maxQueueSize: 1000 #BlockingQueue的最大隊列數，默認值-1 queueSizeRejectionThreshold: 800 #即使maxQueueSize沒有達到，達到queueSizeRejectionThreshold該值后，請求也會被拒絕，默認值5
接下來編寫一個測試類，來驗證幾種錯誤配置，看看會出現什么情況。
測試類代碼（A調用方）：
/**
* @Author: XiongFeng
* @Description:
* @Date: Created in 11:12 2018/6/11
*/
public class RepaymentHelperTest extends FundApplicationTests {
@Autowired
RepaymentHelper repaymentHelper;
@Autowired
private RouterFeign routerFeign;
@Test
public void hystrixTest() throws InterruptedException {
for (int i = 0; i < 135; i++) {
new Thread(new Runnable() {
@Override
public void run() {
job();
}
}).start();
}
Thread.currentThread().join();
}
public void job() {
String repaymentNo = "xf1002";
String transNo = "T4324324234";
String reqNo = "xf1002";
String begintime = "20180831130030";
String endtime = "20180831130050";
TransRecQueryReqDto transRecQueryReqDto = new TransRecQueryReqDto();
transRecQueryReqDto.setTransNo(transNo);
transRecQueryReqDto.setBeginTime(begintime);
transRecQueryReqDto.setEndTime(endtime);
transRecQueryReqDto.setReqNo(reqNo);
Resp<List<TransRecDto>> queryTransRecListResp = routerFeign.queryTransRec(new Req<>(repaymentNo, "2018080200000002", null, null, transRecQueryReqDto));
System.out.println(String.format("獲取結果為：【%s】", JsonUtil.toJson(queryTransRecListResp)));
}
}
這個測試類的作用就是創(chuàng)建135個線程，通過RouterFeign類并發(fā)請求B服務方，看看請求結果是否出現異常。
Feign調用代碼：
@FeignClient(value = "${core.name}", fallbackFactory = RouterFeignBackFactory.class, path = "/router")
public interface RouterFeign {
/**
* 代扣結果查詢
* @param transRecQueryReqDtoReq
* @return
*/
@PostMapping("/queryTransRec")
Resp<List<TransRecDto>> queryTransRec(@RequestBody Req<TransRecQueryReqDto> transRecQueryReqDtoReq);
}
這個類，就是通過Feign方式去調用B服務方的客戶端
服務提供方代碼（B服務方）：
/**
* @Author: XiongFeng
* @Description:
* @Date: Created in 16:04 2018/5/24
*/
@Api("還款服務")
@RefreshScope
@RestController
@RequestMapping("/router")
public class TestController {
private static Logger logger = LoggerFactory.getLogger(TestController.class);
// 計數器
private static AtomicInteger count = new AtomicInteger(1);
@ApiOperation(value = "代扣結果查詢")
@PostMapping("/queryTransRec")
Resp<List<TransRecDto>> queryTransRec(@RequestBody Req<TransRecQueryReqDto> transRecQueryReqDtoReq) throws InterruptedException {
System.out.println(String.format("查詢支付結果......計數： %s", count.getAndAdd(1)));
Thread.sleep(500);
return Resp.success(RespStatus.SUCCESS.getDesc(), null);
}
這個類的作用，就是一個服務提供方，計數并返回結果。
下面我們看一下幾種錯誤的配置。
案例一（將核心線程數調低，最大隊列數調大一點，但是隊列拒絕閾值設置小一點）：
hystrix: threadpool: default: coreSize: 10 maxQueueSize: 1000 queueSizeRejectionThreshold: 20
此時的結果：
左窗口是B服務方，右窗口是A調用方。從結果可以看出，調用135次，成功32次左右，其余線程全部拋異常。
案例二（將核心線程數調低，最大隊列數調小一點，但是隊列拒絕閾值設置大一點）：
hystrix: threadpool: default: coreSize: 10 maxQueueSize: 15 queueSizeRejectionThreshold: 2000
此時的結果：
java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@7d6d472b rejected from java.util.concurrent.ThreadPoolExecutor@17f8bcb7[Running, pool size = 3, active threads = 3, queued tasks = 15, completed tasks = 0]
左窗口是B服務方，右窗口是A調用方。從結果可以看出，調用135次，成功25次左右，其余線程全部拋異常。。
案例三（將核心線程數調低，最大隊列數調大一點，但是隊列拒絕閾值不設置值）：
hystrix: threadpool: default: coreSize: 10 maxQueueSize: 1500
此時的結果：
java.util.concurrent.RejectedExecutionException: Rejected command because thread-pool queueSize is at rejection threshold.
左窗口是B服務方，右窗口是A調用方。此時的結果和案例一的情況一樣，調用135次，成功47次左右，其余線程全部拋異常。報錯跟案例一一樣
案例四（將核心線程數調低，最大隊列數不設值，但是隊列拒絕閾值設置的比較大）：
hystrix: threadpool: default: coreSize: 10 queueSizeRejectionThreshold: 1000
此時的結果：
java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@23d268ea rejected from java.util.concurrent.ThreadPoolExecutor@66d0e2f4[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)
at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:112)
左窗口是B服務方，右窗口是A調用方。此時的結果和案例二的情況一樣，調用135次，成功10次左右，其余線程全部拋異常。報錯跟案例二一樣
下面來看一看正確的配置案例
案例一：將核心線程數調低，最大隊列數和隊列拒絕閾值的值都設置大一點）：
hystrix: threadpool: default: coreSize: 10 maxQueueSize: 1500 queueSizeRejectionThreshold: 1000
此時的結果：
左窗口是B服務方，右窗口是A調用方。此時的結果就完全正常了，并發(fā)請求了135次，全部成功！
結論：官方默認隊列閾值只有5個， 如果要調整隊列，必須同時修改maxQueueSize和queueSizeRejectionThreshold屬性的值，否則都會出現異常！參考文檔：
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
SpringBoot項目Jar包使用systemctl運行過程
這篇文章主要介紹了SpringBoot項目Jar包使用systemctl運行過程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2025-03-03
詳解servlet的url-pattern匹配規(guī)則
本篇文章主要介紹了=servlet的url-pattern匹配規(guī)則，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-12-12
于token通常會被多次使用,我們需要把它保存到緩存中,以減少頻繁地訪問數據庫,本文主要介紹了SpringBoot整合Redis實現token緩存,感興趣的可以了解一下2024-02-02
這篇文章主要介紹了Java數組添加元素的兩種方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友跟著小編來一起學習學習吧2023-04-04
這篇文章主要介紹了Java如何將二維數組轉化為一維數組，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-08-08
Spring cloud stream是為構建微服務消息驅動而產生的一種框架。Spring Cloud Stream基于Spring boot的基礎上，可創(chuàng)建獨立的、生產級別的Spring應用，并采用Spring Integration來連接消息中間件提供消息事件驅動，一起看看吧2021-07-07
Java使用CountDownLatch實現網絡同步請求的示例代碼
CountDownLatch 是一個同步工具類，用來協調多個線程之間的同步，它能夠使一個線程在等待另外一些線程完成各自工作之后，再繼續(xù)執(zhí)行。被將利用CountDownLatch實現網絡同步請求，異步同時獲取商品信息組裝，感興趣的可以了解一下2023-01-01
這篇文章主要介紹了Java類和成員變量聲明類詳解，類中的成員變量——這些被稱為字段，文章圍繞主題展開詳細的內容介紹，具有一定的參考價值，需要的朋友可以參考一下2022-08-08
在寫項目的過程中我發(fā)現有的地方編碼格式被設置成了 gbk 如果用eclipse等工具直接改回utf-8編碼格式則會出現亂碼,所以本文給大家介紹了Java工程編碼格式由GBK轉化成utf-8的具體實現,感興趣的朋友可以參考下2024-05-05
java教程散列表和樹所對應容器類及HashMap解決沖突學習
本篇篇文章是java教程，主要介紹了java教程散列表，樹所對應容器類及HashMap解決沖突的學習，有需要的朋友可以借鑒參考下，希望能夠有所幫助2021-10-10