首页 > Golang > Go教程

Golang自动化运维任务实战示例

时间：2025-12-16 12:20:41 393浏览收藏

推广推荐

支持 PC / 移动端，安全直达

本篇文章向大家介绍《Golang自动化运维任务实现示例》，主要包括，具有一定的参考价值，需要的朋友可以参考一下。

Golang通过其高并发与高性能特性，适用于构建自动化运维工具。1. 使用time.Ticker实现每5分钟定时巡检磁盘使用率；2. 结合filepath.Walk与time.NewTicker每日清理超7天日志；3. 通过systemctl命令监控服务状态并自动重启异常服务；4. 利用golang.org/x/crypto/ssh批量连接远程服务器执行命令。合理使用标准库与第三方包，辅以错误处理与日志记录，可构建稳定运维工具。

Golang实现自动化运维任务示例

自动化运维是提升系统稳定性和运维效率的关键手段。Golang凭借其高并发、编译型语言的性能优势，非常适合编写轻量高效、可长期运行的运维工具。下面通过几个常见场景展示如何使用Golang实现自动化运维任务。

1. 定时执行系统巡检任务

使用 time.Ticker 可以实现周期性执行系统健康检查，比如检测磁盘使用率、内存状态等。

示例：每5分钟检查一次磁盘使用情况

package main
<p>import (
"fmt"
"os/exec"
"strings"
"time"
)</p><p>func checkDiskUsage() {
cmd := exec.Command("df", "-h")
output, err := cmd.Output()
if err != nil {
fmt.Printf("执行df命令失败: %v\n", err)
return
}</p><pre class="brush:php;toolbar:false"><code>lines := strings.Split(string(output), "\n")
for _, line := range lines {
    if strings.Contains(line, "/dev/") {
        fmt.Println("磁盘状态:", line)
    }
}</code>

}

func main() { ticker := time.NewTicker(5 * time.Minute) defer ticker.Stop()

fmt.Println("启动定时巡检...")
checkDiskUsage() // 立即执行一次

for range ticker.C {
    checkDiskUsage()
}

}

2. 自动化日志清理

定期清理过期日志文件可以防止磁盘被占满。使用Golang的文件系统操作结合定时器可轻松实现。

package main
<p>import (
"fmt"
"os"
"path/filepath"
"time"
)</p><p>func cleanupLogs(logDir string, maxAgeDays int) {
now := time.Now()
cutoff := now.AddDate(0, 0, -maxAgeDays)</p><pre class="brush:php;toolbar:false"><code>filepath.Walk(logDir, func(path string, info os.FileInfo, err error) error {
    if err != nil {
        return nil
    }
    if !info.IsDir() && filepath.Ext(path) == ".log" && info.ModTime().Before(cutoff) {
        os.Remove(path)
        fmt.Printf("已删除过期日志: %s\n", path)
    }
    return nil
})</code>

}

func main() { for range time.NewTicker(24 * time.Hour).C { cleanupLogs("/var/log/myapp", 7) } }

3. 服务状态监控与自动重启

通过执行 shell 命令检查服务是否运行，若未运行则自动拉起。

以监控一个名为 myweb 的 systemd 服务为例：

package main
<p>import (
"fmt"
"os/exec"
"strings"
"time"
)</p><p>func isServiceRunning(serviceName string) bool {
cmd := exec.Command("systemctl", "is-active", serviceName)
output, err := cmd.Output()
return err == nil && strings.TrimSpace(string(output)) == "active"
}</p><p>func startService(serviceName string) {
cmd := exec.Command("systemctl", "start", serviceName)
err := cmd.Run()
if err != nil {
fmt.Printf("启动服务 %s 失败: %v\n", serviceName, err)
} else {
fmt.Printf("已启动服务: %s\n", serviceName)
}
}</p><p>func monitorService(serviceName string) {
ticker := time.NewTicker(30 * time.Second)
defer ticker.Stop()</p><pre class="brush:php;toolbar:false"><code>for range ticker.C {
    if !isServiceRunning(serviceName) {
        fmt.Printf("服务 %s 已停止，正在重启...\n", serviceName)
        startService(serviceName)
    }
}</code>

}

func main() { monitorService("myweb") }

4. 批量执行远程命令（基于SSH）

使用第三方库 golang.org/x/crypto/ssh 可实现对多台服务器批量执行命令。

示例：连接远程主机并获取系统负载

package main
<p>import (
"fmt"
"golang.org/x/crypto/ssh"
"io/ioutil"
"time"
)</p><p>func runSSHCommand(host, user, keyPath, command string) error {
key, err := ioutil.ReadFile(keyPath)
if err != nil {
return fmt.Errorf("无法读取私钥: %v", err)
}</p><pre class="brush:php;toolbar:false"><code>signer, err := ssh.ParsePrivateKey(key)
if err != nil {
    return fmt.Errorf("解析私钥失败: %v", err)
}

config := &ssh.ClientConfig{
    User: user,
    Auth: []ssh.AuthMethod{ssh.PublicKeys(signer)},
    HostKeyCallback: ssh.InsecureIgnoreHostKey(),
    Timeout: 5 * time.Second,
}

client, err := ssh.Dial("tcp", host+":22", config)
if err != nil {
    return fmt.Errorf("SSH连接失败: %v", err)
}
defer client.Close()

session, err := client.NewSession()
if err != nil {
    return err
}
defer session.Close()

output, err := session.CombinedOutput(command)
fmt.Printf("[%s] %s\n", host, string(output))
return err</code>

}

func main() { servers := []string{"192.168.1.10", "192.168.1.11"} for _, server := range servers { go runSSHCommand(server, "root", "/root/.ssh/id_rsa", "uptime") } time.Sleep(5 * time.Second) // 等待执行完成 }

基本上就这些。Golang写运维脚本不复杂但容易忽略错误处理和并发控制。只要合理利用标准库和第三方模块，就能构建出稳定可靠的自动化运维工具。建议结合 cron 或 systemd 启动长期任务，并将输出重定向到日志文件以便排查问题。

到这里，我们也就讲完了《Golang自动化运维任务实战示例》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于golang,自动化运维的知识点！

golang 自动化运维