如何在Golang中实现并发数据写入数据库-Golang-PHP中文网

如何在Golang中实现并发数据写入数据库

P粉602998670

发布： 2025-11-03 23:52:02

原创

919人浏览过

使用goroutine配合连接池和worker模式控制并发写入数据库，设置MaxOpenConns、MaxIdleConns和ConnMaxLifetime优化连接管理，通过channel限制协程数量，避免资源竞争与连接耗尽，结合错误重试机制保障写入稳定性。

如何在golang中实现并发数据写入数据库

在Golang中实现并发数据写入数据库，关键在于合理使用goroutine、连接池和锁机制，同时避免资源竞争和数据库连接耗尽。下面是一些实用的方法和注意事项。

使用数据库连接池

Golang的database/sql包自带连接池功能，正确配置能有效支持并发写入。

建议设置：

SetMaxOpenConns(n)：控制最大并发连接数，避免数据库压力过大
SetMaxIdleConns(n)：设置空闲连接数，提升重复利用效率
SetConnMaxLifetime(t)：防止长时间运行后连接失效

例如：

立即学习“go语言免费学习笔记（深入）”；

db.SetMaxOpenConns(50)
db.SetMaxIdleConns(10)
db.SetConnMaxLifetime(time.Hour)

通过goroutine并发写入

启动多个goroutine处理数据写入，每个goroutine使用独立的语句或事务。

示例：

for _, data := range dataList {
  go func(d Data) {
    _, err := db.Exec("INSERT INTO table VALUES (?, ?)", d.A, d.B)
    if err != nil {
      log.Printf("写入失败: %v", err)
    }
  } (data)
}

注意：直接这样写可能创建太多goroutine，应使用限制机制。

腾讯智影-AI数字人

基于AI数字人能力，实现7*24小时AI数字人直播带货，低成本实现直播业务快速增增，全天智能在线直播

查看详情

控制并发数量（使用Worker模式）

避免无节制地启动goroutine，推荐使用固定数量的工作协程从通道读取任务。

实现方式：

创建一个带缓冲的channel存放待写入数据
启动固定数量的worker goroutine从channel读取并执行写入
主协程将数据发送到channel

这样既能并发又能控制负载。

处理并发中的错误与重试

并发写入可能遇到唯一键冲突、超时等问题。

建议做法：

每个写入操作都检查返回的error
对可重试错误（如网络超时）实现指数退避重试逻辑
记录失败日志，必要时落盘重推

基本上就这些。合理利用Go的并发模型和数据库驱动特性，就能安全高效地实现并发写入。关键是别让goroutine失控，也别把数据库连接打满。

以上就是如何在Golang中实现并发数据写入数据库的详细内容，更多请关注php中文网其它相关文章！

大家都在看：

Go 语言类型系统深度解析：理解命名类型与匿名类型的兼容性 Go 语言类型一致性：命名与非命名类型在函数别名中的作用 Go语言中实现泛型加法：深入理解反射与类型断言 Go语言中的结构体初始化、命名参数与工厂函数模式 Go语言中接口类型与nil的陷阱：理解指针为nil但接口不为nil的场景