liuchang/mall-ebtp-cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v2.1.1 kafka日志发送改为异步，添加事务排除，添加try catch异常拦截，修改异步线程池参数

Browse Source
This commit is contained in:
fuqingji
2022-03-14 08:54:11 +08:00
parent 7eaec0ffc1
commit af03c1cac5
9 changed files with 59 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
uboot-common/src/main/java/com/chinaunicom/mall/ebtp/common/log/producer/OperationLogKafkaProducer.java
View File

@ -3,6 +3,7 @@ package com.chinaunicom.mall.ebtp.common.log.producer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
/**
@ -20,7 +21,7 @@ public class OperationLogKafkaProducer {
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
@Async
public void send(String message) {
kafkaTemplate.send(TOPIC, message)
.addCallback(success -> {

64
uboot-common/src/main/java/com/chinaunicom/mall/ebtp/common/log/service/impl/OperationLogServiceImpl.java
View File

@ -1,6 +1,7 @@
package com.chinaunicom.mall.ebtp.common.log.service.impl;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.exceptions.ExceptionUtil;
import com.chinaunicom.mall.ebtp.common.base.entity.BaseCacheUser;
import com.chinaunicom.mall.ebtp.common.base.service.IBaseCacheUserService;
import com.chinaunicom.mall.ebtp.common.constant.CommonConstants;
@ -12,10 +13,13 @@ import com.chinaunicom.mall.ebtp.common.log.service.OperationLogService;
import com.chinaunicom.mall.ebtp.common.util.HttpContextUtils;
import com.chinaunicom.mall.ebtp.common.util.JsonUtils;
import com.chinaunicom.mall.ebtp.common.util.PropertyUtils;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.MDC;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import javax.servlet.http.HttpServletRequest;
import java.util.Optional;
@ -29,6 +33,8 @@ import static com.chinaunicom.mall.ebtp.cloud.security.starter.common.Constants.
* @author f
*/
@Service
@Slf4j
@Transactional(propagation = Propagation.NOT_SUPPORTED)
public class OperationLogServiceImpl implements OperationLogService {
@Autowired
@ -43,38 +49,42 @@ public class OperationLogServiceImpl implements OperationLogService {
@Override
public void addOperationLog(OperationLog operationLog) {
if (operationLog.getMethod() == null) {
StackTraceElement[] stackTrace = Thread.currentThread().getStackTrace();
for (int i = 1; i < stackTrace.length; i++) {
StackTraceElement element = stackTrace[i];
if (!element.getClassName().equals(OperationLogServiceImpl.class.getName())) {
operationLog.setPackageName(element.getClassName());
operationLog.setMethod(element.getMethodName());
break;
try {
if (operationLog.getMethod() == null) {
StackTraceElement[] stackTrace = Thread.currentThread().getStackTrace();
for (int i = 1; i < stackTrace.length; i++) {
StackTraceElement element = stackTrace[i];
if (!element.getClassName().equals(OperationLogServiceImpl.class.getName())) {
operationLog.setPackageName(element.getClassName());
operationLog.setMethod(element.getMethodName());
break;
}
}
}
}
if (operationLog.getMethod() == null) {
StackTraceElement element = Thread.currentThread().getStackTrace()[1];
operationLog.setPackageName(element.getClassName());
operationLog.setMethod(element.getMethodName());
}
BaseCacheUser user = cacheUserService.getCacheUser();
if (null != user) {
operationLog.setUser(user.setAuthorityList(null));
HttpServletRequest request = HttpContextUtils.getHttpServletRequest();
if (request != null) {
// 提取token头信息 ;
operationLog.setToken(request.getHeader(AUTHORIZATION_HEADER))
.setUrl(request.getMethod() + "." + request.getRequestURI());
if (operationLog.getMethod() == null) {
StackTraceElement element = Thread.currentThread().getStackTrace()[1];
operationLog.setPackageName(element.getClassName());
operationLog.setMethod(element.getMethodName());
}
BaseCacheUser user = cacheUserService.getCacheUser();
if (null != user) {
operationLog.setUser(user.setAuthorityList(null));
HttpServletRequest request = HttpContextUtils.getHttpServletRequest();
if (request != null) {
// 提取token头信息 ;
operationLog.setToken(request.getHeader(AUTHORIZATION_HEADER))
.setUrl(request.getMethod() + "." + request.getRequestURI());
}
}
}
operationLog.setId(PropertyUtils.getSnowflakeId())
.setTransactionId(Optional.ofNullable(operationLog.getTransactionId()).orElseGet(() -> MDC.get(CommonConstants.TRANSACTION_ID)))
.setServiceName(serviceName);
kafkaProducer.send(JsonUtils.objectToJson(operationLog));
operationLog.setId(PropertyUtils.getSnowflakeId())
.setTransactionId(Optional.ofNullable(operationLog.getTransactionId()).orElseGet(() -> MDC.get(CommonConstants.TRANSACTION_ID)))
.setServiceName(serviceName);
kafkaProducer.send(JsonUtils.objectToJson(operationLog));
} catch (Exception e) {
log.info(ExceptionUtil.stacktraceToString(e));
}
}

8
uboot-common/src/main/resources/configuration/async-pool.properties
View File

@ -1,7 +1,7 @@
#spring.task.execution.pool <20>̳߳<DFB3><CCB3><EFBFBD><EFBFBD><EFBFBD>
async.thead.pool.coreSize=200
async.thead.pool.maxSize=1000
async.thead.pool.queueCapaciry=100
async.thead.pool.keepALive=1000
async.thead.pool.coreSize=50
async.thead.pool.maxSize=200
async.thead.pool.queueCapaciry=600
async.thead.pool.keepALive=60
async.thead.pool.threadNamePrefix=ebtp-thread