MongoDB\Driver\Monitoring\CommandSubscriber::commandStarted()
注册一个回调函数，当MongoDB命令开始执行时触发
函数名称：MongoDB\Driver\Monitoring\CommandSubscriber::commandStarted()
函数描述：该函数用于注册一个回调函数，当MongoDB命令开始执行时触发。
适用版本：MongoDB PHP扩展版本 1.2.0 及以上
用法：
首先，创建一个实现了MongoDB\Driver\Monitoring\CommandSubscriber接口的自定义类，例如：
class MyCommandSubscriber implements MongoDB\Driver\Monitoring\CommandSubscriber {
public function commandStarted(MongoDB\Driver\Monitoring\CommandStartedEvent $event) {
// 在命令开始执行时触发的回调函数
// 可以在这里记录命令的相关信息，如命令名称、参数等
$commandName = $event->getCommandName();
$commandParams = $event->getCommand()->toArray();
echo "Command started: {$commandName}\n";
echo "Command parameters: " . json_encode($commandParams) . "\n";
}
}
创建一个MongoDB\Driver\Monitoring\CommandSubscriber实例，并将自定义的MyCommandSubscriber类实例传递给它，例如：
$subscriber = new MongoDB\Driver\Monitoring\CommandSubscriber();
$subscriber->register(new MyCommandSubscriber());
示例：
// 引入MongoDB PHP扩展
require 'vendor/autoload.php';
// 创建MongoDB连接
$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");
// 创建CommandSubscriber实例
$subscriber = new MongoDB\Driver\Monitoring\CommandSubscriber();
// 创建自定义的CommandSubscriber类实例
$mySubscriber = new MyCommandSubscriber();
// 注册自定义的CommandSubscriber
$subscriber->register($mySubscriber);
// 创建一个查询命令
$query = new MongoDB\Driver\Query([], ['limit' => 1]);
// 执行查询命令
$cursor = $manager->executeQuery('test.collection', $query);
// 遍历查询结果
foreach ($cursor as $document) {
// 处理查询结果
echo json_encode($document) . "\n";
}
输出结果：
Command started: find
Command parameters: {"find":"collection","filter":{},"limit":1}
{"_id":{"$oid":"5fd3b4a4e7a2f8269f3f0e28"},"name":"John Doe","age":30}
以上示例中，我们创建了一个自定义的CommandSubscriber类，注册到MongoDB\Driver\Monitoring\CommandSubscriber实例中，并在查询命令执行前输出了命令的名称和参数。当执行查询命令时，会触发commandStarted回调函数，并输出相应的信息。