From 82480c461172d3e9effab1967c53b09bc02d7c99 Mon Sep 17 00:00:00 2001 From: suyiiyii Date: Mon, 20 Jan 2025 17:08:04 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9E=E7=8E=B0=20rpc=20=E8=B0=83=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/auth/biz/service/verify_token_by_rpc.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/app/auth/biz/service/verify_token_by_rpc.go b/app/auth/biz/service/verify_token_by_rpc.go index 855c426..d656934 100644 --- a/app/auth/biz/service/verify_token_by_rpc.go +++ b/app/auth/biz/service/verify_token_by_rpc.go @@ -2,7 +2,12 @@ package service import ( "context" + "fmt" + "github.com/cloudwego/kitex/client" + consul "github.com/kitex-contrib/registry-consul" auth "github.com/suyiiyii/hertz101/app/auth/kitex_gen/auth" + user1 "github.com/suyiiyii/hertz101/rpc_gen/kitex_gen/user" + "github.com/suyiiyii/hertz101/rpc_gen/rpc/user" ) type VerifyTokenByRPCService struct { @@ -15,6 +20,19 @@ func NewVerifyTokenByRPCService(ctx context.Context) *VerifyTokenByRPCService { // Run create note info func (s *VerifyTokenByRPCService) Run(req *auth.VerifyTokenReq) (resp *auth.VerifyResp, err error) { // Finish your business logic. + r, err := consul.NewConsulResolver("10.21.22.53:8500") + rpcClient, err := user.NewRPCClient("user", client.WithResolver(r)) + if err != nil { + return nil, err + } + loginResp, err := rpcClient.Login(s.ctx, &user1.LoginReq{ + Email: "11", + Password: "22", + }) + if err != nil { + return nil, err + } + fmt.Println(loginResp) return }