> 文章列表 > skyWalking自动建表-逻辑梳理

skyWalking自动建表-逻辑梳理

skyWalking自动建表-逻辑梳理

skyWalking自动建表-逻辑梳理

使用skyWalking后,发现我们不需要创建表,启动skywalking会自动创建表,遂研究官方源码,感觉oap-server设计的自动建表功能很强大,并进行逻辑梳理,仅供参考。

源码地址:https://github.com/apache/skywalking.git

架构图

skyWalking自动建表-逻辑梳理

  • Agent(代理/探针) :负责从应用中,无侵入式的收集,并通过HTTP或者gRPC方式发送数据到SkyWalking OAP 服务器;
  • SkyWalking OAP :负责接收Agent发送的Tracing数据信息,然后进行分析(Analysis Core),存储到外部存储器(Storage),最终提供查询(Query)功能;
  • Storage:Tracing数据存储,目前支持ES、MySQL、Sharding Sphere、TiDB、H2等多种存储器,SkyWalking开发团队自己的生产环境采用ES为主;
  • SkyWalking UI:负责提供控制台,查看链路等等;

建表逻辑

1、启动时执行脚本
skyWalking自动建表-逻辑梳理

2、脚本内容指向:org.apache.skywalking.oap.server.starter.OAPServerStartUp
skyWalking自动建表-逻辑梳理

3、进行初始化操作
skyWalking自动建表-逻辑梳理

4、moduleManager#init方法调用BootstrapFlow#start方法,BootstrapFlow#start调用ModuleProvider#start方法
skyWalking自动建表-逻辑梳理

5、抽象类ModuleProvider#start方法实现类JDBCStorageProvider#start方法,此方法开始调用 modelInstaller#start方法用于重写列,使语法兼容MySQL,然后调用StorageModels#addModelListener方法用于把创建或修改表的操作通知到ModelInstaller#whenCreating
skyWalking自动建表-逻辑梳理

6、收到通知后,ModelInstaller#whenCreating开始建表操作
skyWalking自动建表-逻辑梳理

7、方法内部依次进行 1.创建/更新 表字段;2.添加/更新 字段索引;3.创建/更新 关联表的字段及索引
skyWalking自动建表-逻辑梳理

8、为表添加ID字段、普通字段;添加字段类型及长度;执行建表SQL
skyWalking自动建表-逻辑梳理

9、添加字段类型,进行字段长度转换
skyWalking自动建表-逻辑梳理

济南医保科普网