From ad1ccc2bc16b8920b18e143f191593ad45aa9f60 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=96=8C?= <259278618@qq.com> Date: Thu, 27 Nov 2025 14:42:51 +0800 Subject: [PATCH] =?UTF-8?q?gateway=E5=8F=8D=E5=90=91=E4=BB=A3=E7=90=86?= =?UTF-8?q?=E5=AF=BC=E8=87=B4=E7=9A=84header=E4=BF=A1=E6=81=AF=E9=87=8D?= =?UTF-8?q?=E5=A4=8DBUG=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consul/consul.go | 2 ++ http/http.go | 14 ++------------ 2 files changed, 4 insertions(+), 12 deletions(-) diff --git a/consul/consul.go b/consul/consul.go index d674451..bc72dd2 100644 --- a/consul/consul.go +++ b/consul/consul.go @@ -4,6 +4,7 @@ import ( "context" "github.com/gogf/gf/contrib/registry/consul/v2" "github.com/gogf/gf/v2/frame/g" + "github.com/gogf/gf/v2/net/gsel" "github.com/gogf/gf/v2/net/gsvc" ) @@ -18,4 +19,5 @@ func init() { panic(err) } gsvc.SetRegistry(registry) + gsel.SetBuilder(gsel.NewBuilderRoundRobin()) } diff --git a/http/http.go b/http/http.go index c675ec4..afcad70 100644 --- a/http/http.go +++ b/http/http.go @@ -8,10 +8,8 @@ import ( "gitee.com/red-future---jilin-g/common/jaeger" "gitee.com/red-future---jilin-g/common/middleware" "gitee.com/red-future---jilin-g/common/utils" - "github.com/gogf/gf/contrib/registry/consul/v2" "github.com/gogf/gf/v2/frame/g" "github.com/gogf/gf/v2/net/ghttp" - "github.com/gogf/gf/v2/net/gsel" "github.com/gogf/gf/v2/net/gsvc" "github.com/gogf/gf/v2/os/glog" "github.com/gogf/gf/v2/util/gconv" @@ -65,17 +63,8 @@ func init() { `) - Httpserver.BindMiddlewareDefault(ghttp.MiddlewareCORS, ghttp.MiddlewareHandlerResponse, middleware.Limiter, jaeger.NewTracer) //使用默认http返回结构 + Httpserver.BindMiddlewareDefault(ghttp.MiddlewareHandlerResponse) go Httpserver.Run() - - consulCfg, _ := g.Cfg().Get(context.Background(), "consul.address") - consulAddr := consulCfg.String() - registry, err := consul.New(consul.WithAddress(consulAddr)) - if err != nil { - panic(err) - } - gsvc.SetRegistry(registry) - gsel.SetBuilder(gsel.NewBuilderRoundRobin()) Httpclient.SetDiscovery(gsvc.GetRegistry()) } func RouteRegister(controllers []interface{}) { @@ -86,6 +75,7 @@ func RouteRegister(controllers []interface{}) { return fmt.Sprintf("/%s", strings.ToLower(s)) }) Httpserver.Group(convertedStr, func(group *ghttp.RouterGroup) { + group.Middleware(middleware.Limiter, jaeger.NewTracer) group.Bind(t) }) }