ssyg/hertz101
2
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects 1 Releases Wiki Activity

实现 rpc 调用

Browse Source
This commit is contained in:
suyiiyii 2025-01-20 17:08:04 +08:00
parent bda2501bae
commit 82480c4611
Signed by: suyiiyii
GPG Key ID: 044704CB29B8AD85
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
app/auth/biz/service/verify_token_by_rpc.go
View File

@ -2,7 +2,12 @@ package service
import ( import (
"context" "context"
"fmt"
"github.com/cloudwego/kitex/client"
consul "github.com/kitex-contrib/registry-consul"
auth "github.com/suyiiyii/hertz101/app/auth/kitex_gen/auth" 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 { type VerifyTokenByRPCService struct {
@ -15,6 +20,19 @@ func NewVerifyTokenByRPCService(ctx context.Context) *VerifyTokenByRPCService {
// Run create note info // Run create note info
func (s *VerifyTokenByRPCService) Run(req *auth.VerifyTokenReq) (resp *auth.VerifyResp, err error) { func (s *VerifyTokenByRPCService) Run(req *auth.VerifyTokenReq) (resp *auth.VerifyResp, err error) {
// Finish your business logic. // 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 return
} }