stdlib.go 1.3 KB

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