update 默认转发路由 沿用原有请求路由地址

config/configStruct.go

@@ -40,8 +40,8 @@ type HttpConfig struct {
 }
 
 type ApiServerConfig struct {
-	Port   uint              `json:"port"`
+	Port    uint              `json:"port"`
-	Routes map[string]string `json:"routes"`
+	Routers map[string]string `json:"routers"`
 }
 
 type Token struct {

configFiles/config_转发http2axy60000端口.json

@@ -6,7 +6,7 @@
         "port": 7000,
         "userName": "anQuanDai",
         "password": "123",
-        "routes": {
+        "routers": {
           "route1": "POST /upload/work/ABStatus",
           "route2": "POST /upload/work/ABHeart"
         }
@@ -14,7 +14,7 @@
     },
     "out": {
       "httpPost": {
-        "url": "http://218.3.126.49:60000/upload",
+        "url": "http://218.3.126.49:60000",
         "method": "post"
       }
     }

consumers/consumerHTTP_PRPXY.go

@@ -44,7 +44,7 @@ func (the *consumerHttpProxy) InputInitial() error {
 	//数据入口
 	the.InApiServer = dbHelper.NewApiServer(
 		the.Info.IoConfig.In.ApiServer.Port,
-		the.Info.IoConfig.In.ApiServer.Routes,
+		the.Info.IoConfig.In.ApiServer.Routers,
 	)
 	the.InApiServer.Initial()
 	return nil
@@ -59,9 +59,11 @@ func (the *consumerHttpProxy) OutputInitial() error {
 }
 func (the *consumerHttpProxy) Work() {
 	go func() {
-		router := "POST /onData"
+		for _, router := range the.Info.IoConfig.In.ApiServer.Routers {
-		the.InApiServer.RouteRegister(router, the.onData)
+			the.InApiServer.RouteRegister(router, the.onData)
+		}
 		the.InApiServer.Run()
+
 	}()
 }
 func (the *consumerHttpProxy) onData(w http.ResponseWriter, r *http.Request) {
@@ -86,6 +88,8 @@ func (the *consumerHttpProxy) onData(w http.ResponseWriter, r *http.Request) {
 	params := map[string]string{
 		"id": id,
 	}
+	//沿用请求路由
+	the.outHttpPost.Url += r.URL.String()
 	resp, err := the.outHttpPost.HttpPostWithParams(string(body), params)
 	if err != nil {
 		return

dbHelper/apiServerHelper.go

@@ -30,7 +30,7 @@ func (the *ApiServerHelper) Initial() {
 		Addr:    fmt.Sprintf(":%d", the.port),
 	}
 
-	the.routeRegister()
+	//the.routeRegister()
 
 }
 func (the *ApiServerHelper) Run() {