| | |
|---|
| | | "aps_crm/middleware" |
|---|
| | | "aps_crm/model" |
|---|
| | | "aps_crm/pkg/logx" |
|---|
| | | "aps_crm/proto/product_inventory" |
|---|
| | | "aps_crm/router" |
|---|
| | | "fmt" |
|---|
| | | "google.golang.org/grpc" |
|---|
| | | "net" |
|---|
| | | "net/http" |
|---|
| | | "os" |
|---|
| | | "os/signal" |
|---|
| | |
|---|
| | | WriteTimeout: 5 * time.Second, |
|---|
| | | } |
|---|
| | | |
|---|
| | | //启动grpc客户端 |
|---|
| | | go v1.InitProductServiceConn() |
|---|
| | | go middleware.InitUserConn() |
|---|
| | | go v1.InitCodeServiceConn() |
|---|
| | | go v1.InitProductInventoryServiceConn() |
|---|
| | | |
|---|
| | | //启动grpc服务 |
|---|
| | | go func() { |
|---|
| | | ln, err := net.Listen("tcp", ":"+conf.Conf.System.GrpcPort) |
|---|
| | | if err != nil { |
|---|
| | | logx.Errorf("grpc server init error: %v", err.Error()) |
|---|
| | | panic(fmt.Sprintf("grpc server init error: %v", err.Error())) |
|---|
| | | } |
|---|
| | | s := grpc.NewServer() |
|---|
| | | //todo 添加具体服务 |
|---|
| | | product_inventory.RegisterProductInventoryServiceServer(s, &product_inventory.Server{}) |
|---|
| | | err = s.Serve(ln) |
|---|
| | | if err != nil { |
|---|
| | | logx.Errorf("grpc server init error: %v", err.Error()) |
|---|
| | | panic(fmt.Sprintf("grpc server init error: %v", err.Error())) |
|---|
| | | } |
|---|
| | | }() |
|---|
| | | //c := cron.New() |
|---|
| | | //c.AddFunc("@every 15s", service.SyncUserInfo) // 每15秒同步一次 |
|---|
| | | //c.Start() |
|---|
