使用Golang并发遍历源和目标目录，通过walkDir函数将文件路径发送至channel，实现高效路径收集与元信息获取。
构建一个并发文件同步工具需要处理多个核心问题：文件遍历、内容比对、增量更新、以及在多 goroutine 环境下的读写安全。Golang 的并发模型和同步机制为此类任务提供了简洁高效的解决方案。下面通过实战方式讲解如何使用 Golang 实现一个基础但实用的并发文件同步工具。
1. 并发文件遍历与路径收集
文件同步的第一步是扫描源目录和目标目录，获取所有文件路径及其元信息（如修改时间、大小）。为了提升效率，可使用 goroutine 并发遍历目录树。
利用 walk 函数配合 channel 将发现的文件路径发送到管道中，由后续流程消费：
func walkDir(root string, fileCh chan<- string) {
filepath.Walk(root, func(path string, info os.FileInfo, err error) error {
if err != nil {
return nil // 忽略无法访问的文件
}
if !info.IsDir() {
fileCh <- path
}
return nil
})
close(fileCh)
}
启动多个 worker 处理文件列表时，可通过缓冲 channel 控制并发数，避免系统资源耗尽。
立即学习“go语言免费学习笔记（深入）”；
2. 文件内容比对与差异检测
同步前需判断哪些文件需要更新。常见策略是比较修改时间和文件大小，更精确的方式是计算哈希值（如 MD5 或 SHA256）。
为避免阻塞主线程，哈希计算可在独立 goroutine 中完成：
func hashFile(path string) (string, error) {
f, err := os.Open(path)
if err != nil {
return "", err
}
defer f.Close()
h := sha256.New()
_, err = io.Copy(h, f)
return fmt.Sprintf("%x", h.Sum(nil)), err}
将待同步文件分批送入工作池，每个 worker 计算源文件与目标文件的哈希是否一致，仅当不一致时触发复制操作。
3. 使用 sync.Mutex 保护共享状态
在并发环境下，多个 goroutine 可能同时尝试记录日志、更新进度或写入状态变量。这类共享资源必须加锁保护。
例如维护一个同步计数器：
var (
mu sync.Mutex
copiedCount int
)
func incCopied() {
mu.Lock()
defer mu.Unlock()
copiedCount++
}
也可使用 sync.Atomic 操作替代锁，提高性能：
atomic.AddInt32(&copiedCount, 1)
4. 控制并发度：带缓冲的工作池
盲目开启大量 goroutine 会导致系统负载过高。推荐使用固定数量的 worker 从任务 channel 消费任务，实现可控并发。
示例代码：
func startWorkers(tasks <-chan FileTask, workers int) {
var wg sync.WaitGroup
for i := 0; i < workers; i++ {
wg.Add(1)
go func() {
defer wg.Done()
for task := range tasks {
task.Process()
}
}()
}
wg.Wait()
}
主流程将差异文件构造成任务放入 channel，worker 自动拉取并执行复制逻辑。
基本上就这些。通过合理使用 channel 进行数据传递、用 mutex 或 atomic 保证状态一致性，并控制并发规模，就能构建出稳定高效的文件同步工具。实际项目中还可加入错误重试、断点续传、实时监控等功能进一步增强健壮性。
