测试接口： get请求，返回一个字符串
测试命令： ab -n100000 -c50 url(10万请求 50并发量)
-
不使用agent，qps: 11765.16
-
使用agent，qps: 10760.62
7 遇到的问题总结
7.1 java.lang.NoClassDefFoundError
该异常的主要 原因是classloader问题，agent运行的classloader为app classloader（默认），springboot的classloader为JarLauncher（parent为app classloader）。
因为双亲委派机制，如果agent使用了JarLauncher加载的class，会报上述错误。
解决方法： 将 使用JarLauncher加载的class的class文件打包成jar包，自己新建个AgentClassLoader（parent为JarLauncher）来加载jar包 和 创建对象。
7.2 agent无法attach问题
bytebuddy有2套annotation api来处理aop逻辑，一套是implemetaion下的注解，另一套是adivce api 。
解决方法： 使用advice api， 只有这套注解是支持attach的
7.3 agent如何detach
ResettableClassFileTransformer resettable = new AgentBuilder.Default()
.disableClassFormatChanges()
//忽略classes的匹配规则（不拦截）
.ignore(IgnoreTypes.INSTANCE.get()) .with(AgentBuilder.RedefinitionStrategy.RETRANSFORMATION)
.with(new AgentListener())
//定义被拦截class的匹配规则
.type(MatchTypes.INSTANCE.get(enhanceClassDefineList)) //拦截class做增强处理
.transform(new Transformers(enhanceClassDefineList))
.installOn(inst);
//attach模式agent卸载
if (isRuntimeAttach) { ProcessWatcher.watch(AgentSpyApi.getAttacherPid())
.checkIntervalMills(1000)
.onShutdown(() -> {
//agent卸载
resettable.reset(inst, AgentBuilder.RedefinitionStrategy.RETRANSFORMATION);
//重置attach相关的值
AgentSpyApi.destroy();
System.out.println("TrafficCaptureAgent stopped successfully!");
LOGGER.info("TrafficCaptureAgent stopped successfully!");
}).start();
}
resettable.reset(inst, AgentBuilder.RedefinitionStrategy.RETRANSFORMATION);
触发机制: 监听attacher进程号
7.4 advice api使用坑
绑定参数案例：
newBuilder.visit(Advice.withCustomMapping()
.bind(AInterceptorClass.class, methodsInterceptPoint.interceptorClass())
//拦截器代理
.to(MethodsInterceptorDelegator.class) //被拦截的方法匹配规则
.on(methodsInterceptPoint.methodMatcher()));
具体使用案例：
@Advice.OnMethodEnter
public static InterceptorContext enter(@Advice.This Object target,
@Advice.Origin Method method,
@Advice.AllArguments(readOnly = false, typing = Assigner.Typing.DYNAMIC) Object[] allArguments,
@AInterceptorClass String interceptorClass) { InterceptorContext context = new InterceptorContext(target, method, allArguments, method.getParameterTypes());
try { MethodsInterceptor interceptor = InterceptorClassLoader.load(interceptorClass,
Thread.currentThread().getContextClassLoader());
interceptor.beforeMethod(context);
allArguments = context.getArguments();
} catch (Throwable t) { LOGGER.error(t, "class[%s] before method[%s] intercept failure", target.getClass(), method.getName());
} return context;
}
@Advice.OnMethodExit(onThrowable = Throwable.class)
public static void exit(@Advice.Enter InterceptorContext context,
@Advice.Return(readOnly = false, typing = Assigner.Typing.DYNAMIC) Object ret,
@Advice.Thrown Throwable thrown,
@AInterceptorClass String interceptorClass) { try {
MethodsInterceptor interceptor = InterceptorClassLoader.load(interceptorClass,
Thread.currentThread().getContextClassLoader());
Object newRet = ret;
interceptor.afterMethod(context, newRet, thrown);
ret = newRet;
} catch (Throwable t) { LOGGER.error(t, "class[%s] after method[%s] intercept failure", context.getObjInst().getClass(),
context.getMethod().getName());
}}
@Advice.AllArguments(readOnly = false, typing = Assigner.Typing.DYNAMIC) Object[] allArguments readOnly=false 代表可修改该对象；
typing = Assigner.Typing.DYNAMIC 不用指定具体类型来接收参数，每次获取到的allArguments是一份浅拷贝数据