PHP动态网页用户在线统计_PHP动态网页实时在线用户统计功能指南

online_users

CREATE TABLE `online_users` (
    `id` INT AUTO_INCREMENT PRIMARY KEY,
    `user_id` INT NOT NULL UNIQUE COMMENT '用户ID，如果未登录则为0或NULL',
    `session_id` VARCHAR(255) NOT NULL UNIQUE COMMENT 'PHP会话ID',
    `ip_address` VARCHAR(45) NULL COMMENT '用户IP地址',
    `last_activity` DATETIME NOT NULL COMMENT '最后活跃时间',
    INDEX `idx_last_activity` (`last_activity`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

<?php
session_start(); // 启动会话

// 获取当前用户ID (假设已登录)
$userId = $_SESSION['user_id'] ?? 0; // 如果未登录，则为0
$sessionId = session_id();
$ipAddress = $_SERVER['REMOTE_ADDR'];

// 连接数据库 (示例，请替换为你的实际数据库连接)
$pdo = new PDO('mysql:host=localhost;dbname=your_database', 'username', 'password');
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

// 更新或插入用户活跃记录
// 这里使用 ON DUPLICATE KEY UPDATE 避免重复插入，并更新活跃时间
$stmt = $pdo->prepare("
    INSERT INTO online_users (user_id, session_id, ip_address, last_activity)
    VALUES (?, ?, ?, NOW())
    ON DUPLICATE KEY UPDATE last_activity = NOW(), ip_address = ?
");
$stmt->execute([$userId, $sessionId, $ipAddress, $ipAddress]);

// 清理过期用户 (可选，也可以通过定时任务进行)
// 比如清理10分钟内没有活动的记录
$pdo->exec("DELETE FROM online_users WHERE last_activity < DATE_SUB(NOW(), INTERVAL 10 MINUTE)");

// 统计当前在线用户数 (活跃时间在过去5分钟内)
$stmt = $pdo->prepare("SELECT COUNT(DISTINCT user_id) AS online_count FROM online_users WHERE last_activity > DATE_SUB(NOW(), INTERVAL 5 MINUTE)");
$stmt->execute();
$onlineUsersCount = $stmt->fetch(PDO::FETCH_ASSOC)['online_count'];

// 对于未登录用户，如果需要单独统计，可以这样：
// $stmt = $pdo->prepare("SELECT COUNT(DISTINCT session_id) AS guest_online_count FROM online_users WHERE user_id = 0 AND last_activity > DATE_SUB(NOW(), INTERVAL 5 MINUTE)");
// $stmt->execute();
// $guestOnlineCount = $stmt->fetch(PDO::FETCH_ASSOC)['guest_online_count'];

// 现在 $onlineUsersCount 包含了过去5分钟内活跃的登录用户数
// 你可以在页面上显示这个数字
// echo "当前在线用户: " . $onlineUsersCount;
?>

<!-- 在你的HTML页面底部或某个公共JS文件中 -->
<script>
document.addEventListener('DOMContentLoaded', function() {
    function sendHeartbeat() {
        fetch('/api/heartbeat.php', { method: 'POST' })
            .then(response => response.json())
            .then(data => {
                // console.log('Heartbeat sent:', data);
                // 可以在这里更新页面上的在线人数显示
                if (data.onlineCount !== undefined) {
                    document.getElementById('online-users-display').innerText = data.onlineCount;
                }
            })
            .catch(error => console.error('Error sending heartbeat:', error));
    }

    // 每30秒发送一次心跳
    setInterval(sendHeartbeat, 30 * 1000);

    // 页面加载时立即发送一次
    sendHeartbeat();
});
</script>
<p>当前在线用户: <span id="online-users-display">...</span></p>

/api/heartbeat.php

<?php
session_start();
header('Content-Type: application/json');

$userId = $_SESSION['user_id'] ?? 0;
$sessionId = session_id();
$ipAddress = $_SERVER['REMOTE_ADDR'];

$pdo = new PDO('mysql:host=localhost;dbname=your_database', 'username', 'password');
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

// 更新活跃时间
$stmt = $pdo->prepare("
    INSERT INTO online_users (user_id, session_id, ip_address, last_activity)
    VALUES (?, ?, ?, NOW())
    ON DUPLICATE KEY UPDATE last_activity = NOW(), ip_address = ?
");
$stmt->execute([$userId, $sessionId, $ipAddress, $ipAddress]);

// 统计在线人数
$stmt = $pdo->prepare("SELECT COUNT(DISTINCT user_id) AS online_count FROM online_users WHERE last_activity > DATE_SUB(NOW(), INTERVAL 5 MINUTE)");
$stmt->execute();
$onlineUsersCount = $stmt->fetch(PDO::FETCH_ASSOC)['online_count'];

echo json_encode(['status' => 'success', 'onlineCount' => $onlineUsersCount]);
?>

<?php
// ... (session_start() 和获取 userId, sessionId, ipAddress 保持不变)

// 连接Redis (示例)
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 设置用户活跃状态，并设置5分钟过期
// 键名可以设计为 'online_user:userId' 或 'online_session:sessionId'
// 这里我们用session_id来确保即使未登录用户也能被统计
$redis->setex("online_session:{$sessionId}", 300, $userId); // 300秒 = 5分钟

// 如果是登录用户，也可以同时维护一个用户ID到活跃时间的映射
if ($userId > 0) {
    $redis->setex("online_user_active:{$userId}", 300, time());
}

// 统计在线用户数
// 对于登录用户，我们可以通过遍历所有 'online_user_active:*' 键来统计
// 但更高效的方式是使用 Redis 的 SET 或 ZSET
// 我们可以用一个 ZSET 来存储所有在线用户的ID和活跃时间戳
$redis->zadd('online_users_zset', time(), $userId . '_' . $sessionId); // 存储用户ID和会话ID，防止不同会话同一用户重复计数

// 清理过期用户 (ZSET方式)
// 移除所有活跃时间戳在当前时间 - 5分钟之前的数据
$redis->zremrangebyscore('online_users_zset', 0, time() - 300);

// 获取在线用户数 (去重)
// 这里的统计需要注意，如果一个用户有多个会话（比如在不同浏览器），ZSET会记录多次
// 如果要统计独立用户，需要进一步处理。一个简单的做法是，如果user_id > 0，则统计user_id
// 否则统计session_id。
// 比较精确的统计方式是先获取所有member，然后解析user_id并去重
$activeMembers = $redis->zrangebyscore('online_users_zset', time() - 300, '+inf');
$uniqueUsers = [];
$uniqueSessions = [];
foreach ($activeMembers as $member) {
    list($uid, $sid) = explode('_', $member);
    if ($uid > 0) {
        $uniqueUsers[$uid] = true;
    } else {
        $uniqueSessions[$sid] = true; // 统计匿名会话
    }
}
$onlineUsersCount = count($uniqueUsers) + count($uniqueSessions); // 这是一个简化的统计方式

// echo "当前在线用户 (Redis): " . $onlineUsersCount;
?>

ZSET

zremrangebyscore

zadd