userlib.go 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839
  1. package main
  2. import (
  3. jyDocsRpcUtil "app.yhyue.com/moapp/jy_docs/services/util"
  4. "flag"
  5. "fmt"
  6. "log"
  7. "app.yhyue.com/moapp/jy_docs/rpc/userlib/internal/config"
  8. "app.yhyue.com/moapp/jy_docs/rpc/userlib/internal/server"
  9. "app.yhyue.com/moapp/jy_docs/rpc/userlib/internal/svc"
  10. "app.yhyue.com/moapp/jy_docs/rpc/userlib/userlib"
  11. "github.com/tal-tech/go-zero/core/conf"
  12. "github.com/tal-tech/go-zero/zrpc"
  13. "google.golang.org/grpc"
  14. )
  15. var configFile = flag.String("f", "etc/userlib.yaml", "the config file")
  16. func main() {
  17. flag.Parse()
  18. var c config.Config
  19. conf.MustLoad(*configFile, &c)
  20. if c.JyDocsMysqlDB.DataSourceName != "" {
  21. jyDocsRpcUtil.InitDB(c.JyDocsMysqlDB.DataSourceName, c.JyDocsMysqlDB.DriverName, c.JyDocsMysqlDB.MaxOpenConn, c.JyDocsMysqlDB.MaxIdleConn)
  22. ctx := svc.NewServiceContext(c)
  23. srv := server.NewUserLibServer(ctx)
  24. s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
  25. userlib.RegisterUserLibServer(grpcServer, srv)
  26. })
  27. defer s.Stop()
  28. fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
  29. s.Start()
  30. } else {
  31. log.Fatal("【jy_docs】 read config error!")
  32. }
  33. }