網(wǎng)站首頁 編程語言 正文
思路:對高并發(fā)的接口,單獨配置線程池。需考慮線程池內(nèi)的線程數(shù)量,以及tomcat總線程數(shù)量與CPU的關(guān)系。
線程池的配置
接口如何配置單獨的線程池
異步任務(wù) @Async(“myExecutors”)
對實時性要求高的
分析下:實時就是同步,每一次請求就是一條線程,高并發(fā)就意味著同時運行大量線程,大量線程意味著對CPU時間片的搶奪會變多,導(dǎo)致CPU使用率飆升,同時IO運算較多也會導(dǎo)致內(nèi)存占用飆升。總結(jié)一下就是,單機是有瓶頸的,我們要測出單機的并發(fā)瓶頸,然后使用多機部署(集群or微服務(wù))
QPS://todo
TPS://todo
怎么集群
//todo
怎么微服務(wù)
//todo
對實時性要求不高的
⑴ 設(shè)置接口冪等性,返回唯一ID,讓調(diào)用方通過ID查詢此次的運行結(jié)果(這里用UUID標(biāo)識的唯一ID,正式項目用 SnowFlake)
@ApiOperation("測試SUCCESS")
@RequestMapping("/success")
@WebLog(description = "請求了測試接口")
@Async("myExecutors")
public ResultVo testSuccess(@ApiParam("入?yún)?) @RequestBody TestVo testVo) {
//業(yè)務(wù)邏輯處理
String resultCode = service.run();
return new ResultVo(resultCode, testVo.getID());
}
(2)提供回調(diào),調(diào)用方傳入需要回調(diào)的接口地址,待異步執(zhí)行后,把結(jié)果返回
@ApiOperation("測試SUCCESS")
@RequestMapping("/success")
@WebLog(description = "請求了測試接口")
@Async("myExecutors")
public void testSuccess(@ApiParam("入?yún)?) @RequestBody TestVo testVo) {
//業(yè)務(wù)邏輯處理
String resultCode = service.run();
//結(jié)果回調(diào)
AsyncUtil.callBack(testVo.getUrl(),new ResultVo(ResultEnum.SUCCESS, testVo.getID()));
}
線程池的選擇
-
使用ThreadPoolExecutor,不要用Executors,具體原因網(wǎng)上搜,一堆
-
BlockingQueue對應(yīng)三種,ArrayBlockingQuere:需要自己設(shè)置隊列的容量,隊列滿了以后,將會開始創(chuàng)建maxPoolSize允許的線程數(shù);LinkedBlockingQueue:隊列的容量默認(rèn)設(shè)置成了Integer.MaxValue;SynchronousQueue:不存儲元素的隊列,會直接給線程,使用它的話,線程數(shù)量很容易達(dá)到maxPoolSize;
單個線程池的線程數(shù)量設(shè)置
不要相信什么CPU數(shù)量+1,CPU數(shù)量 X 2 這種公式
理應(yīng)通過排查當(dāng)前服務(wù)器cpu使用率和負(fù)載,對要使用線程的任務(wù)進行壓測,通過不斷的調(diào)整CPU使用率和線程數(shù),達(dá)到一個領(lǐng)自己滿意的數(shù)值,這才是最適合的線程數(shù)量,如果非要給一個初始值,那么就是核的數(shù)量吧,然后反復(fù)調(diào)整,確定最終的值。
top:命令查詢cpu使用率
cpuinfo:文件里查看核心數(shù)
線程總數(shù)量和CPU的關(guān)系
linux中,對于進程所擁有的的線程數(shù)有限制,一個進程最大線程數(shù)為1024
Tomcat和請求的關(guān)系
#最大隊列數(shù)
server.tomcat.accept-count=100
#最大鏈接數(shù)
server.tomcat.max-connections=8192
#最大線程數(shù)
server.tomcat.max-threads=100
- tomcat的最大線程數(shù),可以決定同時處理客戶端的請求數(shù)量。
- 最大連接數(shù)一定要大于最大線程數(shù),否則會有很多請求無響應(yīng)
原文鏈接:https://blog.csdn.net/longqiyuye925/article/details/126980332
相關(guān)推薦
- 2022-05-02 dubbo服務(wù)使用redis注冊中心的系列異常解決_Redis
- 2023-12-12 線程并發(fā)協(xié)作(生產(chǎn)者/消費者模式)
- 2023-01-23 python操作excel之openpyxl模塊讀寫xlsx格式使用方法詳解_python
- 2021-12-29 Android中String與int相互轉(zhuǎn)換_Android
- 2021-12-07 Linux系統(tǒng)的修復(fù)模式(單用戶模式)_Linux
- 2022-03-24 .Net?Core服務(wù)治理Consul自動擴展和服務(wù)調(diào)用_自學(xué)過程
- 2022-05-16 C++Smart?Pointer?智能指針詳解_C 語言
- 2022-04-09 python去掉空格的一些常用方式_python
- 最近更新
-
- window11 系統(tǒng)安裝 yarn
- 超詳細(xì)win安裝深度學(xué)習(xí)環(huán)境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎(chǔ)操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區(qū)別,Jav
- spring @retryable不生效的一種
- Spring Security之認(rèn)證信息的處理
- Spring Security之認(rèn)證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權(quán)
- redisson分布式鎖中waittime的設(shè)
- maven:解決release錯誤:Artif
- restTemplate使用總結(jié)
- Spring Security之安全異常處理
- MybatisPlus優(yōu)雅實現(xiàn)加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務(wù)發(fā)現(xiàn)-Nac
- Spring Security之基于HttpR
- Redis 底層數(shù)據(jù)結(jié)構(gòu)-簡單動態(tài)字符串(SD
- arthas操作spring被代理目標(biāo)對象命令
- Spring中的單例模式應(yīng)用詳解
- 聊聊消息隊列,發(fā)送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠(yuǎn)程分支