From a2025e890185b29e70d261faa0463132eeb63813 Mon Sep 17 00:00:00 2001 From: "DESKTOP-V763RJ7\\Administrator" <835606593@qq.com> Date: Wed, 14 Jan 2026 16:00:26 +0800 Subject: [PATCH] =?UTF-8?q?feat=20=E6=8B=A6=E6=88=AA=E5=99=A8=E5=8F=96usn?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- net/grpc/service/service.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/net/grpc/service/service.go b/net/grpc/service/service.go index d469482..d24f235 100644 --- a/net/grpc/service/service.go +++ b/net/grpc/service/service.go @@ -5,6 +5,7 @@ import ( "fmt" "git.hlsq.asia/mmorpg/service-common/discover" "git.hlsq.asia/mmorpg/service-common/log" + "git.hlsq.asia/mmorpg/service-common/net/http/http_resp" "git.hlsq.asia/mmorpg/service-common/utils" "google.golang.org/grpc" "google.golang.org/grpc/codes" @@ -56,8 +57,13 @@ func (s *Base) Init(addr string, port int32) { err = status.Error(codes.Internal, fmt.Sprintf("%v", r)) } }() - resp, err = handler(ctx, req) - return + if usnReq, ok := req.(interface{ GetUSN() string }); ok { + usn := usnReq.GetUSN() + if !utils.ShouldBindUsn(ctx, &usn) { + return nil, http_resp.ParamError + } + } + return handler(ctx, req) }, ), grpc.KeepaliveEnforcementPolicy(keepalive.EnforcementPolicy{