首页 > 编程语言 >多个AJAX请求并发写入同一文件的安全方法

多个AJAX请求并发写入同一文件的安全方法

来源：互联网 2026-06-30 08:02:05

本文介绍在 go 语言中通过单写 goroutine + 通道（channel）模式实现高并发 ajax 请求下的安全、非阻塞文件写入，避免竞态、数据错乱和响应延迟问题。在 Web 服务里，多个 AJAX 请求同时往同一个文件里追加日志或数据，这事儿看着简单，真要处理好却没那么容易。直接拿 syn

本文介绍在 go 语言中通过单写 goroutine + 通道（channel）模式实现高并发 ajax 请求下的安全、非阻塞文件写入，避免竞态、数据错乱和响应延迟问题。

在 Web 服务里，多个 AJAX 请求同时往同一个文件里追加日志或数据，这事儿看着简单，真要处理好却没那么容易。直接拿 sync.Mutex 锁一把？确实能防并发写入，但问题是——锁一加，请求处理就变成串行的了，I/O 冲突不但没根治，响应速度反而被拖得死死的。更麻烦的是，进程内的锁根本管不了跨进程或重启后的写冲突，操作系统层面的文件句柄竞争更是防不胜防。

那怎么办？其实社区里早就有一个非常成熟的解法：把“接收请求”和“写入文件”这两件事彻底拆开——用单个专门的 goroutine 来写，别的所有处理器只管发数据，发完就走。

长期稳定更新的攒劲资源： >>>点此立即查看<<<

推荐方案：单写 goroutine + 缓冲通道

核心逻辑就三条：

文件只由一个专用的 goroutine 打开，并且一直持有它，从头写到尾；
所有 HTTP 处理器（比如这里的 ajaxHandler）只负责把待写的数据塞进一个缓冲通道，自己绝不去碰文件 I/O；
写入操作完全解耦，文件操作绝对串行，而请求响应几乎零等待——数据扔进通道就返回，剩下的事交给后台。

直接看一个可运行的完整例子：

package main

import (
    "fmt"
    "log"
    "net/http"
    "os"
)

var (
    f      *os.File
    datach = make(chan string, 100)
)

func init() {
    var err error
    f, err = os.OpenFile("requests.log", os.O_CREATE|os.O_APPEND|os.O_WRONLY, 0644)
    if err != nil {
        log.Fatal("无法打开日志文件:", err)
    }
    go func() {
        defer f.Close()
        for line := range datach {
            if _, err := f.WriteString(line + "n"); err != nil {
                log.Printf("写入日志失败: %v", err)
            }
        }
    }()
}

func ajaxHandler(w http.ResponseWriter, r *http.Request) {
    clientIP := r.RemoteAddr
    timestamp := fmt.Sprintf("%s", r.URL.Query().Get("t"))
    logEntry := fmt.Sprintf("[%s] %s - AJAX request at %s", r.Method, clientIP, timestamp)
    select {
    case datach <- logEntry:
        w.WriteHeader(http.StatusOK)
        w.Write([]byte("OK"))
    default:
        http.Error(w, "服务器繁忙，请稍后重试", http.StatusServiceUna vailable)
    }
}

func main() {
    http.HandleFunc("/write", ajaxHandler)
    log.Println("服务器启动，监听 :8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

关键设计说明

缓冲通道大小：make(chan string, 100) 里的 100 怎么定？得看你的峰值 QPS 和单次写入耗时。太小了容易触发 default 分支，直接返回 503；太大了内存占用高，而且程序意外崩溃时通道里积压的数据全丢。建议配合 Prometheus 实时监控 len(datach) 的水平，动态调整。
错误处理边界：写入失败时 HTTP 响应已经发出去了，客户端拿不到这个错误。所以必须在写入 goroutine 里记录错误日志，并配好落盘失败的告警——这是安全兜底。
优雅关闭：程序退出前，一定要 close(datach)，这样写入 goroutine 才能正常退出，把缓冲区里的数据刷干净。用 signal.Notify 捕捉 SIGINT/SIGTERM 来实现。
扩展性提示：如果数据可靠性要求更高，可以把通道里待写的内容先持久化到 WAL（预写日志），或者干脆切换到结构化日志系统，比如 Loki + Promtail。