如何使用PHP和MQTT为网站添加实时用户活动跟踪功能

$client = new MosquittoClient();
$client->connect('localhost'); // 连接到MQTT消息服务器
$client->loopStart(); // 启动一个循环以侦听来自服务器的消息

$client->subscribe('user_activity'); // 订阅一个名为'user_activity'的主题

while (true) {
    $client->loop(); // 处理接收到的消息
}

$client->disconnect(); // 断开与MQTT消息服务器的连接
$client->loopStop(); // 停止循环

// 创建MQTT客户端实例
$client = new MosquittoClient();
$client->connect('localhost');

// 获取当前用户的标识符（例如，用户ID或会话ID）
$userId = $_SESSION['user_id'];

// 向MQTT消息服务器发布用户活动消息
$client->publish('user_activity', '用户 ' . $userId . ' 访问了页面 ' . $_SERVER['REQUEST_URI']);

// 断开与MQTT消息服务器的连接
$client->disconnect();

$client = new MosquittoClient();
$client->connect('localhost');
$client->loopStart();

$client->subscribe('user_activity');

while (true) {
    $client->loop();

    // 处理收到的用户活动消息
    $messages = $client->messages;
    foreach ($messages as $message) {
        echo $message->topic . '：' . $message->payload . PHP_EOL;
    }
}

$client->disconnect();
$client->loopStop();