[CI SKIP]

src/handler/proxyhandler.go

@@ -11,6 +11,7 @@ import (
 	"github.com/vulcand/oxy/testutils"
 	"gitlab.wodcloud.com/apaas/apaas-meshproxy/src/model"
 	"gitlab.wodcloud.com/apaas/apaas-meshproxy/src/service"
+	"gitlab.wodcloud.com/apaas/apaas-meshproxy/src/tools"
 	"io/ioutil"
 	"net/http"
 	"strconv"
@@ -174,3 +175,41 @@ func getHost(url string) (path string) {
 	}
 	return
 }
+
+func HealthCheck(c *gin.Context) {
+	res := model.WebRes{}
+	proxyData, err := service.GetReqPath()
+	if err != nil {
+		res.Data = err.Error()
+		c.JSON(500, res)
+		return
+	}
+	var requstMethod string
+	//获取真实地址1GET 2POST 3 PUT 4 DELETE
+	if proxyData.ReqType == 1 {
+		requstMethod = "GET"
+	} else if proxyData.ReqType == 2 {
+		requstMethod = "POST"
+	} else if proxyData.ReqType == 3 {
+		requstMethod = "PUT"
+	} else if proxyData.ReqType == 4 {
+		requstMethod = "DELETE"
+	}
+	header := make(map[string]string, 0)
+	resp, err := tools.ProxySendRes(c.Request, requstMethod, proxyData.ReqUrl, "", header)
+	if err != nil {
+		res.Data = err.Error()
+		c.JSON(500, res)
+		return
+	}
+	fmt.Println(resp)
+	if resp.StatusCode < 400 {
+		res.Data = "success"
+	} else {
+		res.Data = "fail"
+	}
+	res.Success = 1
+	//请求真实地址根据返回状态码判断是否服务可用
+	c.JSON(200, res)
+	return
+}

src/main.go

@@ -18,7 +18,7 @@ import (
 var (
 	argPort      = pflag.Int("port", 8011, "")
 	argPrefix    = pflag.String("prefix", "/bgmesh/fiddler", "")
-	meshId       = pflag.String("meshId", "", "")
+	meshId       = pflag.String("meshId", "149", "")
 	redisUrl     = pflag.String("redisUrl", "redis://apaas-redis.apaas-v3:6379", "")
 	redisTag     = pflag.String("redisTag", "apaas-mesh-proxy", "")
 	confPath     = pflag.String("confPath", "/app/config/proxy.json", "")

src/model/tables/service.go

+package tables
+
+type Service struct {
+	Id      int    `json:"id"xorm:"pk"`
+	ReqUrl  string `json:"req_url"`
+	ReqType int    `json:"req_type"`
+	//ReqType string `json:"req_type"`
+}

src/router/router.go

@@ -32,8 +32,8 @@ func Load(middleware ...gin.HandlerFunc) http.Handler {
 	e.Use(middleware...)
 	root := e.Group(fmt.Sprintf("%s/%s", config.Prefix, config.MeshId))
 	{
-		root.Any("/:applyId", handler.Proxy)
-		root.GET("/:applyId/health", handler.Proxy)
+		root.GET("/health", handler.HealthCheck)
+		root.Any("/service/:applyId", handler.Proxy)
 	}
 	return e
 }

src/service/field.go

@@ -16,6 +16,7 @@ import (
 	"gitlab.wodcloud.com/apaas/apaas-meshproxy/src/dao"
 	"gitlab.wodcloud.com/apaas/apaas-meshproxy/src/model"
 	"gitlab.wodcloud.com/apaas/apaas-meshproxy/src/model/request"
+	"gitlab.wodcloud.com/apaas/apaas-meshproxy/src/model/tables"
 	"gitlab.wodcloud.com/apaas/apaas-meshproxy/src/tools"
 	"gitlab.wodcloud.com/apaas/apaas-meshproxy/src/tools/dataconvertutil"
 	"strconv"
@@ -444,3 +445,14 @@ func GetRealPath(applyId string) (res model.ProxyData, err error) {
 	}
 	return
 }
+
+// 获取真实地址
+func GetReqPath() (res tables.Service, err error) {
+	db, err := client.GetConnect()
+	if err != nil {
+		return
+	}
+	res = tables.Service{}
+	_, err = db.ID(config.MeshId).Get(&res)
+	return
+}