Sleuth+logback 設(shè)置traceid 及自定義信息方式
更新時(shí)間：2021年07月26日 11:42:58 作者：duolantu
這篇文章主要介紹了Sleuth+logback 設(shè)置traceid 及自定義信息方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
Sleuth+logback 設(shè)置traceid及自定義信息
背景：
分布式系統(tǒng)中，如何快速定位某個(gè)用戶(hù)的請(qǐng)求日志？
使用Sleuth生成的traceid可以跟蹤某個(gè)請(qǐng)求，但是很多時(shí)候我們需要知道traceid 與某個(gè)用戶(hù)的映射關(guān)系，方便定位某個(gè)用戶(hù)的日志
方案：
@Component
@Order(TraceWebServletAutoConfiguration.TRACING_FILTER_ORDER + 1)
public class CustomHttpSpanExtractor extends GenericFilterBean {
private final Tracer tracer;
CustomHttpSpanExtractor(Tracer tracer) {
this.tracer = tracer;
}
@Override
public void doFilter(ServletRequest request, ServletResponse response,
FilterChain chain) throws IOException, ServletException {
Span currentSpan = this.tracer.currentSpan();
if (currentSpan == null) {
chain.doFilter(request, response);
return;
}
HttpServletRequest httpRequest = (HttpServletRequest) request;
try {
// mdc(httpRequest,currentSpan.context().traceIdString());
MDC.put(MdcConstant.USER_ID,"userid-12345");
} catch (Exception e) {
e.printStackTrace();
}
try {
chain.doFilter(request, response);
} finally {
MDC.clear();//must be,threadLocal
}
}}
logback 配置
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS}[${applicationName},%X{X-B3-TraceId:-},%X{userId:-}] [%thread] %-5level %logger{50} - %msg%n</pattern>
logback簡(jiǎn)單使用，自定義key
1.logback的pom依賴(lài)
<dependency>
<groupId>net.logstash.logback</groupId>
<artifactId>logstash-logback-encoder</artifactId>
<version>4.11</version>
</dependency>
2.配置文件: logback.xml
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="false" scanPeriod="5000" debug="false">
<springProperty scope="context" name="springAppName" source="spring.application.name" defaultValue="defaultAppName"/>
<timestamp key="bySecond" datePattern="yyyy-MM-dd HH:mm:ss"/>
<appender name="STASH-REDIS" class="com.jlb.yts.common.util.aop.RedisAppender">
<key>${springAppName:-}</key>
<!-- <filter class="ch.qos.logback.classic.filter.LevelFilter">
<level>ALL</level>
<onMatch>ACCEPT</onMatch>
<onMismatch>DENY</onMismatch>
</filter> -->
<layout>
<pattern>
{
"time": "%d{yyyy-MM-dd HH:mm:ss}",
"application":"tech_cloud",
"subapplication":"${springAppName:-}",
"level": "%level",
"trace": "%X{X-B3-TraceId:-}",
"span": "%X{X-B3-SpanId:-}",
"parent": "%X{X-B3-ParentSpanId:-}",
"classname": "%logger{100}",
"msg": "%message"
}
</pattern>
</layout>
</appender>
<appender name="ASYNC" class="ch.qos.logback.classic.AsyncAppender">
<!-- 不丟失日志.默認(rèn)的,如果隊(duì)列的80%已滿(mǎn),則會(huì)丟棄TRACT、DEBUG、INFO級(jí)別的日志 -->
<discardingThreshold>0</discardingThreshold>
<!-- 更改默認(rèn)的隊(duì)列的深度,該值會(huì)影響性能.默認(rèn)值為256 -->
<queueSize>5120</queueSize>
<appender-ref ref="STASH-REDIS" />
</appender>
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder charset="UTF-8">
<pattern>%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{40} - %msg%n</pattern>
</encoder>
</appender>
<logger name="com.jlb.yts" additivity="true" level="ERROR">
<appender-ref ref="ASYNC" />
</logger>
<logger name="com.jlb.yts" additivity="true" level="INFO">
<appender-ref ref="ASYNC" />
</logger>
<!-- mongodb打印語(yǔ)句 -->
<logger name="org.springframework.data.mongodb.core" level="DEBUG"/>
<logger name="com.jlb.yts" additivity="true" level="DEBUG">
<appender-ref ref="ASYNC" />
</logger>
<root level="INFO">
<appender-ref ref="STDOUT" />
</root>
</configuration>
3.自定義appender
package com.jlb.yts.common.util.aop;
import ch.qos.logback.classic.spi.ILoggingEvent;
import ch.qos.logback.classic.spi.IThrowableProxy;
import ch.qos.logback.classic.spi.LoggingEvent;
import ch.qos.logback.classic.spi.StackTraceElementProxy;
import ch.qos.logback.core.Layout;
import ch.qos.logback.core.UnsynchronizedAppenderBase;
import ch.qos.logback.core.filter.Filter;
import com.jlb.yts.common.util.redis.RedisHandle;
import com.jlb.yts.common.util.redis.ReidsConnect;
import net.logstash.logback.layout.LoggingEventCompositeJsonLayout;
import java.lang.reflect.Field;
public class RedisAppender extends UnsynchronizedAppenderBase<ILoggingEvent> {
public static String service;
Layout<ILoggingEvent> layout;
public void setFilter(Filter<ILoggingEvent> filter) {
if(filter != null){
this.addFilter(filter);
}
}
String key = null;
public RedisAppender() {
layout = new LoggingEventCompositeJsonLayout();
}
private final static RedisHandle redisHandle = ReidsConnect.init("redis-log.properties","redis-log.properties");
@Override
protected void append(ILoggingEvent event) {
try {
LoggingEvent loggingEvent = (LoggingEvent) event;
String json = layout.doLayout(loggingEvent);
redisHandle.addList(key,json);
} catch (Exception e) {
e.printStackTrace();
} finally {
}
}
public String getKey() {
return key;
}
public void setKey(String key) {
String prefix = (System.getenv("APPLICATION_ENV") == null)?"dev":System.getenv("APPLICATION_ENV");
key = prefix + "-" + key;
this.key = key;
}
public Layout<ILoggingEvent> getLayout() {
return layout;
}
public void setLayout(Layout<ILoggingEvent> layout) {
this.layout = layout;
}
}
4.代碼實(shí)例
//注意導(dǎo)入的包都是slf4j的包
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class LogbackTest {
private static final Logger LOGGER = LoggerFactory.getLogger(LogbackTest.class);
public static void main(String[] args) {
LOGGER.trace("logback的--trace日志--輸出了");
LOGGER.debug("logback的--debug日志--輸出了");
LOGGER.info("logback的--info日志--輸出了");
LOGGER.warn("logback的--warn日志--輸出了");
LOGGER.error("logback的--error日志--輸出了");
}
}
5.日志添加自定義KEY
import org.slf4j.MDC; MDC.put(key, value);
logback.xml 配置
"key":"%X{key:-}"
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要給大家介紹了關(guān)于Java如何實(shí)現(xiàn)單鏈表的增刪改查的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-04-04
這篇文章給大家介紹了spring本地事務(wù)失效的情況原因分析,給大家羅列了五種原因分析,通過(guò)代碼示例介紹的非常詳細(xì),具有一定的參考價(jià)值,需要的朋友可以參考下2023-10-10
想知道如何用Java讀取圖片的拍攝時(shí)間嗎？在這篇指南中,我將向你展示如何利用Java編程語(yǔ)言輕松獲取圖像的拍攝時(shí)間信息,不要錯(cuò)過(guò)這個(gè)簡(jiǎn)單而有用的技巧！2023-12-12
java-collection中的null,isEmpty用法
這篇文章主要介紹了java-collection中的null,isEmpty用法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-02-02
idea使用外置tomcat配置springboot詳細(xì)步驟
昨天小編遇到一個(gè)問(wèn)題使用springboot自帶的tomcat啟動(dòng)沒(méi)有任何問(wèn)題，不知道idea使用外置tomcat配置springboot該如何設(shè)置的，今天小編給大家分享一篇教程幫助大家解決這個(gè)問(wèn)題2021-07-07
AOP是一種思想,是對(duì)某一類(lèi)事情的集中處理,切面就是指某一類(lèi)特定的問(wèn)題,所以AOP可以理解為面向特定方法編程,這篇文章主要介紹了Spring AOP的實(shí)現(xiàn)方式,需要的朋友可以參考下2024-02-02
Spring?Boot多個(gè)定時(shí)任務(wù)阻塞問(wèn)題的解決方法
在日常的項(xiàng)目開(kāi)發(fā)中,往往會(huì)涉及到一些需要做到定時(shí)執(zhí)行的代碼,下面這篇文章主要給大家介紹了關(guān)于Spring?Boot多個(gè)定時(shí)任務(wù)阻塞問(wèn)題的解決方法,需要的朋友可以參考下2022-01-01
這篇文章主要介紹了如何利用Java實(shí)現(xiàn)圖片裁剪功能，可以將圖片按照自定義尺寸進(jìn)行裁剪，文中的示例代碼講解詳細(xì)，感興趣的可以了解一下2022-01-01
spring security動(dòng)態(tài)配置url權(quán)限的2種實(shí)現(xiàn)方法
對(duì)于使用spring security來(lái)說(shuō)，存在一種需求，就是動(dòng)態(tài)去配置url的權(quán)限，即在運(yùn)行時(shí)去配置url對(duì)應(yīng)的訪問(wèn)角色。下面這篇文章主要給大家介紹了關(guān)于spring security動(dòng)態(tài)配置url權(quán)限的2種實(shí)現(xiàn)方法，需要的朋友可以參考下2018-06-06
STW，即Stop The World，這篇文章來(lái)為大家詳細(xì)介紹了JVM中是如何做到STW使程序暫停的原理分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助2022-01-01