限制MongoDB Server执行时间

接受的超时值

下表描述了与 timeoutMS 的可接受值相对应的超时行为：

如果指定 timeoutMS 选项，驱动程序会自动将指定的超时应用于每个服务器操作。以下代码示例在客户端端级别指定 200 毫秒的超时，然后调用 MongoCollection.insertOne() 方法：

val settings = MongoClientSettings.builder
  .applyConnectionString(ConnectionString("<connection string>"))
  .timeout(200L, MILLISECONDS)
  .build
val mongoClient = MongoClient(settings)
val database = mongoClient.getDatabase("db")
val collection = database.getCollection("people")
collection.insertOne(Document("name" -> "Francine Loews"))

超时继承

当您指定 timeoutMS 选项时，驱动程序将根据与其他 Scala 驱动程序选项相同的继承行为应用超时。下表描述了如何在每个级别继承超时值：

有关覆盖和特定选项的更多信息，请参阅以下覆盖部分。

事务

当您创建新的ScalaClientSession实例来实现ACID 事务时，请在构建 ClientSessionOptions实例时使用 defaultTimeout() 方法。您可以使用此选项指定以下方法的超时时间：

• commitTransaction()

• abortTransaction()

• close()

以下代码演示了如何在实例化 ClientSession 时设立defaultTimeout：

val opts = ClientSessionOptions.builder
  .defaultTimeout(200L, MILLISECONDS)
  .build
val session = mongoClient.startSession(opts)
// ... perform operations on ClientSession

如果未指定 defaultTimeout，驱动程序将使用在父项 MongoClient 上设立的超时值。

您还可以在构建 TransactionOptions实例时调用 timeout() 方法来设立事务级超时。设置此选项会将超时应用于在ACID 事务范围内执行的所有操作：

val transactionOptions = TransactionOptions.builder
  .timeout(200L, MILLISECONDS)
  .build

要学习；了解有关事务的更多信息，请参阅 执行事务指南。

客户端加密

使用客户端字段级加密 (CSFLE) 时，驱动程序使用 timeoutMS 选项来限制加密和解密操作所允许的时间。您可以在构建 ClientEncryptionSettings实例时调用 timeout() 方法，为 ClientEncryption实例设立超时选项。

如果在构造 ClientEncryption实例时指定了超时，则该超时将控制对该实例执行的所有操作的生命周期。如果在实例化 ClientEncryption 时未提供超时，则该实例将从 ClientEncryption 构造函数中使用的 MongoClient 继承超时设置。

如果您在客户端和直接在 ClientEncryption 中同时设立timeoutMS，则提供给 ClientEncryption 的值优先。

生命周期模式

生命周期模式使用超时设置来限制 Observable 的整个生命周期。在此模式下，您的应用程序必须初始化 Observable，完成对 Observable 方法的所有调用，并在指定的时限内返回所有文档。否则，Observable 生命周期将过期，驱动程序会引发超时错误。

以下示例展示了如何设立Observable 超时，以确保在继承的超时时间内初始化游标并检索所有文档：

val observableWithLifetimeTimeout = collection
  .find(gte("age", 40))
  .timeoutMode(TimeoutMode.CURSOR_LIFETIME)