注释ip替换代码,这个代码会导致服务器环境访问不到下游服务
This commit is contained in:
38
main.go
38
main.go
@@ -61,25 +61,25 @@ func StartServerProxy() {
|
||||
}
|
||||
|
||||
// 1. 解析 consul 配置地址
|
||||
consulAddr := g.Cfg().MustGet(r.GetCtx(), "consul.address").String()
|
||||
consulAddrList := strings.Split(consulAddr, ":")
|
||||
if len(consulAddrList) < 1 {
|
||||
g.Log().Error(r.GetCtx(), "consul.address 配置格式错误")
|
||||
r.Response.WriteJsonExit(map[string]interface{}{
|
||||
"success": false,
|
||||
"code": 500,
|
||||
"message": fmt.Sprintf("consul.address 配置格式错误:%s", consulAddr),
|
||||
})
|
||||
return
|
||||
}
|
||||
ipStr := instanceAddr
|
||||
if strings.Contains(instanceAddr, ":") {
|
||||
ipStr = strings.Split(instanceAddr, ":")[0]
|
||||
}
|
||||
// 2. 如果不是本地IP,则替换为consul配置的IP
|
||||
if !utils.IsLocalIP(ipStr) {
|
||||
instanceAddr = strings.Replace(instanceAddr, ipStr, consulAddrList[0], 1)
|
||||
}
|
||||
//consulAddr := g.Cfg().MustGet(r.GetCtx(), "consul.address").String()
|
||||
//consulAddrList := strings.Split(consulAddr, ":")
|
||||
//if len(consulAddrList) < 1 {
|
||||
// g.Log().Error(r.GetCtx(), "consul.address 配置格式错误")
|
||||
// r.Response.WriteJsonExit(map[string]interface{}{
|
||||
// "success": false,
|
||||
// "code": 500,
|
||||
// "message": fmt.Sprintf("consul.address 配置格式错误:%s", consulAddr),
|
||||
// })
|
||||
// return
|
||||
//}
|
||||
//ipStr := instanceAddr
|
||||
//if strings.Contains(instanceAddr, ":") {
|
||||
// ipStr = strings.Split(instanceAddr, ":")[0]
|
||||
//}
|
||||
//// 2. 如果不是本地IP,则替换为consul配置的IP
|
||||
//if !utils.IsLocalIP(ipStr) {
|
||||
// instanceAddr = strings.Replace(instanceAddr, ipStr, consulAddrList[0], 1)
|
||||
//}
|
||||
|
||||
r.Request.URL.Path = strings.Replace(r.Request.URL.Path, fmt.Sprintf("%s/", serverName), "", 1)
|
||||
r.MakeBodyRepeatableRead(false)
|
||||
|
||||
Reference in New Issue
Block a user