zhangqian
2024-03-20 4f526b034a6e13a521ad71dcbdbea97043d6ea19
main.go
@@ -1,13 +1,14 @@
package main
import (
   v1 "aps_crm/api/v1"
   "aps_crm/conf"
   "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"
@@ -51,7 +52,7 @@
   }
   //启动grpc客户端
   go middleware.InitUserConn()
   go v1.InitProductInventoryServiceConn()
   go grpc_init.InitProductInventoryServiceConn()
   go grpc_init.InitCrmApsGrpcServiceConn()
   //启动grpc服务
   go func() {
@@ -63,6 +64,8 @@
      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())
@@ -82,7 +85,7 @@
   <-quit
   middleware.StopRefreshUser()
   v1.CloseProductInventoryServiceConn()
   grpc_init.CloseProductInventoryServiceConn()
   middleware.CloseUserConn()
   grpc_init.CloseCrmApsGrpcServiceConn()