func init() {
	flag.StringVar(&commonconf, "common", "./configs/local", "common config path, eg: -conf config.yaml")
	flag.StringVar(&flagconf, "conf", "./configs/local/api", "config path, eg: -conf config.yaml")
    flag.Parse()
}

//初始化配置
//新增兩個(gè)配置源, 文件格式 common and flagconf 路徑
c := config.New(
    config.WithSource(
        file.NewSource(commonconf),
        file.NewSource(flagconf),
    ),
)
// 關(guān)閉watch相關(guān)的監(jiān)聽器
defer c.Close()
// 加載配置文件
if err := c.Load(); err != nil {
	panic(err)
}
//解析配置到bc結(jié)構(gòu)上
var bc conf.Bootstrap
if err := c.Scan(&bc); err != nil {
    panic(err)
}

// 初始化解析器, 關(guān)聯(lián)reader對(duì)象, 數(shù)據(jù)交給由reader加工和存儲(chǔ)
func New(opts ...Option) Config {
	o := options{
		decoder:  defaultDecoder,
		resolver: defaultResolver,
	}
	for _, opt := range opts {
		opt(&o)
	}
	return &config{
		opts:   o,
		reader: newReader(o),
	}
}

type options struct {
	sources  []Source // 配置源, 由初始化負(fù)責(zé)傳入的source配置源
	decoder  Decoder //  解析器
	resolver Resolver // 變量解析替換
}

func (c *config) Load() error {
    // 因?yàn)槲覀冊(cè)谌肟趥魅氲氖莊ile對(duì)象, 所以執(zhí)行src load的時(shí)候也是file對(duì)象的 load 方法
	for _, src := range c.opts.sources {
        // 獲取文件內(nèi)容(可能是一個(gè)目錄, 會(huì)存在多個(gè)文件)
		kvs, err := src.Load()
		if err != nil {
			return err
		}
		for _, v := range kvs {
			log.Debugf("config loaded: %s format: %s", v.Key, v.Format)
		}
        // 合并配置key
		if err = c.reader.Merge(kvs...); err != nil {
			log.Errorf("failed to merge config source: %v", err)
			return err
		}
        // 調(diào)用file watch, 監(jiān)聽文件變化
		w, err := src.Watch()
		if err != nil {
			log.Errorf("failed to watch config source: %v", err)
			return err
		}
		c.watchers = append(c.watchers, w)
        // 異步監(jiān)聽文件變化(調(diào)用對(duì)應(yīng)的watch對(duì)象)
		go c.watch(w)
	}
    // 解析內(nèi)容中是否包含 ${APPID:default} 變量
    // 如果在配置文件中存在 APPID: xx 配置, 則進(jìn)行替換
    // 否則使用default默認(rèn)值
	if err := c.reader.Resolve(); err != nil {
		log.Errorf("failed to resolve config source: %v", err)
		return err
	}
	return nil
}

func (c *config) watch(w Watcher) {
	for {
		kvs, err := w.Next()
		if err != nil {
			if errors.Is(err, context.Canceled) {
				log.Infof("watcher's ctx cancel : %v", err)
				return
			}
			time.Sleep(time.Second)
			log.Errorf("failed to watch next config: %v", err)
			continue
		}
    	// 處理邏輯忽略 .....
		c.cached.Range(func(key, value interface{}) bool {
			k := key.(string)
			v := value.(Value)
			if n, ok := c.reader.Value(k); ok && reflect.TypeOf(n.Load()) == reflect.TypeOf(v.Load()) && !reflect.DeepEqual(n.Load(), v.Load()) {
				v.Store(n.Load())
				if o, ok := c.observers.Load(k); ok {
					o.(Observer)(k, v)
				}
			}
			return true
		})
	}
}

var bc conf.Bootstrap
if err := c.Scan(&bc); err != nil {
    panic(err)
}