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 }