golang守护进程编写工具插件库godaemon的使用

godaemon - Golang守护进程编写工具插件库

godaemon是一个使用exec()而不是fork()来守护进程化Go应用程序的库。

为什么需要godaemon

在Go中无法以常规方式实现守护进程化。守护进程化是一个Unix概念，需要一些在Go中不容易实现的特定操作。但如果你不介意程序会多次启动自身副本（而不是像许多程序员习惯的那样使用fork()），你仍然可以实现相同的目标。

快速开始

要在你的程序中实现守护进程化，请尽可能早地在main()函数中添加以下代码：

import (
	"github.com/VividCortex/godaemon"
)

func main() {
	godaemon.MakeDaemon(&godaemon.DaemonAttr{})
}

完整示例

下面是一个完整的示例，展示如何使用godaemon创建一个守护进程：

package main

import (
	"fmt"
	"log"
	"os"
	"time"
	
	"github.com/VividCortex/godaemon"
)

func main() {
	// 将程序转为守护进程
	godaemon.MakeDaemon(&godaemon.DaemonAttr{
		// 可选：捕获标准输出和标准错误
		CaptureOutput: true,
		// 可选：指定要继承的文件描述符
		Files: []*os.File{os.Stdin, os.Stdout, os.Stderr},
	})
	
	// 守护进程主逻辑
	log.Println("Daemon started with PID:", os.Getpid())
	
	for i := 1; ; i++ {
		log.Printf("Daemon running, iteration %d", i)
		time.Sleep(5 * time.Second)
	}
}

高级用法

捕获输出

如果你需要捕获程序的标准输出和标准错误流，可以使用CaptureOutput属性：

stdout, stderr, err := godaemon.MakeDaemon(&godaemon.DaemonAttr{
	CaptureOutput: true,
})

if err != nil {
	log.Fatal(err)
}

// 你可以读取stdout和stderr的内容
go io.Copy(os.Stdout, stdout)
go io.Copy(os.Stderr, stderr)

继承文件描述符

如果需要将打开的文件继承到守护进程中，可以使用Files属性：

file, err := os.OpenFile("lockfile", os.O_RDWR|os.O_CREATE, 0666)
if err != nil {
	log.Fatal(err)
}

godaemon.MakeDaemon(&godaemon.DaemonAttr{
	Files: []*os.File{file},
})

注意事项

  1. 使用此包的方法时需要特别小心，因为它与Go的常规使用模式有所不同
  2. 不要在init()函数中启动goroutine或执行其他可能在守护进程化过程中导致问题的操作
  3. 不要使用文件继承功能来继承TTY描述符，否则从技术上讲你得到的不是一个真正的守护进程

许可证

本仓库版权归VividCortex, Inc.所有，采用MIT许可证授权。


更多关于golang守护进程编写工具插件库godaemon的使用的实战教程也可以访问 https://www.itying.com/category-94-b0.html

1 回复

更多关于golang守护进程编写工具插件库godaemon的使用的实战系列教程也可以访问 https://www.itying.com/category-94-b0.html


godaemon - Go语言守护进程工具库

godaemon 是一个用于将Go应用程序转换为守护进程(daemon)的工具库，它可以帮助你轻松地将普通程序转换为后台运行的守护进程。

安装

go get github.com/VividCortex/godaemon

基本用法

1. 最简单的守护进程

package main

import (
	"log"
	"time"
	
	"github.com/VividCortex/godaemon"
)

func main() {
	// 将当前进程转换为守护进程
	godaemon.MakeDaemon(&godaemon.DaemonAttr{})

	// 守护进程的工作逻辑
	for {
		log.Println("Daemon is running...")
		time.Sleep(5 * time.Second)
	}
}

2. 带配置的守护进程

package main

import (
	"log"
	"os"
	"time"
	
	"github.com/VividCortex/godaemon"
)

func main() {
	// 配置守护进程属性
	daemonAttr := &godaemon.DaemonAttr{
		ProcName: "my_daemon",     // 进程名称
		LogFile:  "/var/log/my_daemon.log", // 日志文件
		PidFile:  "/var/run/my_daemon.pid", // PID文件
		Umask:    022,             // 文件权限掩码
	}

	// 转换为守护进程
	godaemon.MakeDaemon(daemonAttr)

	// 守护进程工作逻辑
	log.Println("Daemon started with PID:", os.Getpid())
	
	ticker := time.NewTicker(10 * time.Second)
	defer ticker.Stop()
	
	for range ticker.C {
		log.Println("Daemon is working...")
	}
}

高级功能

1. 信号处理

package main

import (
	"log"
	"os"
	"os/signal"
	"syscall"
	"time"
	
	"github.com/VividCortex/godaemon"
)

func main() {
	daemonAttr := &godaemon.DaemonAttr{
		ProcName: "signal_daemon",
		LogFile:  "/var/log/signal_daemon.log",
	}

	godaemon.MakeDaemon(daemonAttr)

	// 设置信号处理
	sigChan := make(chan os.Signal, 1)
	signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)

	log.Println("Daemon started with PID:", os.Getpid())

	// 主循环
	for {
		select {
		case sig := <-sigChan:
			log.Printf("Received signal: %v, shutting down...\n", sig)
			// 清理工作
			log.Println("Cleanup completed")
			os.Exit(0)
		default:
			// 正常工作
			log.Println("Working...")
			time.Sleep(5 * time.Second)
		}
	}
}

2. 重启功能

package main

import (
	"log"
	"os"
	"os/signal"
	"syscall"
	"time"
	
	"github.com/VividCortex/godaemon"
)

func main() {
	daemonAttr := &godaemon.DaemonAttr{
		ProcName: "restartable_daemon",
		LogFile:  "/var/log/restartable_daemon.log",
		PidFile:  "/var/run/restartable_daemon.pid",
	}

	godaemon.MakeDaemon(daemonAttr)

	// 设置信号处理
	sigChan := make(chan os.Signal, 1)
	signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP)

	log.Println("Daemon started with PID:", os.Getpid())

	// 主循环
	for {
		select {
		case sig := <-sigChan:
			switch sig {
			case syscall.SIGHUP:
				log.Println("Received SIGHUP, reloading config...")
				// 重新加载配置
			case syscall.SIGINT, syscall.SIGTERM:
				log.Printf("Received %v, shutting down...\n", sig)
				os.Exit(0)
			}
		default:
			// 正常工作
			log.Println("Working...")
			time.Sleep(5 * time.Second)
		}
	}
}

注意事项

  1. 日志记录：守护进程没有控制台输出，必须将日志写入文件或系统日志(syslog)
  2. 资源限制：守护进程应该小心管理文件描述符等资源
  3. 权限管理：考虑以什么用户身份运行守护进程
  4. 工作目录：守护进程通常会改变工作目录到根目录("/")

替代方案

如果你需要更多功能，也可以考虑以下替代方案：

  • github.com/sevlyar/go-daemon
  • github.com/takama/daemon

godaemon 是一个轻量级的解决方案，适合简单的守护进程需求。对于更复杂的需求，可能需要考虑其他更全功能的库。

回到顶部