diff --git a/main.go b/main.go index 91cddf1..f3af3fa 100644 --- a/main.go +++ b/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)