连接 阿里云 MSE Nacos 取配置失败，也不报任何错误，取回的内容为空

	remote.SetOptions(&remote.Option{
		Url:         Config.Mse.Server,
		Port:        uint64(Config.Mse.Port),
		NamespaceId: Config.Mse.Namespace,
		GroupName:   Config.Mse.GroupName,
		Config:      remote.Config{DataId: Config.Mse.ConfigName},
		Auth:        nil,
	})
	remoteConfig := viper.New()
	err := remoteConfig.AddRemoteProvider("nacos", "mse-8f7b0b60-nacos-ans.mse.aliyuncs.com", "")
	if err != nil {
		fmt.Println("加载远程配置失败 :", err.Error())
	}
	remoteConfig.SetConfigType("yaml")
	err = remoteConfig.ReadRemoteConfig()
	if err != nil {
		fmt.Println("加载远程配置失败 :", err.Error())
	}
	fmt.Println("加载远程配置: Config = ", remoteConfig.GetString("log.level"))

	loadFromViper(remoteConfig)

	fmt.Println("加载远程配置: Config = ", ObjToJSON(Config))

import ( "github.com/sirupsen/logrus" "github.com/spf13/viper" _ "github.com/spf13/viper/remote" remote "github.com/yoyofxteam/nacos-viper-remote" )

func SetRemoteYaml() {

var remoteViper = viper.New()
remote.SetOptions(&remote.Option{
	Url:          	"192.168.123.22",
	Port:        	31150,
	NamespaceId: 	"xincan-dev-0001",
	GroupName:   	"dev_group",
	Config: 		remote.Config{
		DataId: "test-gokit-dev.yaml",
	},
	Auth: nil,
})

remoteErr := remoteViper.AddRemoteProvider("nacos", "192.168.123.22", "")
remoteViper.SetConfigType("yaml")
_ = remoteViper.ReadRemoteConfig()
_ = remoteViper.WatchRemoteConfigOnChannel()
if remoteErr == nil {
	logrus.WithField("fail", remoteErr).Error("viper获取Nacos配置中心数据失败")
}

}

直接在ListenConfig的回调里面新建一个Vipper对象，然后Store到一个线程安全的对象里，用的时候每次Load一次即可…

type SafeVipper struct {
	lock   sync.RWMutex
	vipper *viper.Viper
}

func (sv *SafeVipper) Load() *viper.Viper {
	sv.lock.RLock()
	defer sv.lock.RUnlock()
	return sv.vipper
}

func (sv *SafeVipper) Store(vp *viper.Viper) {
	sv.lock.Lock()
	sv.vipper = vp
	sv.lock.Unlock()
}

func GetViper(group, dataId string, cbs ...func(*viper.Viper)) (*SafeVipper, chan struct{}) {
	suffix := "yaml"
	idx := strings.LastIndex(dataId, ".")
	if idx >= 0 {
		suffix = dataId[idx+1:]
	}
	sv := &SafeVipper{}
	fn := func(namespace, group, dataId, data string) {
		vp := viper.New()
		vp.SetConfigType(suffix)
		if err := vp.ReadConfig(bytes.NewReader([]byte(data))); err != nil {
			log.Error("fail parse config file, group: %s, dataId: %s", group, dataId)
		} else {
			for _, cb := range cbs {
				cb(vp)
			}
			//仅当解析成功才替换掉
			sv.Store(vp)
		}
	}
	// 第一次读入文件
	data, err := configClient.GetConfig(vo.ConfigParam{
		DataId: dataId,
		Group:  group,
	})
	if err != nil || data == "" {
		log.Fatal("fail to read config from %s, data:%s, err:%v", dataId, data, err)
	}
	fn("", group, dataId, data)
	if sv.Load() == nil {
		log.Fatal("fail to parse config file:%s, err:%s", dataId, err)
	}
	// 监听文件变化
	err = configClient.ListenConfig(vo.ConfigParam{
		DataId:   dataId,
		Group:    group,
		OnChange: fn,
	})
	if err != nil {
		log.Fatal("fail to comm with nacos:%s", err)
	}
	ch := make(chan struct{}, 1)
	go func() {
		<-ch
		_ = configClient.CancelListenConfig(vo.ConfigParam{
			DataId: dataId,
			Group:  group,
		})
	}()
	return sv, ch
}