由於公司需要收集移動端的操作事件,用戶的每一個操作,都要存下來,我們用mongodb存放操作日誌。
這時可以用spring異步任務來處理,可以提快接口的響應時間。做法如下:
在spring的配置文件裏面加入下面類容
rejection-policy="DISCARD" 表示 pool-size到了最大,隊列也滿了,再來任務就直接丟棄,因為這是收集數據,可以丟一些,防止系統崩潰
<!-- 數據收集異步處理的線程池 -->
<task:executor id="dcExecutor" pool-size="15-1000"
queue-capacity="100" keep-alive="5" rejection-policy="DISCARD" />
<!-- 上下車提醒異步處理的線程池 -->
<task:executor id="remind" pool-size="15-500"
queue-capacity="1000" keep-alive="5" rejection-policy="DISCARD" />
要調用的方法上面加上註解@Async
@Async("dcExecutor")
public void handleDataCollection(CMDEnum cmdEnum, String json) {
switch (cmdEnum) {
case ROUTE_DETAIL:
RouteDetail routeDetail = JSON.parseObject(json, RouteDetail.class);
save(routeDetail, cmdEnum.tableName());
break;
case TRANSFER:
Transfer transfer = JSON.parseObject(json, Transfer.class);
save(transfer, cmdEnum.tableName());
break;
default:
break;
}
總結【基本使用方式】:
@Async這個註解用於標註某個方法或某個類裏面的所有方法都是需要異步處理的。被註解的方法被調用的時候,會在新線程中執行,而調用它的方法會在原來的線程中執行。這樣可以避免阻塞、以及保證任務的實時性。適用於處理log、發送郵件、短信……等。
註解的應用範圍:
- 類:表示這個類中的所有方法都是異步的
- 方法:表示這個方法是異步的,如果類也註解了,則以這個方法的註解為準
相關的配置:
<task:annotation-driven />配置:
- executor:指定一個缺省的executor給@Async使用。
例子:
<task:annotation-driven executor="asyncExecutor" />
<task:executor />配置參數:
- id:當配置多個executor時,被@Async("id")指定使用;也被作為線程名的前綴。
- pool-size:
-
- core size:最小的線程數,缺省:1
- max size:最大的線程數,缺省:Integer.MAX_VALUE
- queue-capacity:當最小的線程數已經被占用滿後,新的任務會被放進queue裏面,當這個queue的capacity也被占滿之後,pool裏面會創建新線程處理這個任務,直到總線程數達到了max size,這時系統會拒絕這個任務並拋出TaskRejectedException異常(缺省配置的情況下,可以通過rejection-policy來決定如何處理這種情況)。缺省值為:Integer.MAX_VALUE
- keep-alive:超過core size的那些線程,任務完成後,再經過這個時長(秒)會被結束掉
- rejection-policy:當pool已經達到max size的時候,如何處理新任務
- ABORT(缺省):拋出TaskRejectedException異常,然後不執行
- DISCARD:不執行,也不拋出異常
- DISCARD_OLDEST:丟棄queue中最舊的那個任務
- CALLER_RUNS:不在新線程中執行任務,而是有調用者所在的線程來執行
配置例子:
<task:annotation-driven executor="asyncExecutor" />
<task:executor id="asyncExecutor" pool-size="100-10000" queue-capacity="10"/>
實例:
<!-- 缺省的異步任務線程池 -->
<task:annotation-driven executor="asyncExecutor" />
<task:executor id="asyncExecutor" pool-size="100-20000" queue-capacity="10" />
<!-- 處理數據收集的線程池 -->
<task:executor id="dcExecutor" pool-size="15-10000" queue-capacity="50" keep-alive="50/>
@Async("dcExecutor") //如果不指定名字,會使用缺省的“asyncExecutor”
public void handleDataCollection(CMDEnum cmdEnum, String json) {
switch (cmdEnum) {
case ROUTE_DETAIL:
RouteDetail routeDetail = JSON.parseObject(json, RouteDetail.class);
save(routeDetail, cmdEnum.tableName());
break;
case TRANSFER:
Transfer transfer = JSON.parseObject(json, Transfer.class);
save(transfer, cmdEnum.tableName());
break;
default:
break;
}
(註意如果在同一個類中調用的話,不會生效,原因請參考:
http://blog.csdn.net/clementad/article/details/47339519
線程的優先級和類型:
優先級:NORM_PRIORITY
類型:非守護線程
用戶線程(User Thread):JVM會等待所有的用戶線程結束後才退出;當系統中沒有用戶線程了,JVM也就退出了
守護線程(Daemon Thread):一般是為其他線程提供服務的線程,比如GC垃圾回收器;JVM退出時,不會管守護線程是否存在,而是直接退出
所以,對於文件、數據庫的操作,不適宜使用守護線程,不然可能會丟失數據!
Web應用停止時,Spring容器會被關閉,調用者如果是Spring bean,就會停止生成新任務。然而,線程池中已經在運行的任務,由於缺省是用戶線程,所以JVM會等待它們結束後才退出。
附:Java編程方式的配置方法:
@Configuration
@EnableAsync
public class SpringConfig {
/** Set the ThreadPoolExecutor's core pool size. */
private int corePoolSize = 10;
/** Set the ThreadPoolExecutor's maximum pool size. */
private int maxPoolSize = 200;
/** Set the capacity for the ThreadPoolExecutor's BlockingQueue. */
private int queueCapacity = 10;
private String ThreadNamePrefix = "MyLogExecutor-";
@Bean
public Executor logExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(corePoolSize);
executor.setMaxPoolSize(maxPoolSize);
executor.setQueueCapacity(queueCapacity);
executor.setThreadNamePrefix(ThreadNamePrefix);
// rejection-policy:當pool已經達到max size的時候,如何處理新任務
// CALLER_RUNS:不在新線程中執行任務,而是有調用者所在的線程來執行
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
executor.initialize();
return executor;
}
}
Tags: default 配置文件 spring public 吞吐量
文章來源: