mirage
/
edu
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

优化: 系统日志异步写入

This commit is contained in:
TinyAnts 2023-03-16 11:26:15 +08:00
parent 65d10f608c
commit 1b56ede827
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server/like-admin/src/main/java/com/mdd/admin/aop/aspect/LogAspect.java
View File

@ -25,6 +25,8 @@ import org.springframework.web.multipart.support.StandardMultipartHttpServletReq
import javax.annotation.Resource; import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import java.lang.reflect.Method; import java.lang.reflect.Method;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@Aspect @Aspect
@ -41,6 +43,11 @@ public class LogAspect {
*/ */
private static final ThreadLocal<Long> threadLocal = new ThreadLocal<>(); private static final ThreadLocal<Long> threadLocal = new ThreadLocal<>();
/**
* 单线程化的线程池
*/
private final ExecutorService executor = Executors.newSingleThreadExecutor();
/** /**
* 声明切面点拦截那些类 * 声明切面点拦截那些类
*/ */
@ -151,7 +158,9 @@ public class LogAspect {
model.setEndTime(endTime / 1000); model.setEndTime(endTime / 1000);
model.setTaskTime(endTime - beginTime); model.setTaskTime(endTime - beginTime);
model.setCreateTime(System.currentTimeMillis() / 1000); model.setCreateTime(System.currentTimeMillis() / 1000);
systemLogOperateMapper.insert(model); executor.submit(() -> {
systemLogOperateMapper.insert(model);
});
} }
} catch (Exception ex) { } catch (Exception ex) {
log.error("异常信息:{}", ex.getMessage()); log.error("异常信息:{}", ex.getMessage());