Spring?Boot小型項(xiàng)目如何使用異步任務(wù)管理器實(shí)現(xiàn)不同業(yè)務(wù)間的解耦
前言
在有些業(yè)務(wù)場(chǎng)景中,系統(tǒng)對(duì)于響應(yīng)時(shí)間有一定的要求,而一個(gè)方法里面同步執(zhí)行的業(yè)務(wù)邏輯太多勢(shì)必會(huì)影響響應(yīng)速度,帶來(lái)不好的用戶體驗(yàn)。比如登錄時(shí)記錄登錄用戶的訪問(wèn)記錄、注冊(cè)時(shí)發(fā)送郵件、短信通知等等場(chǎng)景,不需要等待處理結(jié)果之后再進(jìn)行下一步操作,這時(shí)候就可以使用異步線程進(jìn)行處理,這樣主線程不會(huì)因?yàn)檫@些耗時(shí)的操作而阻塞,保證主線程的流程可以正常進(jìn)行。
異步任務(wù)可以通過(guò)多線程也可以通過(guò)消息隊(duì)列來(lái)實(shí)現(xiàn),目的都是為了實(shí)現(xiàn)不同業(yè)務(wù)之間的解耦,提高業(yè)務(wù)系統(tǒng)的響應(yīng)速度。但是相對(duì)于小型系統(tǒng)采用多線程的方式相對(duì)更便捷,所以,這篇文章就記錄一下我是如何使用多線程實(shí)現(xiàn)異步任務(wù)管理器來(lái)記錄訪問(wèn)日志的。
一、異步任務(wù)管理器是什么?
顧名思義,就是用來(lái)對(duì)異步任務(wù)進(jìn)行統(tǒng)一的管理,并提供了一種訪問(wèn)其唯一對(duì)象的方式,這樣做的好處就是,在內(nèi)存中有且僅有一個(gè)實(shí)例,減少了內(nèi)存的開(kāi)銷,尤其對(duì)于頻繁的創(chuàng)建和銷毀實(shí)例,用這種方式來(lái)頻繁執(zhí)行多個(gè)異步任務(wù)性能是相對(duì)比較好的。
二、實(shí)現(xiàn)步驟
1.自定義線程池
執(zhí)行異步任務(wù)時(shí),需要將執(zhí)行的任務(wù)放入到線程池中,所以需配置好我們的線程池。并創(chuàng)建一個(gè)調(diào)度線程池執(zhí)行器,用來(lái)執(zhí)行異步任務(wù)。
代碼如下(示例):
2. 新建異步任務(wù)管理器類
代碼如下(示例):
public class AsyncManager {
/**
* 操作延遲10毫秒
*/
private final int OPERATE_DELAY_TIME = 10;
/**
* 異步操作任務(wù)調(diào)度線程池
*/
private ScheduledExecutorService executor = SpringUtils.getBean("scheduledExecutorService");
/**
* 餓漢式單例模式
*/
private AsyncManager(){}
private static AsyncManager me = new AsyncManager();
public static AsyncManager me() {
return me;
}
/**
* 執(zhí)行任務(wù)
* @param task 任務(wù)
*/
public void execute(TimerTask task) {
executor.schedule(task, OPERATE_DELAY_TIME, TimeUnit.MILLISECONDS);
}3. 新建異步工廠類
設(shè)計(jì)這個(gè)類主要是用來(lái)產(chǎn)生 TimerTask 的,代碼如下(示例):
@Slf4j
public class AsyncFactory {
/**
* 記錄登錄信息
* @param username 用戶名
* @param status 狀態(tài)
* @param message 消息
* @param args 列表
* @return 任務(wù)task
*/
public static TimerTask recordLoginLog(final String username, final String status, final String message,final Object... args) {
// 客戶端操作系統(tǒng)、瀏覽器等信息
final UserAgent userAgent = UserAgentUtil.parse(ServletUtils.getRequest().getHeader("User-Agent"));
// 請(qǐng)求的IP地址
final String ip = ServletUtil.getClientIP(ServletUtils.getRequest());
return new TimerTask() {
@Override
public void run() {
String address = AddressUtils.getRealAddressByIp(ip);
// 獲取客戶端操作系統(tǒng)
String os = userAgent.getOs().getName();
// 獲取客戶端瀏覽器
String browser = userAgent.getBrowser().getName();
// 封裝對(duì)象
XlLoginLog loginLog = new XlLoginLog();
loginLog.setUserCode(username);
loginLog.setIpaddr(ip);
loginLog.setLoginLocation(address);
loginLog.setBrowser(browser);
loginLog.setOs(os);
loginLog.setMsg(message);
loginLog.setLoginTime(new Date());
// 日志狀態(tài)
if (Constants.LOGIN_FAIL.equals(status)) {
loginLog.setStatus(Integer.valueOf(Constants.FAIL));
} else {
loginLog.setStatus(Integer.valueOf(Constants.SUCCESS));
}
// 插入數(shù)據(jù)
SpringUtils.getBean(IXlLoginLogService.class).create(loginLog);
}
};
}
}4. 調(diào)用
例如:在登錄的方法中鏈?zhǔn)秸{(diào)用,與同步方式不同,開(kāi)發(fā)者不用考慮當(dāng)進(jìn)行登錄操作是否進(jìn)行日志操作,在異步的方式中,業(yè)務(wù)的操作與日志的操作分開(kāi)來(lái)。執(zhí)行流程:AsyncManager.me()獲取一個(gè)AsyncManager對(duì)象,執(zhí)行execute方法,執(zhí)行任務(wù),傳入的是一個(gè)task對(duì)象。實(shí)現(xiàn)了Runnable接口,是一個(gè)任務(wù),由線程Thread去執(zhí)行。
recordLoginLog方法返回的是TimerTask定時(shí)任務(wù)類,將用戶登錄信息記錄到日志中作為一個(gè)定時(shí)任務(wù),交給定時(shí)任務(wù)調(diào)度線程池scheduledExecutorService,scheduledExecutorService通過(guò)在異步任務(wù)管理器類中,用getBean()從IOC容器中獲取。

5. 實(shí)現(xiàn)效果
進(jìn)行登錄操作時(shí),會(huì)異步進(jìn)行日志的記錄。

總結(jié)
到此這篇關(guān)于Spring Boot小型項(xiàng)目如何使用異步任務(wù)管理器實(shí)現(xiàn)不同業(yè)務(wù)間的解耦的文章就介紹到這了,更多相關(guān)Spring Boot實(shí)現(xiàn)不同業(yè)務(wù)間解耦內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java中mkdir()和mkdirs()的區(qū)別及說(shuō)明
這篇文章主要介紹了Java中mkdir()和mkdirs()的區(qū)別及說(shuō)明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-11-11
SpringBoot如何通過(guò)Map實(shí)現(xiàn)策略模式
策略模式是一種行為設(shè)計(jì)模式,它允許在運(yùn)行時(shí)選擇算法的行為,在Spring框架中,我們可以利用@Resource注解和Map集合來(lái)優(yōu)雅地實(shí)現(xiàn)策略模式,這篇文章主要介紹了SpringBoot如何通過(guò)Map實(shí)現(xiàn)策略模式,需要的朋友可以參考下2025-03-03
使用Spring Security集成手機(jī)驗(yàn)證碼登錄功能實(shí)現(xiàn)
本文詳細(xì)介紹了如何利用SpringSecurity來(lái)實(shí)現(xiàn)手機(jī)驗(yàn)證碼的注冊(cè)和登錄功能,在登錄過(guò)程中,同樣需通過(guò)驗(yàn)證碼進(jìn)行驗(yàn)證,文章還提供了相關(guān)的代碼實(shí)現(xiàn)2024-10-10
一文搞明白Java?Spring?Boot分布式事務(wù)解決方案
這篇文章主要介紹了一文搞明白Java?Spring?Boot分布式事務(wù)解決方案,文章圍繞主題展開(kāi)詳細(xì)的內(nèi)容介紹,具有一定的參考價(jià)值,需要的小伙伴可以參考一下2022-07-07
Spring Boot集成Shiro實(shí)現(xiàn)動(dòng)態(tài)加載權(quán)限的完整步驟
這篇文章主要給大家介紹了關(guān)于Spring Boot集成Shiro實(shí)現(xiàn)動(dòng)態(tài)加載權(quán)限的完整步驟,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用Spring Boot具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-09-09
Spring Bean 依賴注入常見(jiàn)錯(cuò)誤問(wèn)題
這篇文章主要介紹了Spring Bean 依賴注入常見(jiàn)錯(cuò)誤問(wèn)題,文中提到value的工作大體分為三個(gè)核心步驟,具體內(nèi)容詳情跟隨小編一起看看吧2021-09-09

