MongoDB\Driver\Monitoring\SDAMSubscriber::serverHeartbeatSucceeded()函数—用法及示例

函数：MongoDB\Driver\Monitoring\SDAMSubscriber::serverHeartbeatSucceeded()

适用版本：PHP 7.2.0 及更高版本

用法： MongoDB\Driver\Monitoring\SDAMSubscriber::serverHeartbeatSucceeded()函数用于处理MongoDB服务器成功进行心跳检测的事件。当MongoDB驱动程序成功发送心跳包并接收到响应时，会触发此事件。

示例： 以下示例演示了如何使用serverHeartbeatSucceeded()函数来处理心跳检测成功的事件。

<?php

// 创建一个自定义的SDAMSubscriber类
class MySDAMSubscriber implements MongoDB\Driver\Monitoring\SDAMSubscriber
{
    public function serverHeartbeatSucceeded(MongoDB\Driver\Monitoring\ServerHeartbeatSucceededEvent $event)
    {
        // 获取心跳检测成功的服务器信息
        $server = $event->getServer();
        $serverInfo = $event->getReply();

        // 输出服务器信息
        echo "服务器地址: " . $server->getHost() . ":" . $server->getPort() . "\n";
        echo "服务器版本: " . $serverInfo->version . "\n";
        echo "心跳延迟: " . $serverInfo->roundTripTime . "ms\n";
    }

    // 实现其他接口方法...
}

// 创建一个MongoDB连接
$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");

// 创建一个SDAMSubscriber实例
$subscriber = new MySDAMSubscriber();

// 注册SDAMSubscriber实例到连接管理器
$manager->subscribe($subscriber);

// 执行一次心跳检测
$manager->executeCommand("admin", new MongoDB\Driver\Command(["ping" => 1]));

?>

在上面的示例中，我们首先创建了一个自定义的SDAMSubscriber类，实现了serverHeartbeatSucceeded()方法来处理心跳检测成功的事件。然后，我们创建了一个MongoDB连接管理器$manager，并将自定义的SDAMSubscriber实例$subscriber注册到连接管理器中。最后，我们执行了一次心跳检测，当心跳检测成功时，会调用serverHeartbeatSucceeded()方法，并输出服务器信息。

请注意，这只是一个简单的示例，您可以根据实际需求进行适当的修改和扩展。