如何创建Firebase Functions实现用户离线15分钟后清理数据？

我刚好处理过类似的场景，结合Firebase的在线状态系统和Google Cloud Tasks，完全可以实现你要的需求——不用持续运行的cronjob，只在用户真正离线超15分钟时触发清理，还能处理用户中途重新上线的情况。下面是具体的实现思路和代码示例：

核心思路 #

1. 维护用户的lastActive时间戳：每次用户有活动（登录、操作）就更新这个字段，确保能准确判断用户的活跃状态。
2. 用Google Cloud Tasks实现延迟任务：当用户标记为离线时，创建一个延迟15分钟的任务；如果用户在15分钟内重新上线，就取消这个任务。
3. 任务触发时做二次校验：避免因为网络延迟等情况导致误清理，检查用户的lastActive是否确实超过15分钟，再执行清理。

具体步骤 #

1. 配置用户在线状态文档 #

首先，确保你的users/{userId}文档包含以下字段：

• isOnline: boolean（标记用户是否在线）
• lastActive: Timestamp（记录最后活跃时间）
• cleanupTaskName: string（存储该用户对应的清理任务名称，方便后续取消）

2. 更新用户活跃状态的逻辑 #

无论是用户主动登录，还是进行操作，都要更新lastActive和isOnline，同时取消可能存在的未执行清理任务：

// 客户端或云函数中更新用户活跃状态
async function updateUserActive(userId) {
  const userRef = firestore.collection('users').doc(userId);
  
  // 取消之前的清理任务
  const userDoc = await userRef.get();
  if (userDoc.exists && userDoc.data().cleanupTaskName) {
    await tasksClient.deleteTask({ name: userDoc.data().cleanupTaskName });
  }
  
  // 更新在线状态和最后活跃时间
  await userRef.set({
    isOnline: true,
    lastActive: firestore.FieldValue.serverTimestamp(),
    cleanupTaskName: null
  }, { merge: true });
}

3. 处理用户离线事件（onDisconnect） #

当用户断开连接时，标记为离线，并创建延迟15分钟的清理任务：

// 客户端设置onDisconnect逻辑
const userRef = firestore.collection('users').doc(currentUserId);
userRef.onDisconnect().update({
  isOnline: false
}).then(async () => {
  // 通过云函数创建延迟清理任务，避免客户端权限问题
  const createTaskResponse = await fetch('/create-cleanup-task', {
    method: 'POST',
    body: JSON.stringify({ userId: currentUserId })
  });
  const { taskName } = await createTaskResponse.json();
  // 把任务名称存在用户文档中，方便后续取消
  await userRef.update({ cleanupTaskName: taskName });
});

4. 创建Cloud Functions处理延迟任务 #

首先需要启用Google Cloud Tasks API，并在项目中提前创建对应的任务队列，然后编写以下两个云函数：

4.1 创建延迟任务的云函数

const { CloudTasksClient } = require('@google-cloud/tasks');
const tasksClient = new CloudTasksClient();
const project = 'your-project-id';
const location = 'us-central1'; // 选择你的函数所在区域
const queue = 'user-cleanup-queue'; // 提前在Cloud Tasks中创建的队列

exports.createCleanupTask = functions.https.onCall(async (data, context) => {
  if (!context.auth) {
    throw new functions.https.HttpsError('unauthenticated', '用户未授权');
  }
  
  const userId = data.userId;
  const userRef = admin.firestore().collection('users').doc(userId);
  const userDoc = await userRef.get();
  if (!userDoc.exists) {
    throw new functions.https.HttpsError('not-found', '用户不存在');
  }

  // 构建任务请求
  const taskName = tasksClient.taskPath(project, location, queue, `cleanup-user-${userId}`);
  const payload = JSON.stringify({ userId });
  
  const task = {
    name: taskName,
    httpRequest: {
      httpMethod: 'POST',
      url: `https://${location}-${project}.cloudfunctions.net/cleanupUser`,
      body: Buffer.from(payload).toString('base64'),
      headers: {
        'Content-Type': 'application/json',
      },
    },
    scheduleTime: {
      seconds: Date.now() / 1000 + 15 * 60, // 延迟15分钟
    },
  };

  // 创建任务
  await tasksClient.createTask({ parent: tasksClient.queuePath(project, location, queue), task });
  
  // 更新用户文档中的任务名称
  await userRef.update({ cleanupTaskName: taskName });
  
  return { taskName };
});

4.2 执行清理的云函数

exports.cleanupUser = functions.https.onRequest(async (req, res) => {
  try {
    const { userId } = req.body;
    const userRef = admin.firestore().collection('users').doc(userId);
    const userDoc = await userRef.get();
    
    if (!userDoc.exists) {
      return res.status(404).send('用户不存在');
    }
    
    const userData = userDoc.data();
    const now = Date.now();
    const lastActiveTime = userData.lastActive.toDate().getTime();
    
    // 二次校验：确认用户离线且lastActive超过15分钟
    if (!userData.isOnline && (now - lastActiveTime) >= 15 * 60 * 1000) {
      // 执行你的清理逻辑，比如删除特定用户数据
      await admin.firestore().collection('user-specific-data').doc(userId).delete();
      // 清除用户文档中的任务名称记录
      await userRef.update({ cleanupTaskName: null });
      res.status(200).send('数据清理完成');
    } else {
      // 用户已经重新上线，无需清理
      res.status(200).send('用户已活跃，跳过清理');
    }
  } catch (error) {
    console.error('清理任务执行失败:', error);
    res.status(500).send('内部错误');
  }
});

关键细节说明 #

• 取消任务的必要性：当用户在15分钟内重新上线，必须取消之前创建的延迟任务，避免误清理。我们通过存储cleanupTaskName在用户文档中，方便快速定位并取消任务。
• 二次校验：即使任务触发了，也要再次检查用户的isOnline和lastActive，因为可能存在网络延迟导致onDisconnect触发不及时，或者用户已经重新上线但任务还没取消的情况。
• 权限控制：创建任务的函数要确保只有授权用户能调用，避免恶意创建任务。

这样实现的好处是完全不需要持续运行的cronjob，只有当用户离线时才会创建延迟任务，用户上线就取消，资源利用率非常高，完全符合你的需求。

内容的提问来源于stack exchange，提问作者Jordan Benge