提交 cc5e1a3b authored 作者: mooncake9527's avatar mooncake9527

fix

上级 6f112d71
...@@ -47,6 +47,7 @@ func parse() (err error) { ...@@ -47,6 +47,7 @@ func parse() (err error) {
if confType == "nacos" { if confType == "nacos" {
nacosConf() nacosConf()
nc := NewNacos(&Cfg.Nacos, func(content []byte) (err error) { nc := NewNacos(&Cfg.Nacos, func(content []byte) (err error) {
Cfg.SetContent(content)
v := viper.New() v := viper.New()
v.SetConfigType("yaml") v.SetConfigType("yaml")
if err := v.ReadConfig(bytes.NewReader(content)); err != nil { if err := v.ReadConfig(bytes.NewReader(content)); err != nil {
...@@ -72,7 +73,9 @@ func SetExtend(ext IExtend) { ...@@ -72,7 +73,9 @@ func SetExtend(ext IExtend) {
func ParseExtend() error { func ParseExtend() error {
v := viper.New() v := viper.New()
v.SetConfigType("yaml") v.SetConfigType("yaml")
if err := v.ReadConfig(bytes.NewReader(Cfg.GetContent())); err != nil { content := string(Cfg.GetContent())
// if err := v.ReadConfig(bytes.NewReader(Cfg.GetContent())); err != nil {
if err := v.ReadConfig(strings.NewReader(content)); err != nil {
return err return err
} }
if extend != nil { if extend != nil {
......
...@@ -107,6 +107,7 @@ func (x *NacosClient) Watch() *NacosClient { ...@@ -107,6 +107,7 @@ func (x *NacosClient) Watch() *NacosClient {
Group: x.cfg.Conf.Group, Group: x.cfg.Conf.Group,
OnChange: func(namespace, group, dataId, data string) { OnChange: func(namespace, group, dataId, data string) {
fmt.Println("[nacos]conf changed") fmt.Println("[nacos]conf changed")
x.content = []byte(data)
_ = x.Parse() _ = x.Parse()
}, },
}) })
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论