daemon.go 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
  1. package daemon
  2. import (
  3. "fmt"
  4. "os"
  5. "path/filepath"
  6. "github.com/astaxie/beego"
  7. "github.com/kardianos/service"
  8. "github.com/mindoc-org/mindoc/commands"
  9. "github.com/mindoc-org/mindoc/conf"
  10. "github.com/mindoc-org/mindoc/controllers"
  11. )
  12. type Daemon struct {
  13. config *service.Config
  14. errs chan error
  15. }
  16. func NewDaemon() *Daemon {
  17. config := &service.Config{
  18. Name: "mindocd", //服务显示名称
  19. DisplayName: "MinDoc service", //服务名称
  20. Description: "A document online management program.", //服务描述
  21. WorkingDirectory: conf.WorkingDirectory,
  22. Arguments: os.Args[1:],
  23. }
  24. return &Daemon{
  25. config: config,
  26. errs: make(chan error, 100),
  27. }
  28. }
  29. func (d *Daemon) Config() *service.Config {
  30. return d.config
  31. }
  32. func (d *Daemon) Start(s service.Service) error {
  33. go d.Run()
  34. return nil
  35. }
  36. func (d *Daemon) Run() {
  37. commands.ResolveCommand(d.config.Arguments)
  38. commands.RegisterFunction()
  39. commands.RegisterAutoLoadConfig()
  40. commands.RegisterError()
  41. beego.ErrorController(&controllers.ErrorController{})
  42. f, err := filepath.Abs(os.Args[0])
  43. if err != nil {
  44. f = os.Args[0]
  45. }
  46. fmt.Printf("MinDoc version => %s\nbuild time => %s\nstart directory => %s\n%s\n", conf.VERSION, conf.BUILD_TIME, f, conf.GO_VERSION)
  47. beego.Run()
  48. }
  49. func (d *Daemon) Stop(s service.Service) error {
  50. if service.Interactive() {
  51. os.Exit(0)
  52. }
  53. return nil
  54. }
  55. func Install() {
  56. d := NewDaemon()
  57. d.config.Arguments = os.Args[3:]
  58. s, err := service.New(d, d.config)
  59. if err != nil {
  60. beego.Error("Create service error => ", err)
  61. os.Exit(1)
  62. }
  63. err = s.Install()
  64. if err != nil {
  65. beego.Error("Install service error:", err)
  66. os.Exit(1)
  67. } else {
  68. beego.Info("Service installed!")
  69. }
  70. os.Exit(0)
  71. }
  72. func Uninstall() {
  73. d := NewDaemon()
  74. s, err := service.New(d, d.config)
  75. if err != nil {
  76. beego.Error("Create service error => ", err)
  77. os.Exit(1)
  78. }
  79. err = s.Uninstall()
  80. if err != nil {
  81. beego.Error("Install service error:", err)
  82. os.Exit(1)
  83. } else {
  84. beego.Info("Service uninstalled!")
  85. }
  86. os.Exit(0)
  87. }
  88. func Restart() {
  89. d := NewDaemon()
  90. s, err := service.New(d, d.config)
  91. if err != nil {
  92. beego.Error("Create service error => ", err)
  93. os.Exit(1)
  94. }
  95. err = s.Restart()
  96. if err != nil {
  97. beego.Error("Install service error:", err)
  98. os.Exit(1)
  99. } else {
  100. beego.Info("Service Restart!")
  101. }
  102. os.Exit(0)
  103. }