1
0

daemon.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128
  1. package daemon
  2. import (
  3. "fmt"
  4. "os"
  5. "github.com/astaxie/beego"
  6. "github.com/kardianos/service"
  7. "github.com/lifei6671/mindoc/commands"
  8. "github.com/lifei6671/mindoc/conf"
  9. "github.com/lifei6671/mindoc/controllers"
  10. "path/filepath"
  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. beego.ErrorController(&controllers.ErrorController{})
  41. f,err := filepath.Abs(os.Args[0])
  42. if err != nil {
  43. f = os.Args[0]
  44. }
  45. fmt.Printf("MinDoc version => %s\nbuild time => %s\nstart directory => %s\n%s\n", conf.VERSION, conf.BUILD_TIME, f, conf.GO_VERSION)
  46. beego.Run()
  47. }
  48. func (d *Daemon) Stop(s service.Service) error {
  49. if service.Interactive() {
  50. os.Exit(0)
  51. }
  52. return nil
  53. }
  54. func Install() {
  55. d := NewDaemon()
  56. d.config.Arguments = os.Args[3:]
  57. s, err := service.New(d, d.config)
  58. if err != nil {
  59. beego.Error("Create service error => ", err)
  60. os.Exit(1)
  61. }
  62. err = s.Install()
  63. if err != nil {
  64. beego.Error("Install service error:", err)
  65. os.Exit(1)
  66. } else {
  67. beego.Info("Service installed!")
  68. }
  69. os.Exit(0)
  70. }
  71. func Uninstall() {
  72. d := NewDaemon()
  73. s, err := service.New(d, d.config)
  74. if err != nil {
  75. beego.Error("Create service error => ", err)
  76. os.Exit(1)
  77. }
  78. err = s.Uninstall()
  79. if err != nil {
  80. beego.Error("Install service error:", err)
  81. os.Exit(1)
  82. } else {
  83. beego.Info("Service uninstalled!")
  84. }
  85. os.Exit(0)
  86. }
  87. func Restart() {
  88. d := NewDaemon()
  89. s, err := service.New(d, d.config)
  90. if err != nil {
  91. beego.Error("Create service error => ", err)
  92. os.Exit(1)
  93. }
  94. err = s.Restart()
  95. if err != nil {
  96. beego.Error("Install service error:", err)
  97. os.Exit(1)
  98. } else {
  99. beego.Info("Service Restart!")
  100. }
  101. os.Exit(0)
  102. }