| | |
|---|
| | | "aps_crm/initialize" |
|---|
| | | "aps_crm/middleware" |
|---|
| | | "aps_crm/model" |
|---|
| | | "aps_crm/model/grpc_init" |
|---|
| | | "aps_crm/pkg/logx" |
|---|
| | | "aps_crm/proto/client" |
|---|
| | | "aps_crm/proto/crm_aps" |
|---|
| | | "aps_crm/proto/product_inventory" |
|---|
| | | "aps_crm/router" |
|---|
| | | "fmt" |
|---|
| | |
|---|
| | | WriteTimeout: 5 * time.Second, |
|---|
| | | } |
|---|
| | | //启动grpc客户端 |
|---|
| | | go v1.InitProductServiceConn() |
|---|
| | | go middleware.InitUserConn() |
|---|
| | | go v1.InitCodeServiceConn() |
|---|
| | | go v1.InitProductInventoryServiceConn() |
|---|
| | | go grpc_init.InitCrmApsGrpcServiceConn() |
|---|
| | | //启动grpc服务 |
|---|
| | | go func() { |
|---|
| | | ln, err := net.Listen("tcp", ":"+conf.Conf.System.GrpcPort) |
|---|
| | |
|---|
| | | s := grpc.NewServer() |
|---|
| | | //todo 添加具体服务 |
|---|
| | | product_inventory.RegisterProductInventoryServiceServer(s, &product_inventory.Server{}) |
|---|
| | | crm_aps.RegisterCrmAndApsGrpcServiceServer(s, &crm_aps.Server{}) |
|---|
| | | client.RegisterClientServiceServer(s, &client.Server{}) |
|---|
| | | err = s.Serve(ln) |
|---|
| | | if err != nil { |
|---|
| | | logx.Errorf("grpc server init error: %v", err.Error()) |
|---|
| | |
|---|
| | | <-quit |
|---|
| | | |
|---|
| | | middleware.StopRefreshUser() |
|---|
| | | v1.CloseProductServiceConn() |
|---|
| | | v1.CloseCodeServiceConn() |
|---|
| | | v1.CloseProductInventoryServiceConn() |
|---|
| | | middleware.CloseUserConn() |
|---|
| | | grpc_init.CloseCrmApsGrpcServiceConn() |
|---|
| | | |
|---|
| | | logx.Infof("aps-crm exited...") |
|---|
| | | os.Exit(0) |
|---|
