red-future/common
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 19 Wiki Activity

consul地址分配优先调用gateway同IP的微服务

Browse Source
This commit is contained in:
张斌
2025-12-03 12:04:20 +08:00
parent 17cc8a371a
commit 0541ac776a
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
consul/consul.go
View File

@@ -49,19 +49,18 @@ func GetInstanceAddr(ctx context.Context, name string) (addr string, err error)
err = errors.New("获取customerService服务实例失败！") err = errors.New("获取customerService服务实例失败！")
return return
} }
maxService := grand.N(0, len(service)-1)
maxEndpoints := grand.N(0, len(service[maxService].GetEndpoints())-1)
//优先使用gateway同IP的服务实例 //优先使用gateway同IP的服务实例
addr, err = getLocalIP() addr, err = getLocalIP()
if err != nil { if err != nil {
return return
} }
for _, point := range service[maxService].GetEndpoints() { for _, s := range service {
if point.Host() == addr { if s.GetEndpoints()[0].Host() == addr {
addr = point.String() addr = s.GetEndpoints()[0].String()
return return
} }
} }
addr = service[maxService].GetEndpoints()[maxEndpoints].String() maxService := grand.N(0, len(service)-1)
addr = service[maxService].GetEndpoints()[0].String()
return return
} }