main.go 812 B

123456789101112131415161718192021222324252627282930313233343536373839404142434445
  1. package main
  2. import (
  3. "fmt"
  4. "git.beswell.com/gframe/application"
  5. "github.com/ZR233/glog/v2"
  6. "github.com/sirupsen/logrus"
  7. "log"
  8. "net"
  9. "sportfitness/base/api/grpc"
  10. pb "sportfitness/base/api/grpc/base"
  11. "sportfitness/base/assembly/base"
  12. )
  13. func main() {
  14. glog.Init("sportfitness", "base")
  15. app := application.NewDefault()
  16. err := app.LogUseKafka()
  17. if err != nil {
  18. panic(err)
  19. }
  20. err = app.AddServiceGrpcClient("bsw/im")
  21. if err != nil {
  22. panic(err)
  23. }
  24. //基础库初始化
  25. base.Init()
  26. grpcServer := app.GRPCServer()
  27. lis, err := net.Listen("tcp", fmt.Sprintf(":%d", 19090))
  28. if err != nil {
  29. logrus.Fatalf("failed to listen: %s", err)
  30. }
  31. pb.RegisterApiServer(grpcServer, &grpc.ApiBase{})
  32. logrus.Infof("listen :%d", 19090)
  33. err = grpcServer.Serve(lis)
  34. if err != nil {
  35. log.Fatal(err)
  36. }
  37. }