记录日志改为异步执行

main
钱涛 6 months ago
parent be73545d57
commit 6bd7791c0e

@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.parser.Feature; import com.alibaba.fastjson.parser.Feature;
import com.alibaba.fastjson.serializer.SerializerFeature; import com.alibaba.fastjson.serializer.SerializerFeature;
import com.cloudstore.dev.api.util.Util_DataCache;
import com.engine.hrmelog.annotation.ElogTransform; import com.engine.hrmelog.annotation.ElogTransform;
import com.engine.hrmelog.async.LoggerMessageListener; import com.engine.hrmelog.async.LoggerMessageListener;
import com.engine.hrmelog.entity.dto.LoggerContext; import com.engine.hrmelog.entity.dto.LoggerContext;
@ -23,12 +24,13 @@ import java.lang.reflect.Field;
import java.util.*; import java.util.*;
/** /**
* @ClassName: LoggerTemplate *
* @Description * <p>Copyright: Copyright (c) 2024</p>
* @Author tanghj * <p>Company: </p>
* @Date 2021/2/10 14:18 *
*/ * @author qiantao
// * @version 1.0
**/
public class LoggerTemplate { public class LoggerTemplate {
protected String function = "common"; protected String function = "common";
@ -89,8 +91,13 @@ public class LoggerTemplate {
this.localQueue = (StringUtils.isNotEmpty(this.moduleName) ? this.moduleName : elogLocalQueue) + "LocalQueue" + publishkitGroup; this.localQueue = (StringUtils.isNotEmpty(this.moduleName) ? this.moduleName : elogLocalQueue) + "LocalQueue" + publishkitGroup;
} }
try { try {
new Thread() {
@Override
public void run() {
handleContext(context); handleContext(context);
loggerMessageListener.receiveold(context); loggerMessageListener.receiveold(context);
}
}.start();
} catch (Exception e) { } catch (Exception e) {
logger.error("日志写入方法异常!{}", e.getMessage(), e); logger.error("日志写入方法异常!{}", e.getMessage(), e);
} }

Loading…
Cancel
Save