Web 应用中实时用户状态管理：会话终止与浏览器关闭场景下的数据库操作策略

<?php
// server.php - WebSocket 服务器端逻辑
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;

require dirname(__DIR__) . '/vendor/autoload.php'; // 假设通过Composer安装Ratchet

class ChatServer implements MessageComponentInterface {
    protected $clients; // 存储所有连接的客户端
    // 假设有一个数据库连接 $pdo

    public function __construct() {
        $this->clients = new \SplObjectStorage;
        // 可以在这里初始化数据库连接
        // $this->pdo = new PDO(...);
    }

    public function onOpen(ConnectionInterface $conn) {
        // 当有新的WebSocket连接建立时
        $this->clients->attach($conn);
        echo "新连接! ({$conn->resourceId})\n";

        // 假设通过某种方式（如URL参数或首次消息）获取用户ID
        // $userId = $this->getUserIdFromConnection($conn);
        // if ($userId) {
        //     // 将用户标记为在线，并更新数据库
        //     // $stmt = $this->pdo->prepare("INSERT INTO activeuserlist (user_id, status, last_active_at) VALUES (?, 'online', NOW()) ON DUPLICATE KEY UPDATE status = 'online', last_active_at = NOW()");
        //     // $stmt->execute([$userId]);
        //     echo "用户 {$userId} 上线。\n";
        // }
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        // 处理客户端发送的消息，例如聊天消息
        // ...
    }

    public function onClose(ConnectionInterface $conn) {
        // 当WebSocket连接断开时
        $this->clients->detach($conn);
        echo "连接 {$conn->resourceId} 已断开\n";

        // 假设可以通过连接对象关联到用户ID
        // $userId = $this->getUserIdFromConnection($conn);
        // if ($userId) {
        //     // 将用户标记为离线，并更新数据库
        //     // $stmt = $this->pdo->prepare("UPDATE activeuserlist SET status = 'offline' WHERE user_id = ?");
        //     // $stmt->execute([$userId]);
        //     echo "用户 {$userId} 下线。\n";
        // }
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "发生错误: {$e->getMessage()}\n";
        $conn->close();
    }

    // 辅助方法，用于从连接中获取用户ID，具体实现取决于认证方式
    // private function getUserIdFromConnection(ConnectionInterface $conn) {
    //     // 例如，可以在首次连接时通过消息发送用户ID，或通过HTTP头进行认证
    //     return $conn->resourceId; // 示例，实际应是用户ID
    // }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new ChatServer()
        )
    ),
    8080 // WebSocket 服务器监听端口
);

$server->run();

document.addEventListener('DOMContentLoaded', function() {
    function sendHeartbeat() {
        // 假设用户ID或其他认证信息已通过会话或全局变量可用
        // 或者服务器端直接从会话中获取用户ID
        fetch('/api/heartbeat.php', {
            method: 'POST',
            headers: {
                'Content-Type': 'application/json',
                'X-Requested-With': 'XMLHttpRequest' // 标记为AJAX请求
            },
            // body: JSON.stringify({ userId: currentUserId }) // 如果需要显式传递用户ID
        })
        .then(response => response.json())
        .then(data => {
            if (data.status === 'success') {
                console.log('心跳包发送成功。');
            } else {
                console.error('心跳包发送失败:', data.message);
            }
        })
        .catch(error => console.error('发送心跳包时发生错误:', error));
    }

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

    // 页面加载时立即发送一次
    sendHeartbeat();
});

<?php
session_start(); // 确保会话已启动
header('Content-Type: application/json');

// 检查用户是否已认证
if (!isset($_SESSION['user_id'])) {
    echo json_encode(['status' => 'error', 'message' => '用户未认证。']);
    exit;
}

$userId = $_SESSION['user_id'];
$currentTime = date('Y-m-d H:i:s');

// 假设您有一个数据库连接 $pdo
// $pdo = new PDO('mysql:host=localhost;dbname=your_db', 'user', 'password');

try {
    // 将用户添加到 activeuserlist 表，如果已存在则更新其最后活跃时间
    $stmt = $pdo->prepare("INSERT INTO activeuserlist (user_id, last_active_at) VALUES (?, ?) ON DUPLICATE KEY UPDATE last_active_at = ?");
    $stmt->execute([$userId, $currentTime, $currentTime]);

    echo json_encode(['status' => 'success', 'message' => '最后活跃时间已更新。']);
} catch (PDOException $e) {
    error_log("更新心跳包失败: " . $e->getMessage());
    echo json_encode(['status' => 'error', 'message' => '数据库操作失败。']);
}
?>

<?php
// cron_cleanup_active_users.php
// 此脚本应由 Cron Job 定期执行，例如每隔 5 分钟。

// 假设您有一个数据库连接 $pdo
// $pdo = new PDO('mysql:host=localhost;dbname=your_db', 'user', 'password');

// 定义不活跃时间阈值（例如 5 分钟）
$inactivityThreshold = date('Y-m-d H:i:s', strtotime('-5 minutes'));

try {
    // 从 activeuserlist 表中删除所有超过不活跃阈值的用户
    $stmt = $pdo->prepare("DELETE FROM activeuserlist WHERE last_active_at < ?");
    $stmt->execute([$inactivityThreshold]);

    echo "不活跃用户已清理。\n";
} catch (PDOException $e) {
    error_log("清理不活跃用户失败: " . $e->getMessage());
    echo "清理不活跃用户失败。\n";
}
?>