目录

前言

一、TLOG开源组件集成

1.maven引入

2. 日志文件logback-spring.xml修改

二、TLOG扩展开发自己的starter

1.项目层级

2.扩展点：1.打印请求url 2.打印响应日志

a.打印请求日志中的url实现RequestBodyAdvice 

b.打印响应日志实现ResponseBodyAdvice

 c.打印内容

三、多线程与kafka消息队列，方法中traceId的传递

1.线程池

2.kafka等消息队列

前言

随着微服务盛行，很多公司都把系统按照业务边界拆成了很多微服务，在排错查日志的时候。因为业务链路贯穿着很多微服务节点，导致定位某个请求的日志以及上下游业务的日志会变得有些困难，那么今天所介绍的这款开源工具一定是一个不错的选择

一、TLOG开源组件集成

  1.maven引入

      com.yomahubtlog-all-spring-boot-starter${tlog.version}

2. 日志文件logback-spring.xml修改

${LOG_PATH}/${LOG_NAME}/log_error.log${LOG_PATH}/${LOG_NAME}/error/log-error-%d{yyyy-MM-dd}.%i.log10MBtrue%d{yyyy-MM-dd HH:mm:ss.SSS} %X{tl} [%thread] %-5level %logger{50} - %msg[%A][%R]%nerrorACCEPTDENY${LOG_PATH}/${LOG_NAME}/log_info.log${LOG_PATH}/${LOG_NAME}/info/log-info-%d{yyyy-MM-dd}.%i.log10MBtrue%d{yyyy-MM-dd HH:mm:ss.SSS} %X{tl} [%thread] %-5level %logger{50} - %msg[%A][%R]%ninfoACCEPTDENY${LOG_PATH}/${LOG_NAME}/log_all.log${LOG_PATH}/${LOG_NAME}/all/log-all-%d{yyyy-MM-dd}.%i.log10MBtrue%d{yyyy-MM-dd HH:mm:ss.SSS} %X{tl} [%thread] %-5level %logger{50} - %msg[%A][%R]%n%d{yyyy-MM-dd HH:mm:ss.SSS} %X{tl} [%thread] %-5level %logger{50} - %msg[%A][%R]%ndebug

二、TLOG扩展开发自己的starter

1.项目层级

2.扩展点：1.打印请求url 2.打印响应日志

a.打印请求日志中的url实现RequestBodyAdvice 

/*** 日志请求拦截* @author liangxi.zeng*/
@ControllerAdvice
@Component
public class LogRequestBodyAdvice implements RequestBodyAdvice {private static final Logger log = LoggerFactory.getLogger(LogRequestBodyAdvice.class);@Autowiredprivate LogProperties logProperties;@Autowiredprivate LogContext logContext;@Overridepublic boolean supports(MethodParameter methodParameter, Type type, Class> aClass) {return logProperties.getResponse().isEnabled() && !StringUtils.isEmpty(TLogContext.getTraceId());}@Overridepublic HttpInputMessage beforeBodyRead(HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class> aClass) throws IOException {return httpInputMessage;}@Overridepublic Object afterBodyRead(Object body, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class> aClass) {try {if(logProperties.getRequest().isEnabled()) {String url = logContext.getUrlTl().get();if (StringUtils.isEmpty(url)) {url = LogUtil.getUrl(methodParameter);}if (!LogUtil.isIgnore(logProperties.getRequest().getIgnoreList(), url)) {HttpHeaders headers = httpInputMessage.getHeaders();if (headers != null) {List contentTypeList = headers.get(LogUtil.CONTENT_TYPE);if (!CollectionUtils.isEmpty(contentTypeList) &&!LogUtil.isUpload(contentTypeList.get(0))) {log.info("requestBody参数:{}", JSON.toJSONString(body));}}}}} catch (Exception e) {log.error("日志请求打印异常，不影响业务，吞并异常",e);}return body;}@Overridepublic Object handleEmptyBody(Object body, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class> aClass) {return body;}
}

b.打印响应日志实现ResponseBodyAdvice

/*** 脱敏日志响应拦截* @author liangxi.zeng*/
@ControllerAdvice
@Component
public class LogResponseBodyAdvice implements ResponseBodyAdvice