MongoDB CRUD操作：可重试写入

MongoDB CRUD操作：可重试写入

MongoDB的Retryable Writes是一种容错机制，旨在提高数据库操作的可靠性和稳定性。用于在遇到网络波动、副本集节点故障等临时性问题时，自动重新执行写操作。这种机制的目的是确保数据能够安全、准确地写入数据库，从而增强数据库的鲁棒性和可用性。

使用的先决条件

要使用可重试写入，有以下先决条件要求：

部署的限制

可重试写入需要副本集或分片集群，不支持独立实例。

支持的存储引擎

可重试写入需要支持文档级锁定的存储引擎，例如 WiredTiger 或内存存储引擎。

3.6+ MongoDB 驱动程序

客户端需要针对 MongoDB 3.6 或更高版本更新 MongoDB 驱动程序：

Java 3.6+ Python 3.6+ C 1.9+

Go 1.8+ C# 2.5+ Node 3.0+

Ruby 2.5+ Rust 2.1+ Swift 1.2+

Perl 2.0+ PHPC 1.4+ Scala 2.2+

C++ 3.6.6+

MongoDB 版本

集群中每个节点的MongoDB版本必须为3.6或更高版本，集群中每个节点的featureCompatibilityVersion必须为3.6或更高版本。有关 featureCompatibilityVersion 标志的更多信息，请参阅 setFeatureCompatibilityVersion。

写确认

写入关注值为 0 的写入操作不可重试。

可重试写入和多文档事务

事务提交和中止操作是可重试的写操作。如果提交操作或中止操作遇到错误，MongoDB 驱动程序会重试该操作一次，无论 retryWrites 是否设置为 false。

无论 retryWrites 的值如何，事务内的写入操作都不可单独重试。

启用可重试写入

MongoDB驱动

与 MongoDB 4.2 及更高版本兼容的驱动程序默认启用可重试写入。早期的驱动程序需要 retryWrites=true 选项。在使用与 MongoDB 4.2 及更高版本兼容的驱动程序的应用程序中，可以省略 retryWrites=true 选项。
要禁用可重试写入，使用与 MongoDB 4.2 及更高版本兼容的驱动程序的应用程序必须在连接字符串中包含 retryWrites=false。

mongosh

mongosh 中默认启用可重试写入。要禁用可重试写入，请使用 --retryWrites=false 命令行选项：

mongosh --retryWrites=false

可重试的写操作

当发出已确认的写关注时，以下写操作可重试；例如，写关注不能为 {w.0}： 0}.

事务内的写入操作不可单独重试。

方法	说明
db.collection.insertOne()	插入操作
db.collection.insertMany()	插入操作
db.collection.updateOne()	单文档更新操作
db.collection.replaceOne()	单文档更新操作
db.collection.deleteOne()	单文档删除
db.collection.remove()其中justOne为true	单文档删除
db.collection.findAndModify()	单文档更新
db.collection.findOneAndDelete()	单文档删除
db.collection.findOneAndReplace()	单文档更新
db.collection.findOneAndUpdate()	单文档更新
db.collection.bulkWrite()的写操作insertOne、updateOne、replaceOne、deleteOne	只包含单文档写入操作的批量写入操作。可重试的批量操作可包括指定写入操作的任何组合，但不能包括任何多文档写入操作，如updateMany
Bulk操作的Bulk.find.removeOne()、Bulk.find.replaceOne()、Bulk.find.updateOne()	只包含单文档写入操作的批量写入操作。可重试的批量操作可以包括指定写入操作的任何组合，但不能包括任何多文档写入操作，例如为多选项指定为true的更新

行为

持续的网络错误

MongoDB的可重试写入只进行一次重试尝试，这会有助于解决瞬时网络错误和副本集选举问题，但不能解决持续性网络错误。

故障切换周期

如果驱动程序在目标副本集或分片集群分片中找不到运行状况良好的主数据库，则驱动程序将等待serverSelectionTimeoutMS毫秒以确定新的主数据库，然后再重试。可重试写入不能解决故障转移时间超过serverSelectionTimeoutMS的情况。

如果客户端应用程序在发出写入操作后无响应的时间超过localLogicalSessionTimeoutMinutes，则当客户端应用程序开始响应（无需重新启动）时，可能会重试并再次应用写入操作。

诊断

serverStatus命令及其mongosh shell辅助程序db.serverStatus()包含事务部分中可重试写入的统计数据。

针对本地数据库的可重试写入

MongoDB 官方驱动程序默认启用可重试写入，除非显式禁用可重试写入，否则写入本地数据库的应用程序会遇到写入错误。

要禁用可重试写入，可在MongoDB集群的连接字符串中指定retryWrites=false。

错误处理

从MongoDB 6.1开始，如果可重试写入的第一次和第二次尝试都失败而没有执行单个写入，则返回带有NoWritesPerformed标签的错误。NoWritesPerformed标签区分批处理操作（如 insertMany()）的结果。在insertMany操作中，可能会出现以下结果之一：

结果	MongoDB输出
没有插入任何文档	使用NoWritesPerformed标签返回错误
部分工作已完成。 （至少插入一份文档，但不是全部。）	没有NoWritesPerformed标签时返回错误
所有文档均已插入	成功返回

应用程序可以使用NoWritesPerformed标签来明确没有插入任何文档，该错误报告让应用程序可以在处理可重试写入时保持数据库的准确状态。

在MongoDB的早期版本中，当第一次和第二次可重试写入尝试失败时，会返回错误。但没有任何区别来表明没有执行写入。