Commit 7d97d8b6 authored by hujiebin's avatar hujiebin

feat:去掉不必要的fatal,保留最后的连接userCenter的fatal

parent 483fd7af
...@@ -70,41 +70,39 @@ func (b *Builder) UpdateState(addrs []string) { ...@@ -70,41 +70,39 @@ func (b *Builder) UpdateState(addrs []string) {
} }
func init() { func init() {
client, err := consulapi.NewClient(consulapi.DefaultConfig()) //非默认情况下需要设置实际的参数
mylogrus.MyLog.Infoln(client, err)
if err != nil {
mylogrus.MyLog.Fatalln(err)
}
if client == nil {
mylogrus.MyLog.Fatalln("Fail to get consul client.")
}
// 本地环境下不需要userCenter // 本地环境下不需要userCenter
if config.AppIsLocal() { if config.AppIsLocal() {
mylogrus.MyLog.Infoln("userCenter is not required in local env.") mylogrus.MyLog.Infoln("userCenter is not required in local env.")
return return
} }
client, err := consulapi.NewClient(consulapi.DefaultConfig()) //非默认情况下需要设置实际的参数
if err != nil || client == nil {
mylogrus.MyLog.Errorf("consul client fail:%v-%v", err, client)
}
// 服务发现 // 服务发现
bd := &Builder{addrs: map[string][]string{"/api": {userCenterAddr}}} bd := &Builder{addrs: map[string][]string{"/api": {userCenterAddr}}}
cataLog := client.Catalog() if client != nil {
if cataLog == nil { cataLog := client.Catalog()
mylogrus.MyLog.Fatalln("No catalog.") if cataLog != nil {
} services, _, err := cataLog.Service("userCenter", "", nil)
services, _, err := cataLog.Service("userCenter", "", nil) if err != nil {
if err != nil { mylogrus.MyLog.Errorf("cataLog.Service:err%v", err)
mylogrus.MyLog.Fatalln(err) }
} if len(services) == 0 {
if len(services) == 0 { mylogrus.MyLog.Errorf("userCenter not found.")
mylogrus.MyLog.Fatalln("userCenter not found.") }
} var addrs []string
var addrs []string for _, s := range services {
for _, s := range services { addrs = append(addrs, fmt.Sprintf("%s:%d", s.ServiceAddress, s.ServicePort))
addrs = append(addrs, fmt.Sprintf("%s:%d", s.ServiceAddress, s.ServicePort)) }
} if len(addrs) > 0 {
if len(addrs) > 0 { bd = &Builder{addrs: map[string][]string{"/api": addrs}}
bd = &Builder{addrs: map[string][]string{"/api": addrs}} userCenterAddr = "uc:///api"
userCenterAddr = "uc:///api" }
mylogrus.MyLog.Infof("userCenterAddr:%v,addr:%v", userCenterAddr, addrs)
}
} }
mylogrus.MyLog.Infof("userCenterAddr:%v,addr:%v", userCenterAddr, addrs) mylogrus.MyLog.Infof("connect userCenterAddr:%v", userCenterAddr)
resolver.Register(bd) resolver.Register(bd)
go func() { go func() {
address := consulapi.DefaultConfig().Address // 用consul api的default config address := consulapi.DefaultConfig().Address // 用consul api的default config
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment