等待次要副本与主副本同步完成的方法

在 MongoDB 集群中，为了确保副本与主副本同步完成，可以使用 WriteConcern 来控制写入传播。通过设置 WriteConcern.W(2)，可以要求写入操作等待来自 2 个节点（主副本和 2 个副本）的确认。将 WriteConcern 应用于特定集合或整个客户端，可以确保写入操作不会在副本追上主副本之前继续。

有一个mongodb集群（1主2副本）

更新记录数量较多，对于本次使用的BulkWrite，需要在replica追上master后调用下一个BulkWrite，需要确保replica已经追上master的请求。使用 go.mongodb.org/mongo-driver/mongo

正确答案

可以使用 writeconcern.WriteConcern“控制”写入传播。

writeconcern 可以使用不同的 writeconcern.Option 创建。 writeconcern.w() 函数可用于创建 writeconcern.option 来控制必须传播多少个实例写入（或更具体地说，写入操作将等待来自给定数量实例的确认）：

func w(w int) option

w 请求确认写入操作传播到指定数量的 mongod 实例。

因此，首先您需要创建一个 writeconcern.writeconcern ，它被正确配置为等待来自您案例中的 2 个节点的确认（您有 1 个主节点和 2 个副本节点）：

wc := writeconcern.new(writeconcern.w(2))

您现在必须选择此写入关注的范围：它可能应用于整个 mongo.Client，也可能应用于 mongo.Database 或仅应用于 mongo.Collection。

创建客户端、获取数据库或只是一个集合都有允许指定写入关注的选项，因此这实际上取决于您希望将其应用到何处。

如果您只是希望此写入问题对某些更新产生影响，则只需将其应用于用于执行更新的 mongo.collection 即可：

var client *mongo.Client // Initialize / connect client 

wc := writeconcern.New(writeconcern.W(2))
c := client.Database("").
    Collection("",
        options.Collection().SetWriteConcern(wc))

现在，如果您使用此 c 集合来执行写入（更新），则将使用/应用 c 写入关注点，也就是说，每个写入操作将等待传播到 2 个实例的写入的确认。

如果您将 mongo.client 应用 wc 写入音乐会，那么这将是您对该客户端所做的所有操作的默认写入关注点，如果您将其应用于 mongo.database，那么它将是默认为您对该数据库执行的所有操作。当然，默认值可以被覆盖，就像我们在上面的示例中如何在 c 集合上应用 c 一样。

到这里，我们也就讲完了《等待次要副本与主副本同步完成的方法》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！