userimpl.go 1.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. package controllers
  2. import (
  3. context "golang.org/x/net/context"
  4. //grpc "google.golang.org/grpc"
  5. "fmt"
  6. pb "hello_rpc/grpc/gapi"
  7. "github.com/go-redis/redis"
  8. // grpc "google.golang.org/grpc"
  9. )
  10. const (
  11. queueName = "mq:jobs_queue"
  12. restQueueName = "mq:jobs_queue_rest"
  13. )
  14. func NewUserServiceServer(redisAddr string) *server {
  15. cli := redis.NewClient(&redis.Options{
  16. Addr: redisAddr,
  17. DB: 0,
  18. })
  19. return &server{rCli: cli}
  20. }
  21. type server struct {
  22. rCli *redis.Client
  23. pb.UnimplementedUserServiceServer
  24. }
  25. // findByUserId implements gapi.userService
  26. func (s *server) FindByUserId(ctx context.Context, in *pb.UserRequest) (*pb.UserResponse, error) {
  27. fmt.Println("Received: %v", in.GetUserid())
  28. fmt.Println("Received: %v", in.GetPhone())
  29. var result *pb.Result
  30. var user *pb.User
  31. result = &pb.Result{
  32. Code: pb.ResultCode_SUCCEED,
  33. Info: "处理成功",
  34. Value: "123"}
  35. user = &pb.User{
  36. Userid: int32(123),
  37. Username: "dyh_test_Username",
  38. Realname: "dyh_test_Realname",
  39. Mobile: "dyh_test_Mobile",
  40. Idtype: int32(123),
  41. Idno: "dyh_test_Idno",
  42. Sex: int32(123),
  43. Age: int32(123),
  44. Avatar: "dyh_test_Avatar",
  45. Birthday: "dyh_test_Birthday",
  46. Createtime: 12345667890,
  47. Registerip: "dyh_test_Registerip",
  48. Usertype: int32(123)}
  49. return &pb.UserResponse{Result: result, User: user}, nil
  50. }