【底座】启动配置增加应用名称,底座增加traceId机制;

pull/269/head
dongxiayu 2025-06-08 23:16:32 +08:00
parent a4d45fab44
commit 936ce722e8
7 changed files with 196 additions and 2 deletions

View File

@ -0,0 +1,52 @@
/*
* Copyright [2022] [https://www.xiaonuo.vip]
*
* SnowyAPACHE LICENSE 2.0使
*
* 1.LICENSE
* 2.Snowy
* 3.使使
* 4. https://www.xiaonuo.vip
* 5.xiaonuobase@qq.com
* 6.Snowy https://www.xiaonuo.vip
*/
package vip.xiaonuo.common.aspect;
import ch.qos.logback.classic.pattern.ClassicConverter;
import ch.qos.logback.classic.spi.ILoggingEvent;
import org.springframework.stereotype.Component;
import vip.xiaonuo.common.util.CommonTraceIdUtil;
/**
* traceId
*
* @author dongxiayu
* @date 2025/1/9 15:36
*/
@Component
public class CustomTraceIdConverter extends ClassicConverter {
// 使用常量避免重复创建字符串
private static final String LEFT_BRACKET = "[";
private static final String RIGHT_BRACKET = "]";
// 缓存StringBuilder以减少对象创建
private static final ThreadLocal<StringBuilder> bufferHolder =
ThreadLocal.withInitial(() -> new StringBuilder(64));
@Override
public String convert(ILoggingEvent event) {
StringBuilder buffer = bufferHolder.get();
buffer.setLength(0);
String traceId = CommonTraceIdUtil.getTraceId();
buffer.append(LEFT_BRACKET);
if (traceId != null && !traceId.isEmpty()) {
buffer.append(traceId);
} else {
buffer.append(event.getThreadName());
}
buffer.append(RIGHT_BRACKET);
return buffer.toString();
}
}

View File

@ -0,0 +1,42 @@
/*
* Copyright [2022] [https://www.xiaonuo.vip]
*
* SnowyAPACHE LICENSE 2.0使
*
* 1.LICENSE
* 2.Snowy
* 3.使使
* 4. https://www.xiaonuo.vip
* 5.xiaonuobase@qq.com
* 6.Snowy https://www.xiaonuo.vip
*/
package vip.xiaonuo.common.interceptor;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.web.servlet.HandlerInterceptor;
import vip.xiaonuo.common.util.CommonTraceIdUtil;
/**
*
*
* @author dongxiayu
* @date 2025/1/10 11:42
*/
public class CommonTraceInterceptor implements HandlerInterceptor {
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
try {
CommonTraceIdUtil.getTraceId(request);
} catch (Exception e) {
return false;
}
return true;
}
@Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
CommonTraceIdUtil.clear();
HandlerInterceptor.super.afterCompletion(request, response, handler, ex);
}
}

View File

