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()
}

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

// 初始化解析器, 關聯reader對象, 數據交給由reader加工和存儲
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 // 配置源, 由初始化負責傳入的source配置源
	decoder  Decoder //  解析器
	resolver Resolver // 變量解析替換
}

func (c *config) Load() error {
    // 因為我們在入口傳入的是file對象, 所以執(zhí)行src load的時候也是file對象的 load 方法
	for _, src := range c.opts.sources {
        // 獲取文件內容(可能是一個目錄, 會存在多個文件)
		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
		}
        // 調用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)聽文件變化(調用對應的watch對象)
		go c.watch(w)
	}
    // 解析內容中是否包含 ${APPID:default} 變量
    // 如果在配置文件中存在 APPID: xx 配置, 則進行替換
    // 否則使用default默認值
	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)
}