app.AllKeys() 为空,但app.Get("var name")可以拿到值？ about agollo HOT 6 CLOSED

		ag, err := agollo.New(
			endpoint,
			appid,
			agollo.AutoFetchOnCacheMiss(),
			agollo.FailTolerantOnBackupExists(),
		)

package config

import (
	"fmt"
	"github.com/shima-park/agollo"
	"github.com/shima-park/agollo/viper-remote"
	"github.com/spf13/viper"
	"strings"
	"time"
)

func viperInit() {
	var (
		configFile string
		env        string
		err        error
	)

	App = viper.New()
	Local = viper.New()
	Local.AutomaticEnv()

	env = Local.GetString(envName)

	switch strings.ToLower(env) {
	case "sta":
		configFile = "sta.properties"
	case "prd":
		configFile = "prd.properties"
	default:
		configFile = "dev.properties"
	}

	Local.SetConfigFile("./config/" + configFile)
	if err = Local.ReadInConfig(); err != nil {
		panic("基础配置文件读取异常：" + err.Error())
	}

	//if err = agollo.Init(
	//	Local.GetString("APOLLO_SERVER_IP"),
	//	Local.GetString("APOLLO_ID"),
	//	agollo.BackupFile("./config/agollo.local"),
	//); err != nil {
	//	panic("agollo配置初始化失败:" + err.Error())
	//}

	_, err = agollo.New(
		Local.GetString("APOLLO_SERVER_IP"),
		Local.GetString("APOLLO_ID"),
		agollo.AutoFetchOnCacheMiss(),
		agollo.FailTolerantOnBackupExists(),
		agollo.BackupFile("./config/agollo.local"),
	)

	remote.SetAppID(Local.GetString("APOLLO_ID"))
	if err = App.AddRemoteProvider("apollo", Local.GetString("APOLLO_SERVER_IP"), Local.GetString("APOLLO_NAMESPACE")); err != nil {
		panic("阿波罗配置中心初始化失败：" + err.Error())
	}

	if err = App.ReadRemoteConfig(); err != nil {
		panic("阿波罗配置读取失败：" + err.Error())
	}

	watchRemoteConfig()
}

func watchRemoteConfig() {
	go func() {
		for {
			fmt.Println(App.AllKeys(), App.Get("LOG_PATH")) //debug 打印所有keys

			time.Sleep(time.Second * 5)
			err := App.WatchRemoteConfig()
			if err != nil {
				Logger.Error("监听阿波罗配置错误：" + err.Error())
				continue
			}
		}
	}()
}

func newApolloConfigManager(appid, endpoint string) (*apolloConfigManager, error) {
	if appID == "" {
		return nil, errors.New("The appid is not set")
	}

	ag, err := newAgollo(appid, endpoint)
	if err != nil {
		return nil, err
	}

	return &apolloConfigManager{
		agollo: ag,
	}, nil

}

func newAgollo(appid, endpoint string) (agollo.Agollo, error) {
	i, found := agolloMap.Load(endpoint)
	if !found {
		ag, err := agollo.New(
			endpoint,
			appid,
			agollo.AutoFetchOnCacheMiss(),
			agollo.FailTolerantOnBackupExists(),
		)
		if err != nil {
			return nil, err
		}

		// TODO 监听apollo配置变化，同步配置，不关闭也没问题?
		ag.Start()

		agolloMap.Store(endpoint, ag)

		return ag, nil
	}
	return i.(agollo.Agollo), nil
}

// 1. 创建viper对象
App := viper.New()

// 2. 设置remote中apollo的appid，这是一个remote包中的全局变量
remote.SetAppID(appid)

// 3. 你在apollo中的配置文件的格式是什么，例如："properties", "json", "yml", "yaml", "xml"
// !!! 这一步很重要，没有设置就会导致配置读出来是空的。因为viper不知道你从远端读回来的配置文件是什么格式的
// !!! 默认情况下，使用apollo中的application是properties格式的，使用如下配置方式
// 如果你新建了其它格式的namespace，例如xxx.json 对应修改成App.SetConfigType("json")
App.SetConfigType("prop")

// 4. 给viper对象添加远端apollo配置信息
// 目前库中会根据apollo的规则去分析namesapce的后缀，而判断是什么配置文件，进行反序列化 https://github.com/shima-park/agollo/blob/master/viper-remote/remote.go#L89
// viper这边remote的接口返回的是一个io.Reader，https://github.com/shima-park/agollo/blob/master/viper-remote/remote.go#L164
// 它这边也需要反序列化，所以需要上一步的SetConfigType。
// https://github.com/spf13/viper/blob/master/viper.go#L1697
// https://github.com/spf13/viper/blob/master/viper.go#L1382
App.AddRemoteProvider(provider, endpoint, namespace)

// 5. 读取RemoteProvider
// 这里会通过https://github.com/shima-park/agollo/blob/master/viper-remote/remote.go#L66
// 创建agollo对象，目前没有暴露options的配置
App.ReadRemoteConfig()