manager/my-worker
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' into v4.1_dev

Browse Source
This commit is contained in:
thinkgem
2019-11-06 00:11:38 +08:00
parent 7c4ec8e199 345b21c102
commit 2329bd10de
1 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
modules/core/src/main/java/com/jeesite/modules/sys/utils/LogUtils.java
View File

@@ -4,9 +4,14 @@
package com.jeesite.modules.sys.utils; package com.jeesite.modules.sys.utils;
import java.lang.reflect.Method; import java.lang.reflect.Method;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import io.netty.util.concurrent.DefaultThreadFactory;
import org.apache.ibatis.mapping.SqlCommandType; import org.apache.ibatis.mapping.SqlCommandType;
import org.apache.shiro.authz.annotation.RequiresPermissions; import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.core.DefaultParameterNameDiscoverer; import org.springframework.core.DefaultParameterNameDiscoverer;
@@ -39,7 +44,12 @@ import eu.bitwalker.useragentutils.UserAgent;
* @version 2017-11-7 * @version 2017-11-7
*/ */
public class LogUtils { public class LogUtils {
//采用线程池优化性能
private static ExecutorService logThreadPool = new ThreadPoolExecutor(5, 20,
60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(),
new DefaultThreadFactory("log-save"));
/** /**
* 静态内部类，延迟加载，懒汉式，线程安全的单例模式 * 静态内部类，延迟加载，懒汉式，线程安全的单例模式
*/ */
@@ -101,22 +111,21 @@ public class LogUtils {
if (ex != null){ if (ex != null){
throwable = ExceptionUtils.getThrowable(request); throwable = ExceptionUtils.getThrowable(request);
} }
// 异步保存日志 // 异步保存日志
new SaveLogThread(log, handler, request.getContextPath(), throwable).start(); logThreadPool.submit(new SaveLogTask(log, handler, request.getContextPath(), throwable));
} }
/** /**
* 保存日志线程 * 保存日志线程
*/ */
public static class SaveLogThread extends Thread{ public static class SaveLogTask extends Thread{
private Log log; private Log log;
private Object handler; private Object handler;
private String contextPath; private String contextPath;
private Throwable throwable; private Throwable throwable;
public SaveLogThread(Log log, Object handler, String contextPath, Throwable throwable){ public SaveLogTask(Log log, Object handler, String contextPath, Throwable throwable){
super(SaveLogThread.class.getSimpleName());
this.log = log; this.log = log;
this.handler = handler; this.handler = handler;
this.contextPath = contextPath; this.contextPath = contextPath;