监控

命令事件

命令事件是与 MongoDB 数据库命令相关的事件。生成命令事件的数据库命令的一些示例包括 find、insert、delete 和 count。

如需监控命令事件，请编写实现 CommandListener 接口的类，并用 MongoClient 实例注册该类的实例。

有关MongoDB database命令的更多信息，请参阅有关数据库命令的MongoDB手册条目。

class CommandCounter : CommandListener {
    private val commands = mutableMapOf<String, Int>()
    @Synchronized
    override fun commandSucceeded(event: CommandSucceededEvent) {
        val commandName = event.commandName
        val count = commands[commandName] ?: 0
        commands[commandName] = count + 1
        println(commands.toString())
    }
    override fun commandFailed(event: CommandFailedEvent) {
        println("Failed execution of command '${event.commandName}' with id ${event.requestId}")
    }
}

val commandCounter = CommandCounter()
val settings = MongoClientSettings.builder()
    .applyConnectionString(URI)
    .addCommandListener(commandCounter)
    .build()
val mongoClient = MongoClient.create(settings)
val database = mongoClient.getDatabase(DATABASE)
val collection = database.getCollection<Document>(COLLECTION)
// Run some commands to test the counter
collection.find().firstOrNull()
collection.find().firstOrNull()

{find=1}
{find=2}
{find=2, endSessions=1}

服务器发现和监控事件

服务器发现与监控 (SDAM) 事件是指与驱动程序连接到的 MongoDB 实例或集群的状态变化相关的事件。

驱动程序定义了 9 个 SDAM 事件。驱动程序将这 9 个事件分给 3 个独立的监听器接口，每个接口监听 9 个事件中的 3 个。以下是 3 个接口及其监听的事件：

• ClusterListener：拓扑结构相关事件

• ServerListener：与 mongod 或 mongos 进程相关的事件

• ServerMonitorListener：与心跳有关的事件

如需监控 SDAM 事件类型，请编写实现上述 3 个接口之一的类，然后将该类的实例注册到您的 MongoClient 实例中。

有关每个 SDAM 事件的详细说明，请参阅 MongoDB SDAM 监控事件规范。

class IsWriteable : ClusterListener {
    private var isWritable = false
    @Synchronized
    override fun clusterDescriptionChanged(event: ClusterDescriptionChangedEvent) {
        if (!isWritable) {
            if (event.newDescription.hasWritableServer()) {
                isWritable = true
                println("Able to write to cluster")
            }
        } else {
            if (!event.newDescription.hasWritableServer()) {
                isWritable = false
                println("Unable to write to cluster")
            }
        }
    }
}

val clusterListener = IsWriteable()
val settings = MongoClientSettings.builder()
    .applyConnectionString(URI)
    .applyToClusterSettings { builder ->
        builder.addClusterListener(clusterListener)
    }
    .build()
val mongoClient = MongoClient.create(settings)
val database = mongoClient.getDatabase(DATABASE)
val collection = database.getCollection<Document>(COLLECTION)
// Run a command to trigger a ClusterDescriptionChangedEvent event
collection.find().firstOrNull()

Able to write to server

连接池事件

连接池事件是与驱动程序持有的连接池相关的事件。连接池是驱动程序与 MongoDB 实例之间维护的一组开放的 TCP 连接。连接池有助于减少应用程序需要与 MongoDB 实例执行的网络握手次数，还能帮助应用程序更快地运行。

如需监控连接池事件，请编写实现 ConnectionPoolListener 接口的类，然后用 MongoClient 实例注册该类的实例。

class ConnectionPoolLibrarian : ConnectionPoolListener {
    override fun connectionCheckedOut(event: ConnectionCheckedOutEvent) {
        println("Let me get you the connection with id ${event.connectionId.localValue}...")
    }
    override fun connectionCheckOutFailed(event: ConnectionCheckOutFailedEvent) {
        println("Something went wrong! Failed to checkout connection.")
    }
}

val cpListener = ConnectionPoolLibrarian()
val settings = MongoClientSettings.builder()
    .applyConnectionString(URI)
    .applyToConnectionPoolSettings { builder ->
        builder.addConnectionPoolListener(cpListener)
    }
    .build()
val mongoClient = MongoClient.create(settings)
val database = mongoClient.getDatabase(DATABASE)
val collection = database.getCollection<Document>(COLLECTION)
// Run a command to trigger connection pool events
collection.find().firstOrNull()

Let me get you the connection with id 21...

JMX 支持

要启用 JMX 连接池监控，请将 JMXConnectionPoolListener 类的实例添加到 MongoClient 对象。

JMXConnectionPoolListener 类执行以下操作：

1. 为驱动程序维护连接池的每个 mongod 或 mongos 进程创建 MXBean 实例。

2. 将这些 MXBean 实例注册到平台 MBean 服务器。

在平台 MBean 服务器上注册的 MXBean 具有以下属性：

此驱动程序创建的所有 MXBean 实例均位于 "org.mongodb.driver" 域中。

如需了解有关本小节讨论主题的更多信息，请参阅 Oracle 提供的以下资源：

• Platform MBean Server 参考文档

• MXBean 文档

• MBean 文档

JMX 和 JConsole 示例

本例展示了如何使用 JMX 和 JConsole 监控驱动程序的连接池。JConsole 是 Java 平台自带的与 JMX 兼容的图形界面监控工具。

以下代码段将 JMXConnectionPoolListener 添加到 MongoClient 实例。然后代码暂停执行，以便您可以导航到 JConsole 并检查连接池。

val connectionPoolListener = JMXConnectionPoolListener()
val settings = MongoClientSettings.builder()
    .applyConnectionString(uri)
    .applyToConnectionPoolSettings {
        it.addConnectionPoolListener(connectionPoolListener)
    }
    .build()
val mongoClient: MongoClient = MongoClient.create(settings)
try {
    println("Navigate to JConsole to see your connection pools...")
    Thread.sleep(Long.MAX_VALUE)
} catch (e: Exception) {
    e.printStackTrace()
}

Navigate to JConsole to see your connection pools...

启动服务器后，使用以下命令在终端中打开 JConsole：

jconsole

打开 JConsole 后，在图形界面中执行以下操作：

1. 选择运行上述示例代码的进程。

2. 在警告对话框中按 Insecure Connection（不安全连接）。

3. 单击 MBeans 标签页。

4. 检查 "org.mongodb.driver" 域下的连接池事件。

如果您不再希望在 JConsole 中检查连接池，请执行以下操作：

• 关闭 JConsole 窗口，退出 JConsole

• 停止运行上述代码片段的程序

有关 JMX 和 JConsole 的详细信息，请参阅 Oracle 提供的以下资源：

• JConsole 文档。

• 监控和管理指南

有关JMXConnectionPoolListener 类的更多信息，请参阅 JMXConnectionPoolListener 的 API 文档。