使用Golang实现备份恢复系统，先通过filepath.Walk递归复制文件到目标目录实现备份，再结合archive/tar和compress/gzip将目录压缩为tar.gz格式节省空间，利用robfig/cron库设置定时任务每日自动执行备份，最后通过解压tar.gz文件并还原目录结构完成恢复，支持完整文件级备份与恢复功能。
在运维和开发中，数据的安全性至关重要。Golang 由于其高效的并发支持和简洁的语法，非常适合用来编写自动化备份与恢复工具。下面介绍如何使用 Golang 实现基础但实用的文件级自动化备份与恢复功能。
1. 实现文件备份功能
备份的核心是将指定目录或文件复制到安全位置，比如本地归档目录或远程存储。Golang 提供了 os、io 和 filepath 包来处理文件操作。
以下是一个简单的递归备份函数示例：
func backupDir(src, dst string) error {
return filepath.Walk(src, func(path string, info os.FileInfo, err error) error {
if err != nil {
return err
}
// 计算相对路径
relPath, _ := filepath.Rel(src, path)
destPath := filepath.Join(dst, relPath)
if info.IsDir() {
return os.MkdirAll(destPath, info.Mode())
}
// 打开源文件
srcFile, err := os.Open(path)
if err != nil {
return err
}
defer srcFile.Close()
// 创建目标文件
destFile, err := os.Create(destPath)
if err != nil {
return err
}
defer destFile.Close()
// 复制内容
_, err = io.Copy(destFile, srcFile)
return err
})}
调用方式：
err := backupDir("/data/app", "/backup/app_20251010")
if err != nil {
log.Fatal("Backup failed:", err)
}
2. 添加压缩功能减少存储占用
为了节省空间，可以将备份内容打包为 tar.gz 文件。Golang 的 archive/tar 和 compress/gzip 包能轻松实现此功能。
示例：将目录压缩为 .tar.gz
func createTarGz(src, tarFile string) error {
outFile, err := os.Create(tarFile)
if err != nil {
return err
}
defer outFile.Close()
gzipWriter := gzip.NewWriter(outFile)
defer gzipWriter.Close()
tarWriter := tar.NewWriter(gzipWriter)
defer tarWriter.Close()
return filepath.Walk(src, func(path string, info os.FileInfo, err error) error {
if err != nil {
return err
}
header, err := tar.FileInfoHeader(info, "")
if err != nil {
return err
}
// 使用相对路径
relPath, _ := filepath.Rel(src, path)
header.Name = relPath
if err := tarWriter.WriteHeader(header); err != nil {
return err
}
if !info.Mode().IsRegular() {
return nil
}
file, err := os.Open(path)
if err != nil {
return err
}
defer file.Close()
_, err = io.Copy(tarWriter, file)
return err
})}
return err
}
// 使用相对路径
relPath, _ := filepath.Rel(src, path)
header.Name = relPath
if err := tarWriter.WriteHeader(header); err != nil {
return err
}
if !info.Mode().IsRegular() {
return nil
}
file, err := os.Open(path)
if err != nil {
return err
}
defer file.Close()
_, err = io.Copy(tarWriter, file)
return err
})3. 实现自动定时备份
使用 time.Ticker 或第三方库如 robfig/cron 可以实现周期性任务。
例如，每天凌晨执行一次备份：
c := cron.New()
c.AddFunc("0 0 * * *", func() {
timestamp := time.Now().Format("20060102_150405")
backupPath := fmt.Sprintf("/backup/app_%s.tar.gz", timestamp)
err := createTarGz("/data/app", backupPath)
if err != nil {
log.Println("Backup failed:", err)
} else {
log.Println("Backup completed:", backupPath)
}
})
c.Start()
4. 恢复备份数据
恢复过程是压缩的逆操作：解压 tar.gz 并写入目标目录。
func restoreFromTarGz(tarFile, dest string) error {
inFile, err := os.Open(tarFile)
if err != nil {
return err
}
defer inFile.Close()
gzipReader, err := gzip.NewReader(inFile)
if err != nil {
return err
}
defer gzipReader.Close()
tarReader := tar.NewReader(gzipReader)
for {
header, err := tarReader.Next()
if err == io.EOF {
break
}
if err != nil {
return err
}
targetPath := filepath.Join(dest, header.Name)
switch header.Typeflag {
case tar.TypeDir:
if _, err := os.Stat(targetPath); err != nil {
os.MkdirAll(targetPath, 0755)
}
case tar.TypeReg:
outFile, err := os.Create(targetPath)
if err != nil {
return err
}
_, err = io.Copy(outFile, tarReader)
outFile.Close()
if err != nil {
return err
}
}
}
return nil}
调用示例：
err := restoreFromTarGz("/backup/app_20251010.tar.gz", "/data/app")
if err != nil {
log.Fatal("Restore failed:", err)
}
基本上就这些。通过组合文件遍历、压缩归档和定时任务，你可以构建一个轻量但可靠的备份恢复系统。根据需要可扩展上传到 S3、校验哈希、保留策略等功能。不复杂但容易忽略细节，比如权限保留和错误处理。
