蛋蛋星球 后台端

main.go 967 B

1 miesiąc temu
1 tydzień temu
1 miesiąc temu
3 tygodni temu
1 miesiąc temu
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. package main
  2. import (
  3. "fmt"
  4. "os"
  5. "os/signal"
  6. "syscall"
  7. "applet/app/cfg"
  8. "applet/app/db"
  9. "applet/app/task"
  10. "applet/app/utils"
  11. "applet/app/utils/logx"
  12. )
  13. func init() {
  14. // 加载任务配置
  15. cfg.InitTaskCfg()
  16. // 日志配置
  17. cfg.InitLog()
  18. // 初始化redis
  19. cfg.InitCache()
  20. cfg.InitMq() // 队列初始化
  21. cfg.InitEs() //ElasticSearch初始化
  22. baseDb := *cfg.DB
  23. baseDb.Path = fmt.Sprintf(cfg.DB.Path, cfg.DB.Name)
  24. if err := db.InitDB(&baseDb); err != nil {
  25. panic(err)
  26. }
  27. baseImDb := *cfg.IMDB
  28. baseImDb.Path = fmt.Sprintf(cfg.IMDB.Path, cfg.IMDB.Name)
  29. if err := db.InitImDB(&baseImDb); err != nil {
  30. panic(err)
  31. }
  32. utils.CurlDebug = true
  33. //cfg.InitMemCache()
  34. }
  35. func main() {
  36. go func() {
  37. // 初始化jobs方法列表、添加reload方法定时更新任务
  38. task.Init()
  39. task.Run()
  40. }()
  41. // graceful shutdown
  42. quit := make(chan os.Signal)
  43. signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
  44. <-quit
  45. _ = logx.Info("Server exiting...")
  46. }