提交 7553dff4 编写于 作者: wu-sheng's avatar wu-sheng

set a new interceptor point for log4j2 to output traceid.

上级 7545ebcc
package com.a.eye.skywalking.toolkit.log4j.v2.x;
/**
* Created by wusheng on 2016/12/11.
*/
public class Log4j2OutputAppender {
public static void append(StringBuilder toAppendTo){
toAppendTo.append("TID: N/A");
}
}
...@@ -29,6 +29,6 @@ public class TraceIdConverter extends LogEventPatternConverter { ...@@ -29,6 +29,6 @@ public class TraceIdConverter extends LogEventPatternConverter {
@Override @Override
public void format(LogEvent event, StringBuilder toAppendTo) { public void format(LogEvent event, StringBuilder toAppendTo) {
toAppendTo.append("TID: N/A"); Log4j2OutputAppender.append(toAppendTo);
} }
} }
package com.a.eye.skywalking.toolkit.activation.log4j.v2.x; package com.a.eye.skywalking.toolkit.activation.log4j.v2.x;
import com.a.eye.skywalking.plugin.interceptor.ConstructorInterceptPoint;
import com.a.eye.skywalking.plugin.interceptor.InstanceMethodsInterceptPoint;
import com.a.eye.skywalking.plugin.interceptor.MethodMatcher; import com.a.eye.skywalking.plugin.interceptor.MethodMatcher;
import com.a.eye.skywalking.plugin.interceptor.enhance.ClassInstanceMethodsEnhancePluginDefine; import com.a.eye.skywalking.plugin.interceptor.StaticMethodsInterceptPoint;
import com.a.eye.skywalking.plugin.interceptor.enhance.ClassStaticMethodsEnhancePluginDefine;
import com.a.eye.skywalking.plugin.interceptor.matcher.SimpleMethodMatcher; import com.a.eye.skywalking.plugin.interceptor.matcher.SimpleMethodMatcher;
/** /**
* Created by wusheng on 2016/12/7. * Created by wusheng on 2016/12/7.
*/ */
public class TraceIdConverterActivation extends ClassInstanceMethodsEnhancePluginDefine { public class Log4j2OutputAppenderActivation extends ClassStaticMethodsEnhancePluginDefine {
@Override @Override
protected String enhanceClassName() { protected String enhanceClassName() {
return "com.a.eye.skywalking.toolkit.log4j.v2.x.TraceIdConverter"; return "com.a.eye.skywalking.toolkit.log4j.v2.x.Log4j2OutputAppender";
} }
@Override @Override
protected ConstructorInterceptPoint[] getConstructorsInterceptPoints() { protected StaticMethodsInterceptPoint[] getStaticMethodsInterceptPoints() {
return null; return new StaticMethodsInterceptPoint[]{new StaticMethodsInterceptPoint() {
}
@Override
protected InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints() {
return new InstanceMethodsInterceptPoint[]{new InstanceMethodsInterceptPoint() {
@Override @Override
public MethodMatcher[] getMethodsMatchers() { public MethodMatcher[] getMethodsMatchers() {
return new MethodMatcher[]{new SimpleMethodMatcher("format")}; return new MethodMatcher[]{new SimpleMethodMatcher("append")};
} }
@Override @Override
......
...@@ -2,16 +2,14 @@ package com.a.eye.skywalking.toolkit.activation.log4j.v2.x; ...@@ -2,16 +2,14 @@ package com.a.eye.skywalking.toolkit.activation.log4j.v2.x;
import com.a.eye.skywalking.api.Tracing; import com.a.eye.skywalking.api.Tracing;
import com.a.eye.skywalking.plugin.interceptor.EnhancedClassInstanceContext; import com.a.eye.skywalking.plugin.interceptor.EnhancedClassInstanceContext;
import com.a.eye.skywalking.plugin.interceptor.enhance.InstanceMethodInvokeContext; import com.a.eye.skywalking.plugin.interceptor.enhance.*;
import com.a.eye.skywalking.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor;
import com.a.eye.skywalking.plugin.interceptor.enhance.MethodInterceptResult;
/** /**
* Created by wusheng on 2016/12/7. * Created by wusheng on 2016/12/7.
*/ */
public class PrintTraceIdInterceptor implements InstanceMethodsAroundInterceptor { public class PrintTraceIdInterceptor implements StaticMethodsAroundInterceptor {
@Override @Override
public void beforeMethod(EnhancedClassInstanceContext context, InstanceMethodInvokeContext interceptorContext, MethodInterceptResult result) { public void beforeMethod(StaticMethodInvokeContext interceptorContext, MethodInterceptResult result) {
((StringBuilder)interceptorContext.allArguments()[1]).append("TID:" + Tracing.getTraceId()); ((StringBuilder)interceptorContext.allArguments()[1]).append("TID:" + Tracing.getTraceId());
//make sure origin method do not invoke. //make sure origin method do not invoke.
...@@ -19,12 +17,12 @@ public class PrintTraceIdInterceptor implements InstanceMethodsAroundInterceptor ...@@ -19,12 +17,12 @@ public class PrintTraceIdInterceptor implements InstanceMethodsAroundInterceptor
} }
@Override @Override
public Object afterMethod(EnhancedClassInstanceContext context, InstanceMethodInvokeContext interceptorContext, Object ret) { public Object afterMethod(StaticMethodInvokeContext interceptorContext, Object ret) {
return ret; return null;
} }
@Override @Override
public void handleMethodException(Throwable t, EnhancedClassInstanceContext context, InstanceMethodInvokeContext interceptorContext) { public void handleMethodException(Throwable t, MethodInvokeContext interceptorContext) {
} }
} }
com.a.eye.skywalking.toolkit.activation.log4j.v2.x.TraceIdConverterActivation com.a.eye.skywalking.toolkit.activation.log4j.v2.x.Log4j2OutputAppenderActivation
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册