pinpoint源码学习--agent的启动过程

1.根据官方启动脚本，我们发现这样一行

-javaagent:$AGENT_PATH/pinpoint-bootstrap-$VERSION.jar
-Dpinpoint.agentId=xxx
-Dpinpoint.applicationName=xxx

• javaagent
  pinpoint基于java instrument实现，java instrument定义：开发者可以构建一个独立于应用程序的代理程序（Agent），用来监测和协助运行在 JVM 上的程序，甚至能够替换和修改某些类的定义。
  参考文档：https://blog.csdn.net/GV7lZB0y87u7C/article/details/79860776
• pinpoint-bootstrap-$VERSION.jar
  找到pinpoint-bootstrap源码包，我们找到带有premain方法的类PinpointBootStrap

classPathResolver.verify()

在这个方法里，可以知道加载了这四个jar

static final Pattern DEFAULT_AGENT_PATTERN = Pattern.compile("pinpoint-bootstrap" +VERSION_PATTERN + "\\.jar");
static final Pattern DEFAULT_AGENT_COMMONS_PATTERN = Pattern.compile("pinpoint-commons" + VERSION_PATTERN + "\\.jar");
static final Pattern DEFAULT_AGENT_CORE_PATTERN = Pattern.compile("pinpoint-bootstrap-core" + VERSION_PATTERN + "\\.jar");
static final Pattern DEFAULT_AGENT_CORE_OPTIONAL_PATTERN = Pattern.compile("pinpoint-bootstrap-core-optional" + VERSION_PATTERN + "\\.jar");

利用1.6之后的java新特性加载pinpoint-commons,bootstrap-core,pinpoint-bootstrap-core-optional三个jar

appendToBootstrapClassLoader(instrumentation, bootstrapJarFile);

PinpointStarter.java加载插件

// PinpointStarter的start方法加载插件的路径
URL[] pluginJars = classPathResolver.resolvePlugins();
...
// 加载插件
TraceMetadataLoaderService typeLoaderService = new DefaultTraceMetadataLoaderService(pluginJars, loggerFactory);

通过PluginLoader加载，封装ClassLoader

public static <T> List<T> load(Class<T> serviceType, URL[] urls) {
        URLClassLoader classLoader = createPluginClassLoader(urls, ClassLoader.getSystemClassLoader());
        return load(serviceType, classLoader);
    }

这里加载的是TraceMetadataProvider.class这个接口的所有插件里面的实现类并执行setup方法
然后将setup加载的svicetype与code加载进来并存储

 ServiceTypeRegistryService serviceTypeRegistryService  = new DefaultServiceTypeRegistryService(typeLoaderService, loggerFactory);
 AnnotationKeyRegistryService annotationKeyRegistryService = new DefaultAnnotationKeyRegistryService(typeLoaderService, loggerFactory);

之后加载你的额外配置，默认加载pinpoint.config

// 加载pinpoint额外配置，先从虚拟机获取配置文件地址，没有默认pinpoint.config位置
String configPath = getConfigPath(classPathResolver);
...
// 日志地址存入系统
saveLogFilePath(classPathResolver);
// 版本存入系统
savePinpointVersion();
// 加载配置并赋值
ProfilerConfig profilerConfig = DefaultProfilerConfig.load(configPath);
 // 创建pinpoint-commons,bootstrap-core,pinpoint-bootstrap-core-optional三个jar的类加载器
AgentClassLoader agentClassLoader = new AgentClassLoader(libUrlList.toArray(new URL[libUrlList.size()]));

创建pinpointAgent

// 创建代理选项
AgentOption option = createAgentOption(agentId, applicationName, profilerConfig, instrumentation, pluginJars, bootstrapJarFile, serviceTypeRegistryService, annotationKeyRegistryService);
// 获取代理类，默认DefaultAgent
Agent pinpointAgent = agentClassLoader.boot(option);

创建过程中涉及字节码加载技术的选择与插件的执行

// 拦截器初始大小设置
createInterceptorRegistry(agentOption)
// 指定字节码加载技术,支持ASM与JAVASSIST
this.classPool = createInstrumentEngine(agentOption, interceptorRegistryBinder);
...
// 生成插件
final List<ProfilerPlugin> plugins = PluginLoader.load(ProfilerPlugin.class, new URL[] { jar });
// 插件setup方法执行
PluginConfig pluginConfig = new PluginConfig(jar, plugin, agent.getInstrumentation(), agent.getClassPool(), agent.getBootstrapJarPaths(), pluginFilterChain);
final DefaultProfilerPluginContext context = setupPlugin(pluginConfig);
// 插件注入TransformTemplate
final TransformTemplate transformTemplate = new TransformTemplate(guardInstrumentContext);
((TransformTemplateAware) plugin).setTransformTemplate(transformTemplate);
// 执行插件类setup方法，里面组装写好的Interceptor信息并放入拦截器链InterceptorRegistry
plugin.setup(guardPluginContext);
...

DefaultAgent的start方法处理信息的收集与发送

// 定时任务收集与发送（两个定时任务处理）
pinpointAgent.start();

最后优雅停机

// 优雅停机
registerShutdownHook(pinpointAgent);