SpringBoot怎麼實作模組日誌入庫
1.簡述
模組日誌的實作方式大致有三種:
#AOP 自訂註解實作
輸出指定格式日誌日誌掃描實作
在介面中透過程式碼侵入的方式,在業務邏輯處理之後,呼叫方法記錄日誌。
這裡我們主要討論下第3種實作方式。
假設我們需要實作一個使用者登入之後記錄登入日誌的動作。
呼叫關係如下:
這裡的核心程式碼是在LoginService.login() 方法中設定了在交易結束後執行:
// 指定事务提交后执行 TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { // 不需要事务提交前的操作,可以不用重写这个方法 @Override public void beforeCommit(boolean readOnly) { System.out.println("事务提交前执行"); } @Override public void afterCommit() { System.out.println("事务提交后执行"); } });
在這裡,我們把這段程式碼封裝成了工具類,參考:4.TransactionUtils。
如果在LoginService.login() 方法中開啟了事務,不指定事務提交後指定的話,日誌處理的方法做非同步和做新事務都會有問題:
-
做非同步:由於主事務可能沒有執行完畢,導致可能讀取不到主事務中新增或修改的資料資訊;
做新事物:可以透過Propagation .REQUIRES_NEW 事務傳播行為來建立新事務,在新事務中執行記錄日誌的操作,可能會導致以下問題:
由於資料庫預設事務隔離等級是可重複讀,表示事物之間讀取不到未提交的內容,所以也會導致讀取不到主事務中新增或修改的資料資訊;
如果開啟的新事務和先前的事務操作了同一個表,就會導致鎖定表。
什麼都不做,直接同步呼叫:問題最多,可能導致以下幾個問題:
- ##不捕獲異常,直接導致介面所有操作回滾;
- 捕獲異常,部分資料庫,如:PostgreSQL,同一事務中,只要有一次執行失敗,就算捕獲異常,剩餘的資料庫操作也會全部失敗,拋出例外;
- 日誌記錄耗時增加介面回應時間,影響使用者體驗。
@RestController
public class LoginController {
@Autowired
private LoginService loginService;
@RequestMapping("/login")
public String login(String username, String pwd) {
loginService.login(username, pwd);
return "succeed";
}
}
登入後複製
3.Action@RestController public class LoginController { @Autowired private LoginService loginService; @RequestMapping("/login") public String login(String username, String pwd) { loginService.login(username, pwd); return "succeed"; } }
/**
* <p> @Title Action
* <p> @Description 自定义动作函数式接口
*
* @author ACGkaka
* @date 2023/4/26 13:55
*/
public interface Action {
/**
* 执行动作
*/
void doSomething();
}
登入後複製
4.TransactionUtils/** * <p> @Title Action * <p> @Description 自定义动作函数式接口 * * @author ACGkaka * @date 2023/4/26 13:55 */ public interface Action { /** * 执行动作 */ void doSomething(); }
import org.springframework.transaction.support.TransactionSynchronization;
import org.springframework.transaction.support.TransactionSynchronizationManager;
/**
* <p> @Title TransactionUtils
* <p> @Description 事务同步工具类
*
* @author ACGkaka
* @date 2023/4/26 13:45
*/
public class TransactionUtils {
/**
* 提交事务前执行
*/
public static void beforeTransactionCommit(Action action) {
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override
public void beforeCommit(boolean readOnly) {
// 异步执行
action.doSomething();
}
});
}
/**
* 提交事务后异步执行
*/
public static void afterTransactionCommit(Action action) {
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override
public void afterCommit() {
// 异步执行
action.doSomething();
}
});
}
}
登入後複製
5.LoginServiceimport org.springframework.transaction.support.TransactionSynchronization; import org.springframework.transaction.support.TransactionSynchronizationManager; /** * <p> @Title TransactionUtils * <p> @Description 事务同步工具类 * * @author ACGkaka * @date 2023/4/26 13:45 */ public class TransactionUtils { /** * 提交事务前执行 */ public static void beforeTransactionCommit(Action action) { TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { @Override public void beforeCommit(boolean readOnly) { // 异步执行 action.doSomething(); } }); } /** * 提交事务后异步执行 */ public static void afterTransactionCommit(Action action) { TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { @Override public void afterCommit() { // 异步执行 action.doSomething(); } }); } }
@Service
public class LoginService {
@Autowired
private LoginLogService loginLogService;
/** 登录 */
@Transactional(rollbackFor = Exception.class)
public void login(String username, String pwd) {
// 用户登录
// TODO: 实现登录逻辑..
// 事务提交后执行
TransactionUtil.afterTransactionCommit(() -> {
// 异步执行
taskExecutor.execute(() -> {
// 记录日志
loginLogService.recordLog(username);
});
});
}
}
登入後複製
6.LoginLogService6.1 @Async實作非同步@Service public class LoginService { @Autowired private LoginLogService loginLogService; /** 登录 */ @Transactional(rollbackFor = Exception.class) public void login(String username, String pwd) { // 用户登录 // TODO: 实现登录逻辑.. // 事务提交后执行 TransactionUtil.afterTransactionCommit(() -> { // 异步执行 taskExecutor.execute(() -> { // 记录日志 loginLogService.recordLog(username); }); }); } }
@Service
public class LoginLogService {
/** 记录日志 */
@Async
@Transactional(rollbackFor = Exception.class)
public void recordLog(String username) {
// TODO: 实现记录日志逻辑...
}
}
登入後複製
注意:@Async 需要配合@EnableAsync 使用,@EnableAsync 加入啟動類別、設定類別、自訂執行緒池類上均可。 補充:由於@Async 註解會動態建立一個繼承類別來擴展方法的實現,所以可能會導致目前類別注入Bean容器失敗BeanCurrentlyInCreationException,可以使用以下方式:自訂執行緒池@Autowired@Service public class LoginLogService { /** 记录日志 */ @Async @Transactional(rollbackFor = Exception.class) public void recordLog(String username) { // TODO: 实现记录日志逻辑... } }
6.2 自訂執行緒池實作非同步1)自訂執行緒池AsyncTaskExecutorConfig.java
import com.demo.async.ContextCopyingDecorator; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.task.TaskExecutor; import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.util.concurrent.ThreadPoolExecutor; /** * <p> @Title AsyncTaskExecutorConfig * <p> @Description 异步线程池配置 * * @author ACGkaka * @date 2023/4/24 19:48 */ @EnableAsync @Configuration public class AsyncTaskExecutorConfig { /** * 核心线程数(线程池维护线程的最小数量) */ private int corePoolSize = 10; /** * 最大线程数(线程池维护线程的最大数量) */ private int maxPoolSize = 200; /** * 队列最大长度 */ private int queueCapacity = 10; @Bean public TaskExecutor taskExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(corePoolSize); executor.setMaxPoolSize(maxPoolSize); executor.setQueueCapacity(queueCapacity); executor.setThreadNamePrefix("MyExecutor-"); // for passing in request scope context 转换请求范围的上下文 executor.setTaskDecorator(new ContextCopyingDecorator()); // rejection-policy:当pool已经达到max size的时候,如何处理新任务 // CALLER_RUNS:不在新线程中执行任务,而是有调用者所在的线程来执行 executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); executor.setWaitForTasksToCompleteOnShutdown(true); executor.initialize(); return executor; } }
import org.slf4j.MDC; import org.springframework.core.task.TaskDecorator; import org.springframework.security.core.context.SecurityContext; import org.springframework.security.core.context.SecurityContextHolder; import org.springframework.web.context.request.RequestAttributes; import org.springframework.web.context.request.RequestContextHolder; import java.util.Map; /** * <p> @Title ContextCopyingDecorator * <p> @Description 上下文拷贝装饰者模式 * * @author ACGkaka * @date 2023/4/24 20:20 */ public class ContextCopyingDecorator implements TaskDecorator { @Override public Runnable decorate(Runnable runnable) { try { // 从父线程中获取上下文,然后应用到子线程中 RequestAttributes requestAttributes = RequestContextHolder.currentRequestAttributes(); Map<String, String> previous = MDC.getCopyOfContextMap(); SecurityContext securityContext = SecurityContextHolder.getContext(); return () -> { try { if (previous == null) { MDC.clear(); } else { MDC.setContextMap(previous); } RequestContextHolder.setRequestAttributes(requestAttributes); SecurityContextHolder.setContext(securityContext); runnable.run(); } finally { // 清除请求数据 MDC.clear(); RequestContextHolder.resetRequestAttributes(); SecurityContextHolder.clearContext(); } }; } catch (IllegalStateException e) { return runnable; } } }
import org.springframework.transaction.support.TransactionSynchronization; import org.springframework.transaction.support.TransactionSynchronizationManager; @Service public class LoginService { @Autowired private LoginLogService loginLogService; @Qualifier("taskExecutor") @Autowired private TaskExecutor taskExecutor; /** 登录 */ @Transactional(rollbackFor = Exception.class) public void login(String username, String pwd) { // 用户登录 // TODO: 实现登录逻辑.. // 事务提交后执行 TransactionUtil.afterTransactionCommit(() -> { // 异步执行 taskExecutor.execute(() -> { // 记录日志 loginLogService.recordLog(username); }); }); } }
import org.springframework.transaction.support.TransactionTemplate; @Service public class LoginService { @Autowired private LoginLogService loginLogService; @Autowired private TransactionTemplate transactionTemplate; /** 登录 */ public void login(String username, String pwd) { // 用户登录 transactionTemplate.execute(status->{ // TODO: 实现登录逻辑.. }); // 事务提交后异步执行 taskExecutor.execute(() -> { // 记录日志 loginLogService.recordLog(username); }); } }
以上是SpringBoot怎麼實作模組日誌入庫的詳細內容。更多資訊請關注PHP中文網其他相關文章!

熱AI工具

Undresser.AI Undress
人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool
免費脫衣圖片

Clothoff.io
AI脫衣器

Video Face Swap
使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱門文章

熱工具

記事本++7.3.1
好用且免費的程式碼編輯器

SublimeText3漢化版
中文版,非常好用

禪工作室 13.0.1
強大的PHP整合開發環境

Dreamweaver CS6
視覺化網頁開發工具

SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)

Jasypt介紹Jasypt是一個java庫,它允許開發員以最少的努力為他/她的專案添加基本的加密功能,並且不需要對加密工作原理有深入的了解用於單向和雙向加密的高安全性、基於標準的加密技術。加密密碼,文本,數字,二進位檔案...適合整合到基於Spring的應用程式中,開放API,用於任何JCE提供者...添加如下依賴:com.github.ulisesbocchiojasypt-spring-boot-starter2. 1.1Jasypt好處保護我們的系統安全,即使程式碼洩露,也可以保證資料來源的

一、Redis實現分散式鎖原理為什麼需要分散式鎖在聊分散式鎖之前,有必要先解釋一下,為什麼需要分散式鎖。與分散式鎖相對就的是單機鎖,我們在寫多執行緒程式時,避免同時操作一個共享變數產生資料問題,通常會使用一把鎖來互斥以保證共享變數的正確性,其使用範圍是在同一個進程中。如果換做是多個進程,需要同時操作一個共享資源,如何互斥?現在的業務應用通常是微服務架構,這也意味著一個應用會部署多個進程,多個進程如果需要修改MySQL中的同一行記錄,為了避免操作亂序導致髒數據,此時就需要引入分佈式鎖了。想要實現分

使用場景1、下單成功,30分鐘未支付。支付超時,自動取消訂單2、訂單簽收,簽收後7天未進行評估。訂單超時未評價,系統預設好評3、下單成功,商家5分鐘未接單,訂單取消4、配送超時,推播簡訊提醒…對於延時比較長的場景、即時性不高的場景,我們可以採用任務調度的方式定時輪詢處理。如:xxl-job今天我們採

springboot讀取文件,打成jar包後訪問不到最新開發出現一種情況,springboot打成jar包後讀取不到文件,原因是打包之後,文件的虛擬路徑是無效的,只能通過流去讀取。文件在resources下publicvoidtest(){Listnames=newArrayList();InputStreamReaderread=null;try{ClassPathResourceresource=newClassPathResource("name.txt");Input

在Springboot+Mybatis-plus不使用SQL語句進行多表添加操作我所遇到的問題準備工作在測試環境下模擬思維分解一下:創建出一個帶有參數的BrandDTO對像模擬對後台傳遞參數我所遇到的問題我們都知道,在我們使用Mybatis-plus中進行多表操作是極其困難的,如果你不使用Mybatis-plus-join這一類的工具,你只能去配置對應的Mapper.xml文件,配置又臭又長的ResultMap,然後再寫對應的sql語句,這種方法雖然看上去很麻煩,但具有很高的靈活性,可以讓我們

1.自訂RedisTemplate1.1、RedisAPI預設序列化機制基於API的Redis快取實作是使用RedisTemplate範本進行資料快取操作的,這裡開啟RedisTemplate類,查看該類別的源碼資訊publicclassRedisTemplateextendsRedisAccessorimplementsRedisOperations,BeanClassLoaderAware{//聲明了value的各種序列化方式,初始值為空@NullableprivateRedisSe

SpringBoot和SpringMVC都是Java開發中常用的框架,但它們之間有一些明顯的差異。本文將探究這兩個框架的特點和用途,並對它們的差異進行比較。首先,我們來了解一下SpringBoot。 SpringBoot是由Pivotal團隊開發的,它旨在簡化基於Spring框架的應用程式的建立和部署。它提供了一種快速、輕量級的方式來建立獨立的、可執行

在專案中,很多時候需要用到一些配置信息,這些信息在測試環境和生產環境下可能會有不同的配置,後面根據實際業務情況有可能還需要再做修改。我們不能將這些設定在程式碼中寫死,最好是寫到設定檔中,例如可以把這些資訊寫到application.yml檔案中。那麼,怎麼在程式碼裡取得或使用這個位址呢?有2個方法。方法一:我們可以透過@Value註解的${key}即可取得設定檔(application.yml)中和key對應的value值,這個方法適用於微服務比較少的情形方法二:在實際專案中,遇到業務繁瑣,邏
