提交 195a10b3 authored 作者: mooncake9527's avatar mooncake9527

配置为空时报错

上级 216ef8a2
......@@ -47,7 +47,7 @@ func (x *ConsulConfFetcher) sync() *ConsulConfFetcher {
x.err = err
return x
}
if kv == nil {
if kv == nil || len(kv.Value) == 0 {
x.err = xerror.New("[consul]请先配置consul")
return x
}
......
......@@ -62,6 +62,10 @@ func watchConfig(confFile string, obj ICfg, reloads ...func()) {
// Note: OnConfigChange is called twice on Windows
viper.OnConfigChange(func(e fsnotify.Event) {
if content, err := os.ReadFile(confFile); err == nil {
if len(content) == 0 {
fmt.Println("配置为空")
return
}
obj.SetContent(content)
}
obj.Lock()
......
package config
import (
"errors"
"fmt"
"github.com/nacos-group/nacos-sdk-go/clients"
......@@ -110,6 +111,9 @@ func (x *NacosClient) Watch() *NacosClient {
Group: x.cfg.Group,
OnChange: func(namespace, group, dataId, data string) {
fmt.Println("[nacos]conf changed")
if data == "" {
x.e = errors.New("配置为空")
}
x.content = []byte(data)
_ = x.Parse()
},
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论