| | |
| | | ReadTimeout: 5 * time.Second, |
| | | WriteTimeout: 5 * time.Second, |
| | | } |
| | | |
| | | //启动grpc客户端 |
| | | go v1.InitProductServiceConn() |
| | | go middleware.InitUserConn() |
| | |
| | | panic(fmt.Sprintf("grpc server init error: %v", err.Error())) |
| | | } |
| | | }() |
| | | //c := cron.New() |
| | | //c.AddFunc("@every 15s", service.SyncUserInfo) // 每15秒同步一次 |
| | | //c.Start() |
| | | |
| | | middleware.InitRefreshUserManager(5, 5, 3600) |
| | | middleware.RunRefreshUser() ///定时对活跃用户更新用户详情 |
| | | |
| | | logx.Error(server.ListenAndServe().Error()) |
| | | } |
| | |
| | | signal.Notify(quit, syscall.SIGKILL, syscall.SIGQUIT, syscall.SIGINT, syscall.SIGTERM) |
| | | <-quit |
| | | |
| | | middleware.StopRefreshUser() |
| | | v1.CloseProductServiceConn() |
| | | v1.CloseCodeServiceConn() |
| | | v1.CloseProductInventoryServiceConn() |