123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657 |
- package controllers
- import (
- context "golang.org/x/net/context"
- //grpc "google.golang.org/grpc"
- "fmt"
- pb "hello_rpc/grpc/gapi"
- "github.com/go-redis/redis"
- // grpc "google.golang.org/grpc"
- )
- const (
- queueName = "mq:jobs_queue"
- restQueueName = "mq:jobs_queue_rest"
- )
- func NewUserServiceServer(redisAddr string) *server {
- cli := redis.NewClient(&redis.Options{
- Addr: redisAddr,
- DB: 0,
- })
- return &server{rCli: cli}
- }
- type server struct {
- rCli *redis.Client
- pb.UnimplementedUserServiceServer
- }
- // findByUserId implements gapi.userService
- func (s *server) FindByUserId(ctx context.Context, in *pb.UserRequest) (*pb.UserResponse, error) {
- fmt.Println("Received: %v", in.GetUserid())
- fmt.Println("Received: %v", in.GetPhone())
- var result *pb.Result
- var user *pb.User
- result = &pb.Result{
- Code: pb.ResultCode_SUCCEED,
- Info: "处理成功",
- Value: "123"}
- user = &pb.User{
- Userid: int32(123),
- Username: "dyh_test_Username",
- Realname: "dyh_test_Realname",
- Mobile: "dyh_test_Mobile",
- Idtype: int32(123),
- Idno: "dyh_test_Idno",
- Sex: int32(123),
- Age: int32(123),
- Avatar: "dyh_test_Avatar",
- Birthday: "dyh_test_Birthday",
- Createtime: 12345667890,
- Registerip: "dyh_test_Registerip",
- Usertype: int32(123)}
- return &pb.UserResponse{Result: result, User: user}, nil
- }
|