Polaris系列-02.启动分析一
创始人
2025-01-08 21:03:16
0次

直入主题:
在这里插入图片描述
里面最重要的就是上图中的启动方法:

bootstrap.Start(configFilePath) 

cmd子包分析结束,开始进入bootstrap子包。
在这里插入图片描述
第67行:

cfg, err := boot_config.Load(configFilePath) 
  • 1.读取文件内容,变成string
  • 2.使用gopkg.in/yaml.v2库反序列化yaml格式文件,把结果保存到 cfg变量中

所以你应该学会了如何读取yaml配置文件。并且里面需要说明的是,使用了一个方法:os.ExpandEnv(configContent),说明如下:

// ExpandEnv replaces ${var} or $var in the string according to the values // of the current environment variables. References to undefined // variables are replaced by the empty string. func ExpandEnv(s string) string { 	return Expand(s, Getenv) } 

即如果环境变量中配置了相应值,会替换yaml配置中的内容,熟悉Java的或者知道正则中的Matcher.appendReplacement模板替换,如下示例:
在这里插入图片描述
如果环境变量配置了 MYSQL_USER=root, 那么yaml配置内容中${MYSQL_USER} 或者 $MYSQL_USER 解析读取后的内容会被替换成 root

得到cfg数据模型后,又序列化,这是为了校验cfg的有效性?
注意下面红框,这就是控制台出现大堆配置输出的缘由:
在这里插入图片描述
至此,读取配置工作✅

2.初始化日志:这里面我想分享的是 时间轮timewheel
在这里插入图片描述
定时任务每分钟“巡检”一次:看看有没有任务被添加进来,并判断是否需要真正执行:回调任务添加者提供的callback函数
在这里插入图片描述
里面有协程,锁,通过time.Ticker任务调度 等设计理念和实战,不了解的值得去好好看看的。
上图中297行正是添加任务:处理滚动日志,这也好理解:别让一个日志文件太大,定时切割。

在这里插入图片描述
在这里插入图片描述
上图2行代码做了2件事:
1.把localHost的值保存到全局变量utils.LocalHost
2.对传入的context包了一层,添加一个kv, v正是 localHost值

return context.WithValue(ctx, localhostCtx{}, localhost) 

在这里插入图片描述
只做了一件事:把port的值保存到全局变量utils.LocalPort中
在这里插入图片描述
实际上,上述几个保存全局变量值在const.go文件中,里面的变量也就这3个:
在这里插入图片描述
4.metrics.InitMetrics() 跳过分析

InitMetrics 初始化 metrics 的所有指标 

5.eventhub.InitEventHub()

// InitEventHub initialize event hub func InitEventHub() { 	initOnce.Do(func() { 		globalEventHub = createEventhub() 	}) } 

数据模型如下:

// eventHub event hub type eventHub struct { 	ctx    context.Context 	cancel context.CancelFunc 	topics map[string]*topic // 看这里 	mu     sync.RWMutex }  type topic struct { 	name    string 	queue   chan Event // 事件队列 	closeCh chan struct{} 	subs    map[string]*subscription // 订阅者 	mu      sync.RWMutex } // Subscription subscription info type subscription struct { 	name    string 	queue   chan Event 	closeCh chan struct{} 	handler Handler 	opts    *SubOptions // 里面只有一个队列大小属性 } // Handler event handler type Handler interface { 	// PreProcess do preprocess logic for event 	PreProcess(context.Context, any) any 	// OnEvent event process logic 	OnEvent(ctx context.Context, any2 any) error } 

先对发布订阅事件模型有个大概了解,后续有机会案例分析。

6.设置插件配置:
在这里插入图片描述
只是把插件相差配置保存到全局变量中:
在这里插入图片描述
在这里插入图片描述
里面挺多配置内容的,具体可参看
在这里插入图片描述
在这里插入图片描述
因为启动过程涉及到的内容比较多,所以分多篇介绍。
本篇介绍了

  1. 启动开始 读取配置内容
  2. 初始化日志打印,使用第三方日志组件,并且使用时间轮设计处理日志滚动
  3. 初始化ip+port
  4. 初始化prometheus 度量
  5. 初始化事件发布订阅
  6. 保存插件配置到全局变量

后续有 初始化存储,启动流程,初始化插件,加载数据等。

相关内容

热门资讯

每日必看!江岸多玩到底能开挂吗... 每日必看!江岸多玩到底能开挂吗(辅助挂),江岸多玩原来真的有辅助挂讲义1、江岸多玩脚本辅助下载、江岸...
玩家交流!颖河竞技怎么开挂(外... 玩家交流!颖河竞技怎么开挂(外挂),颖河竞技好像是有外挂教材一、颖河竞技游戏安装教程牌型概率发牌机制...
最新通报!皮皮四川麻将软件下载... 最新通报!皮皮四川麻将软件下载(辅助挂),皮皮四川麻将果然有辅助挂模块1、操作简单,无需皮皮四川麻将...
一分钟揭秘!52游戏开挂脚本(... 一分钟揭秘!52游戏开挂脚本(透视挂),52游戏切实有透视挂法子52游戏脚本下载中分为三种模型:52...
一分钟快速了解!堆堆乐开挂破解... 一分钟快速了解!堆堆乐开挂破解(外挂),堆堆乐竟然真的有外挂方针1、下载好堆堆乐正确养号方法之后点击...
重大通报!汇城贵州麻将开挂脚本... 重大通报!汇城贵州麻将开挂脚本(开挂),汇城贵州麻将原来真的有开挂法门1、重大通报!汇城贵州麻将开挂...
盘点一款!七色城透视挂件(外挂... 盘点一款!七色城透视挂件(外挂),七色城切实是真的有外挂经验1、全新机制【七色城ai辅助工具激活码】...
今日头条!多多休闲透视软件下载... 今日头条!多多休闲透视软件下载(外挂),多多休闲确实是真的有外挂攻略1、首先打开多多休闲辅助器下载最...
关于!钱柜麻将真的有透视吗(辅... 关于!钱柜麻将真的有透视吗(辅助器),钱柜麻将一贯是有辅助器练习钱柜麻将能透视中分为三种模型:钱柜麻...
今日焦点!河北家乡棋牌辅助工具... 今日焦点!河北家乡棋牌辅助工具(外挂),河北家乡棋牌果然是有外挂手册小薇(辅助器软件下载)致您一封信...