feat kafka

app/app.go

@@ -22,7 +22,7 @@ func (p *Program) Init(_ svc.Environment) error {
 		return err
 	}
 	p.moduleList = append(p.moduleList, base)
-	p.moduleList = append(p.moduleList, (&module.DB{}).Bind(config.Get().DB, common.KeyDiscoverServiceNameGateway))
+	p.moduleList = append(p.moduleList, (&module.DB{}).Bind(config.Get().DB, config.Get().App.Name))
 	p.moduleList = append(p.moduleList, &ModuleWebServer{})
 	p.moduleList = append(p.moduleList, &ModuleWebsocketServer{})
 	p.moduleList = append(p.moduleList, &ModuleLoginQueue{})

config/config.dev.yaml

@@ -13,19 +13,19 @@ metric:
     address: "0.0.0.0"
     port: 18504
   jaeger:
-    endpoint: "localhost:4317"
+    endpoint: "127.0.0.1:4317"
 
 db:
   etcd:
-    endpoints: [ "localhost:2379" ]
+    endpoints: [ "127.0.0.1:2379" ]
   redis:
-    addr: "localhost:6379"
+    addr: "127.0.0.1:6379"
     password: "lQ7aM8oB6lK0iD5k"
     db: 0
 
 serve:
   grpc:
-    address: "10.0.40.199"
+    address: "127.0.0.1"
     port: 18500
     ttl: 20
   socket:

go.mod

@@ -4,7 +4,7 @@ go 1.24.0
 
 require (
 	bou.ke/monkey v1.0.2
-	git.hlsq.asia/mmorpg/service-common v0.0.0-20260123132258-4d661d08134e
+	git.hlsq.asia/mmorpg/service-common v0.0.0-20260127091405-a93b5fd1aa49
 	github.com/alicebob/miniredis/v2 v2.35.0
 	github.com/gin-contrib/cors v1.7.6
 	github.com/gin-gonic/gin v1.11.0

go.sum

@@ -2,8 +2,8 @@ bou.ke/monkey v1.0.2 h1:kWcnsrCNUatbxncxR/ThdYqbytgOIArtYWqcQLQzKLI=
 bou.ke/monkey v1.0.2/go.mod h1:OqickVX3tNx6t33n1xvtTtu85YN5s6cKwVug+oHMaIA=
 filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
 filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
-git.hlsq.asia/mmorpg/service-common v0.0.0-20260123132258-4d661d08134e h1:jcDwaL280D5BVGCfcIC3mQCjmwPz5fxX7NO1qf6nAIo=
+git.hlsq.asia/mmorpg/service-common v0.0.0-20260127091405-a93b5fd1aa49 h1:neROxvB2bS8U8SchSJEERVk15rRobxPkwJ+krO46fV4=
-git.hlsq.asia/mmorpg/service-common v0.0.0-20260123132258-4d661d08134e/go.mod h1:mMhZcumphj6gaVTppVYsMTkd+5HupmQgAc53Pd4MH9I=
+git.hlsq.asia/mmorpg/service-common v0.0.0-20260127091405-a93b5fd1aa49/go.mod h1:mMhZcumphj6gaVTppVYsMTkd+5HupmQgAc53Pd4MH9I=
 github.com/BurntSushi/toml v1.2.0 h1:Rt8g24XnyGTyglgET/PRUNlrUeu9F5L+7FilkXfZgs0=
 github.com/BurntSushi/toml v1.2.0/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
 github.com/IBM/sarama v1.46.3 h1:njRsX6jNlnR+ClJ8XmkO+CM4unbrNr/2vB5KK6UA+IE=

internal/net/http_gateway/router.go

@@ -14,6 +14,7 @@ import (
 	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	"go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin"
 	"google.golang.org/protobuf/encoding/protojson"
+	"strings"
 )
 
 func InitServeMux() *runtime.ServeMux {
@@ -49,7 +50,13 @@ func InitRouter() *gin.Engine {
 		gin.Recovery(),
 		ginLogger(log.GetLogger().Named("GIN")),
 		cors.New(corsConfig()),
-		otelgin.Middleware(common.KeyDiscoverServiceNameGateway),
+		otelgin.Middleware(
+			common.KeyDiscoverServiceNameGateway,
+			otelgin.WithSpanNameFormatter(func(c *gin.Context) string {
+				method := strings.ToUpper(c.Request.Method)
+				return method + " " + c.Request.URL.Path
+			}),
+		),
 	)
 
 	r.HandleMethodNotAllowed = true