源码角度了解Skywalking之服务端OAP的启动流程
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了源码角度了解Skywalking之服务端OAP的启动流程相关的知识，希望对你有一定的参考价值。
源码角度了解Skywalking之服务端OAP的启动流程
Skywalking的服务端OAP的逻辑对应oap-server模块，入口是server-starter子模块的OAPServerStartUp类，直接调用了server-bootstrap子模块的OAPServerBootstrap的start()方法
OAPServerBootstrap的start()方法：
public static void start()
String mode = System.getProperty("mode");
RunningMode.setMode(mode);
ApplicationConfigLoader configLoader = new ApplicationConfigLoader();
ModuleManager manager = new ModuleManager();
try
ApplicationConfiguration applicationConfiguration = configLoader.load();
manager.init(applicationConfiguration);
manager.find(TelemetryModule.NAME).provider().getService(MetricsCreator.class).createGauge("uptime",
"oap server start up time", MetricsTag.EMPTY_KEY, MetricsTag.EMPTY_VALUE)
// Set uptime to second
.setValue(System.currentTimeMillis() / 1000d);
if (RunningMode.isInitMode())
logger.info("OAP starts up in init mode successfully, exit now...");
System.exit(0);
catch (Throwable t)
logger.error(t.getMessage(), t);
System.exit(1);
- 读取系统配置的mode值，如果值为init表示初始化模式，做所有初始化的事情。如果值是no-init，表示非初始化模式，不进行存储初始化
- 创建ApplicationConfiguration对象，通过load()方法加载配置文件，具体是读取resources文件夹下的application.yml文件，然后读取系统配置，覆盖读取的application.yml文件的值
- 初始化给定的模块
- 查找指定Module中的获取相应Service，创建仪表类型指标实例标记启动时间。
- 如果是初始化模式，初始化成功后会退出OAP服务
我们具体看一下初始化模块
初始化模块
ModuleManager负责在收集器中的所有ModuleDefine
ModuleManager的init()方法：
- 获取配置所有的模块集合，配置文件中配置的都是模块名，这些都是在ModuleDefine的实现类中定义了，比如配置文件中的core对应的是ModuleDefine实现类CoreModule
- 通过SPI机制加载ModuleDefine的实现类
- 通过SPI机制加载ModuleProvider的实现类
- 遍历所有的ModuleDefine实现类，与配置文件中定义的实现类匹配，匹配成功调用prepare()方法进行初始化，否则放入map集合loadedModules中进行记录
- 添加完成准备阶段的标记
- 创建BootstrapFlow对象，启动ModuleManager对象，完成后调用notifyAfterCompleted()方法通知所有的ModuleProvider实例，表示可以对外提供服务了
ModuleDefine的准备阶段
ModuleDefine实例的prepare()方法是运行模块的准备阶段，这个方法中也会找到所有潜在的提供者，让他们也进入准备阶段
ModuleDefine的prepare()方法：
- 遍历SPI机制加载的moduleProviderLoader实现类，与配置文件中模块定义的实现类匹配，匹配成功设置ModuleProvider实例的ModuleManager和当前ModuleDefine
- 调用ModuleProvider的prepare()方法让提供者也进入准备状态，prepare()方法是ModuleProvider的抽象方法，具体方法由它的子类来实现，每个模块的prepare()方法也不同，每个模块仅对应一个ModuleProvider
BootstrapFlow创建、启动与通知
在初始化过程中，创建BootstrapFlow对象，BootstrapFlow的构造方法中创建LinkedList对象用链表集合记录模块的启动顺序，模块之间可能存在依赖，所以需要调用makeSequence()方法设定模块的加载顺序。
BootstrapFlow的start()方法：
void start(
ModuleManager moduleManager) throws ModuleNotFoundException, ServiceNotProvidedException, ModuleStartException
for (ModuleProvider provider : startupSequence)
String[] requiredModules = provider.requiredModules();
if (requiredModules != null)
for (String module : requiredModules)
if (!moduleManager.has(module))
throw new ModuleNotFoundException(module + " is required by " + provider.getModuleName()
+ "." + provider.name() + ", but not found.");
logger.info("start the provider in module.", provider.name(), provider.getModuleName());
provider.requiredCheck(provider.getModule().services());
provider.start();
遍历所有的ModuleProvider：
- 根据ModuleProvider需要的模块名判断是否ModuleProvider中是否有需要的模块，如果没有抛出异常
- 检测模块的service是否实现了，如果没有会抛出异常
- 启动ModuleProvider
所有的ModuleProvider依次启动后回调执行notifyAfterCompleted()方法
总结
这篇文章主要讲了Skywalking的服务端OAP的启动流程，入口是server-starter模块的OAPServerStartUp类的main()方法，这一启动过程主要做的是加载server-bootstrap模块中的application.yml定义的模块定义、模块配置，然后相对应的ModuleProvider依次按顺序进行启动
❤️ 感谢大家
如果你觉得这篇内容对你挺有有帮助的话：
- 欢迎关注我❤️，点赞
以上是关于源码角度了解Skywalking之服务端OAP的启动流程的主要内容，如果未能解决你的问题，请参考以下文章
源码角度了解Skywalking之服务端OAP对服务注册与服务实例注册的处理