当前位置：首页 > 文章列表 > Golang > Go问答 > Go bbolt 读事务内部启动写事务为什么会阻塞

Go bbolt 读事务内部启动写事务为什么会阻塞

来源：17golang原创 2026-10-13 16:48:40 0浏览收藏

Go bbolt 里，View 回调内部再次调用 Update，阻塞通常不是“写入太慢”，而是读写事务的生命周期互相等待。bbolt 同时允许多个只读事务，但同一时刻只有一个读写事务；写事务还可能需要重新映射数据文件，仍未结束的只读事务会让它无法完成这项工作。

官方地址：https://github.com/etcd-io/bbolt

先把读事务中要用的数据复制出来，结束 View，再在事务外启动独立的 Update。不要在同一个读事务生命周期里等待写事务完成。

先判断是不是读写事务嵌套

值班时先找三类信号：goroutine 卡在 db.Update，外层 db.View 回调迟迟不返回，以及同一调用链同时出现读事务和写事务。下面这种写法把两个生命周期叠在一起，读事务不结束，写事务就可能一直等。

// 错误示例：View 尚未返回时又等待 Update 完成。
err := db.View(func(tx *bolt.Tx) error {
    // 读取和判断可以在这里完成，但不要在这里启动写事务。
    b := tx.Bucket([]byte("jobs"))
    if b == nil || b.Get([]byte("pending")) == nil {
        return nil
    }
    // 写事务需要等待当前只读事务释放资源，形成相互等待风险。
    return db.Update(func(writeTx *bolt.Tx) error {
        return writeTx.Bucket([]byte("jobs")).Put([]byte("state"), []byte("done"))
    })
})
if err != nil {
    return err
}

快速判断时不要先改超时或盲目加锁。先确认 Update 是否由 View、游标回调或仍持有 *bolt.Tx 的函数间接触发；bbolt 官方 README 也明确提醒，事务通常不应在同一个 goroutine 中同时打开并相互依赖。

bbolt 读事务域、写事务域与文件映射边界的静态关系说明图 — 图1：事务嵌套说明图，查看读事务与唯一写事务的边界；这是静态说明图，不是运行截图。

把读取结果复制到事务外

处理方式是拆开两个阶段：View 只负责读取和判断，并把后续需要的数据复制到事务外；回调返回后，外层再调用 Update。官方文档还提醒，Get 返回的字节只在事务打开期间有效，因此复制动作不能省略。

// markDone 先读取快照，再用独立写事务更新状态。
func markDone(db *bolt.DB, id []byte) error {
    var shouldWrite bool

    err := db.View(func(tx *bolt.Tx) error {
        // 只在读事务内判断条件，不把 tx 带到外层保存。
        bucket := tx.Bucket([]byte("jobs"))
        if bucket == nil {
            return fmt.Errorf("jobs bucket does not exist")
        }
        value := bucket.Get(id)
        // 只保存判断结果；若要保存字节，必须 append 到新切片。
        shouldWrite = value != nil && bytes.Equal(value, []byte("pending"))
        return nil
    })
    if err != nil || !shouldWrite {
        return err
    }

    return db.Update(func(tx *bolt.Tx) error {
        // View 已经返回，写事务拥有独立的生命周期。
        bucket := tx.Bucket([]byte("jobs"))
        if bucket == nil {
            return fmt.Errorf("jobs bucket does not exist")
        }
        // Put 的错误必须返回，让 Update 决定提交还是回滚。
        return bucket.Put(id, []byte("done"))
    })
}

如果需要把值带出事务，写成 copied := append([]byte(nil), value...)；不要把 value 的原切片直接交给异步 worker。这个示例只表达结构关系，图示和代码都不是本机运行证据。