main1.go 1.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. package main_backup
  2. // 不包含etcd注册的grpc服务
  3. import (
  4. "context"
  5. "fmt"
  6. pb "hello_rpc/grpc/gapi"
  7. _ "hello_rpc/routers"
  8. "net"
  9. "github.com/astaxie/beego"
  10. "google.golang.org/grpc"
  11. )
  12. func main() {
  13. registerGrpcServerTest()
  14. beego.Run()
  15. }
  16. // ------------- grpc server start -----------------------------
  17. // server is used to implement gapi.UserServiceServer.
  18. type server struct {
  19. pb.UnimplementedUserServiceServer
  20. }
  21. // findByUserId implements gapi.userService
  22. func (s *server) FindByUserId(ctx context.Context, in *pb.UserRequest) (*pb.UserResponse, error) {
  23. fmt.Println("Received: %v", in.GetUserid())
  24. fmt.Println("Received: %v", in.GetPhone())
  25. var result *pb.Result
  26. var user *pb.User
  27. result = &pb.Result{
  28. Code: pb.ResultCode_SUCCEED,
  29. Info: "处理成功",
  30. Value: "123"}
  31. user = &pb.User{
  32. Userid: int32(123),
  33. Username: "dyh_test_Username",
  34. Realname: "dyh_test_Realname",
  35. Mobile: "dyh_test_Mobile",
  36. Idtype: int32(123),
  37. Idno: "dyh_test_Idno",
  38. Sex: int32(123),
  39. Age: int32(123),
  40. Avatar: "dyh_test_Avatar",
  41. Birthday: "dyh_test_Birthday",
  42. Createtime: 12345667890,
  43. Registerip: "dyh_test_Registerip",
  44. Usertype: int32(123)}
  45. return &pb.UserResponse{Result: result, User: user}, nil
  46. }
  47. func registerGrpcServerTest() {
  48. fmt.Println("-------I'm coming registerGrpcServerTest------")
  49. port := beego.AppConfig.String("httpport")
  50. lis, err := net.Listen("tcp", ":"+port)
  51. if err != nil {
  52. fmt.Println("failed to listen: %v", err)
  53. }
  54. s := grpc.NewServer()
  55. pb.RegisterUserServiceServer(s, &server{})
  56. if err := s.Serve(lis); err != nil {
  57. fmt.Println("failed to serve: %v", err)
  58. }
  59. fmt.Println(lis)
  60. }
  61. // ------------- end grpc server -----------------------------