@ -14,6 +14,7 @@ package vip.xiaonuo.common.pojo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Getter;
import vip.xiaonuo.common.util.CommonTraceIdUtil;
import java.io.Serial;
import java.io.Serializable;
@ -47,6 +48,9 @@ public class CommonResult<T> implements Serializable{
@Schema(description = "返回数据")
private T data;
@Schema(description = "跟踪ID")
private String traceId;
public CommonResult() {
}
@ -54,6 +58,7 @@ public class CommonResult<T> implements Serializable{
this.setCode(code);
this.setMsg(msg);
this.setData(data);
this.setTraceId(CommonTraceIdUtil.getTraceId());
}
/**
@ -64,6 +69,14 @@ public class CommonResult<T> implements Serializable{
return this.code;
}
/**
* traceId
* @return traceId
*/
public String getTraceId() {
return this.traceId;
}
/**
* code
* @param code code
@ -94,6 +107,16 @@ public class CommonResult<T> implements Serializable{
return this;
}
/**
* traceId
* @param traceId traceId
* @return
*/
public CommonResult<T> setTraceId(String traceId) {
this.traceId = traceId;
return this;
}
// ============================ 构建 ==================================

View File

@ -0,0 +1,60 @@
/*
* Copyright [2022] [https://www.xiaonuo.vip]
*
* SnowyAPACHE LICENSE 2.0使
*
* 1.LICENSE
* 2.Snowy
* 3.使使
* 4. https://www.xiaonuo.vip
* 5.xiaonuobase@qq.com
* 6.Snowy https://www.xiaonuo.vip
*/
package vip.xiaonuo.common.util;
import cn.hutool.core.util.StrUtil;
import jakarta.servlet.http.HttpServletRequest;
import java.util.UUID;
/**
* TraceId
*
* @author dongxiayu
* @date 2025/1/9 17:07
*/
public class CommonTraceIdUtil {
public static final String TRACE_ID_STRING = "traceId";
private static final InheritableThreadLocal<String> TRACE_ID = new InheritableThreadLocal<>();
public static String generateTraceId(HttpServletRequest request) {
String header = request.getHeader(TRACE_ID_STRING);
if (header != null) {
return header;
}
return UUID.randomUUID().toString().replace(StrUtil.DASHED, StrUtil.EMPTY);
}
public static String getTraceId() {
return TRACE_ID.get();
}
public static String getTraceId(HttpServletRequest request) {
String traceId = getTraceId();
if (traceId == null) {
traceId = generateTraceId(request);
setTraceId(traceId);
}
return traceId;
}
public static void setTraceId(String traceId) {
TRACE_ID.set(traceId);
}
public static void clear() {
TRACE_ID.remove();
}
}

View File

@ -66,6 +66,7 @@ import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.jdbc.support.JdbcUtils;
import org.springframework.stereotype.Component;
import org.springframework.util.ResourceUtils;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
import vip.xiaonuo.auth.core.util.StpClientUtil;
@ -74,6 +75,7 @@ import vip.xiaonuo.common.annotation.CommonWrapper;
import vip.xiaonuo.common.cache.CommonCacheOperator;
import vip.xiaonuo.common.enums.CommonDeleteFlagEnum;
import vip.xiaonuo.common.exception.CommonException;
import vip.xiaonuo.common.interceptor.CommonTraceInterceptor;
import vip.xiaonuo.common.listener.CommonDataChangeEventCenter;
import vip.xiaonuo.common.listener.CommonDataChangeListener;
import vip.xiaonuo.common.pojo.CommonResult;
@ -702,4 +704,14 @@ public class GlobalConfigure implements WebMvcConfigurer {
public void registerListenerList(List<CommonDataChangeListener> dataChangeListenerList) {
CommonDataChangeEventCenter.registerListenerList(dataChangeListenerList);
}
/**
*
* @param registry
*/
@Override
public void addInterceptors(InterceptorRegistry registry) {
// 注册注解拦截器,并排除不需要注解鉴权的接口地址 (与登录拦截器无关,只是说明哪些接口不需要被拦截器拦截,此处都拦截)
registry.addInterceptor(new CommonTraceInterceptor()).addPathPatterns("/**");
}
}

View File

@ -2,6 +2,7 @@
# server configuration
#########################################
server.port=82
spring.application.name=snowy
#########################################
# spring allow-circular-references
@ -27,9 +28,9 @@ spring.servlet.multipart.max-file-size=100MB
# mysql
spring.datasource.dynamic.datasource.master.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.dynamic.datasource.master.url=jdbc:mysql://localhost:3306/snowy?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&useInformationSchema=true&rewriteBatchedStatements=true
spring.datasource.dynamic.datasource.master.url=jdbc:mysql://localhost:3306/snowy3-gitee?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&useInformationSchema=true&rewriteBatchedStatements=true
spring.datasource.dynamic.datasource.master.username=root
spring.datasource.dynamic.datasource.master.password=12345678
spring.datasource.dynamic.datasource.master.password=123456
spring.datasource.dynamic.strict=true
# postgres

View File

@ -4,6 +4,10 @@
<!--日志格式应用spring boot默认的格式也可以自己更改-->
<include resource="org/springframework/boot/logging/logback/defaults.xml"/>
<!-- 注册自定义转换器 -->
<conversionRule conversionWord="tid" converterClass="vip.xiaonuo.common.aspect.CustomTraceIdConverter" />
<!--定义日志存放的位置,默认存放在项目启动的相对路径的目录-->
<springProperty scope="context" name="LOG_PATH" source="log.path" defaultValue="app-log"/>