resource.go 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. package main
  2. import (
  3. "flag"
  4. "fmt"
  5. . "bp.jydev.jianyu360.cn/BaseService/resourceCenter/public/db"
  6. . "bp.jydev.jianyu360.cn/BaseService/resourceCenter/rpc/internal/config"
  7. "bp.jydev.jianyu360.cn/BaseService/resourceCenter/rpc/internal/server"
  8. "bp.jydev.jianyu360.cn/BaseService/resourceCenter/rpc/internal/svc"
  9. "bp.jydev.jianyu360.cn/BaseService/resourceCenter/rpc/pb"
  10. "github.com/zeromicro/go-zero/core/conf"
  11. "github.com/zeromicro/go-zero/core/logx"
  12. "github.com/zeromicro/go-zero/core/service"
  13. "github.com/zeromicro/go-zero/zrpc"
  14. "google.golang.org/grpc"
  15. "google.golang.org/grpc/reflection"
  16. )
  17. var configFile = flag.String("f", "etc/resource.yaml", "the config file")
  18. func main() {
  19. flag.Parse()
  20. var c Config
  21. conf.MustLoad(*configFile, &c)
  22. // logx 根据配置初始化
  23. logx.MustSetup(c.Logx)
  24. //初始化mysql
  25. InitMysql(c.Mysql.BaseService)
  26. ctx := svc.NewServiceContext(c)
  27. svr := server.NewResourceServer(ctx)
  28. s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
  29. pb.RegisterResourceServer(grpcServer, svr)
  30. if c.Mode == service.DevMode || c.Mode == service.TestMode {
  31. reflection.Register(grpcServer)
  32. }
  33. })
  34. defer s.Stop()
  35. fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
  36. s.Start()
  37. }