确保 Express Session 在 MongoDB 中彻底销毁的教程

const session = require('express-session');
const MongoStore = require('connect-mongo');
const express = require('express');
const app = express();

// 假设 SESSIONS_SECRET 和数据库连接 URL 已定义
const SESSIONS_SECRET = process.env.SESSIONS_SECRET || 'your-secret-key';

function getSessionStoreURL() {
    const env = app.get("env");
    if (env === "development") {
        return process.env.DEV_DB || 'mongodb://localhost:27017/dev_sessions';
    }
    return process.env.PROD_DB || 'mongodb://localhost:27017/prod_sessions';
}

// 关键步骤：创建 MongoStore 实例并使其可访问
const sessionStore = MongoStore.create({
    mongoUrl: getSessionStoreURL(),
    ttl: 14 * 24 * 60 * 60, // 会话有效期，单位秒 (例如 14 天)
    autoRemove: 'interval', // 自动清理过期会话
    autoRemoveInterval: 10 // 每 10 分钟检查一次
});

app.use(
    session({
        secret: SESSIONS_SECRET,
        resave: false, // 只有当会话数据发生变化时才保存
        saveUninitialized: false, // 不保存未初始化的会话
        cookie: {
            secure: app.get('env') === 'production', // 生产环境使用 secure cookie
            maxAge: 1000 * 60 * 60 * 24 * 14 // Cookie 有效期，例如 14 天
        },
        store: sessionStore // 使用上面创建的存储实例
    })
);

// 示例：创建新用户会话
function createNewUserSession(req, userId, moreUserData) {
    try {
        const session = req.session;
        session.userId = userId;
        session.moreUserData = moreUserData;
        session.save((err) => {
            if (err) {
                console.error('Error saving session:', err);
            } else {
                console.log('Session saved for user:', userId);
            }
        });
    } catch (e) {
        console.error('Error creating new user session:', e);
    }
}

// ... 其他路由和中间件

/**
 * 销毁用户会话，包括内存中的会话对象和 MongoDB 存储中的记录。
 * @param {object} req - Express 请求对象
 * @param {object} sessionStore - 之前创建的 MongoStore 实例
 */
async function destroyUserSession(req, sessionStore) {
    const sessionId = req.session.id; // 获取当前会话的 ID

    req.session.destroy((err) => {
        if (err) {
            console.error('Error destroying session in memory:', err);
            // 可以在此处进行错误处理或通知用户
        } else {
            console.log('Session destroyed from memory. Session ID:', sessionId);

            // 关键步骤：显式调用存储实例的 destroy 方法来删除 MongoDB 中的记录
            sessionStore.destroy(sessionId, (storeErr) => {
                if (storeErr) {
                    console.error('Error destroying session in store:', storeErr);
                    // 可以在此处进行错误处理
                } else {
                    console.log('Session destroyed in MongoDB store. Session ID:', sessionId);
                }
            });
        }
    });
}

// 示例用法（例如在注销路由中）
app.post('/logout', (req, res) => {
    if (req.session) {
        destroyUserSession(req, sessionStore);
        res.status(200).send('Logged out successfully.');
    } else {
        res.status(400).send('No active session to destroy.');
    }
});