Firebase技术问询：如何向用户所有设备推送FCM通知

嘿，这个场景我太熟悉了——很多社交类应用都会遇到多设备推送的需求，核心就是把用户账号和他所有设备的FCM Token绑定起来管理。下面是一步步的具体实现方案：

你需要在后端（比如Firebase Firestore/Realtime Database，或者自己的服务器数据库）里存储每个用户对应的所有设备Token，这样当需要推送时，就能一次性拿到该用户所有设备的Token，批量发送通知。

1. 用户登录/应用启动时，绑定Token到用户账号 #

每次用户登录成功，或者应用冷启动时，都要获取当前设备的FCM Token，并将其添加到该用户的Token列表中（注意去重，避免同一设备Token重复存储）。

举个Firebase Firestore的实现示例：

// 获取当前登录用户的ID（从Firebase Auth获取）
String userId = FirebaseAuth.getInstance().getCurrentUser().getUid();

// 获取当前设备的FCM Token
FirebaseInstanceId.getInstance().getInstanceId().addOnSuccessListener(instanceIdResult -> {
    String deviceToken = instanceIdResult.getToken();
    
    // 将Token添加到用户的Token列表（用arrayUnion自动去重）
    FirebaseFirestore.getInstance()
        .collection("user_device_tokens")
        .document(userId)
        .update("tokens", FieldValue.arrayUnion(deviceToken))
        .addOnSuccessListener(aVoid -> {
            // Token绑定成功
        })
        .addOnFailureListener(e -> {
            // 处理绑定失败的情况，比如日志记录
        });
});

2. 监听Token刷新，及时更新存储 #

FCM Token会因为设备重装、应用卸载重装、系统更新等情况发生变化，所以必须监听Token的刷新事件，及时更新后端的存储：

public class CustomFirebaseMessagingService extends FirebaseMessagingService {
    @Override
    public void onNewToken(String newToken) {
        super.onNewToken(newToken);
        
        // 只有用户已登录时才更新Token
        FirebaseUser currentUser = FirebaseAuth.getInstance().getCurrentUser();
        if (currentUser != null) {
            String userId = currentUser.getUid();
            FirebaseFirestore.getInstance()
                .collection("user_device_tokens")
                .document(userId)
                .update("tokens", FieldValue.arrayUnion(newToken));
        }
    }
}

3. 发送点赞通知时，批量获取用户所有Token #

当有用户点赞帖子时，先拿到帖子作者的用户ID，然后从存储中取出该用户的所有设备Token，再通过FCM批量推送通知。

用Firebase Admin SDK（Node.js）的示例：

const admin = require('firebase-admin');

async function sendLikeNotification(authorUserId, postId, likerUsername) {
    // 获取作者的所有设备Token
    const tokenDoc = await admin.firestore()
        .collection("user_device_tokens")
        .doc(authorUserId)
        .get();
        
    if (!tokenDoc.exists) return;
    const userTokens = tokenDoc.data().tokens;
    if (!userTokens || userTokens.length === 0) return;
    
    // 构建通知内容
    const notificationMessage = {
        notification: {
            title: `${likerUsername} 点赞了你的帖子`,
            body: "点击查看详情"
        },
        data: {
            targetPostId: postId // 用于客户端跳转对应帖子
        },
        tokens: userTokens // 批量发送到所有设备
    };
    
    // 发送通知并处理无效Token
    const response = await admin.messaging().sendMulticast(notificationMessage);
    const failedTokens = response.responses
        .filter(res => !res.success)
        .map(res => res.token);
    
    if (failedTokens.length > 0) {
        // 从用户的Token列表中移除无效Token
        await admin.firestore()
            .collection("user_device_tokens")
            .doc(authorUserId)
            .update("tokens", admin.firestore.FieldValue.arrayRemove(...failedTokens));
    }
}

额外的细节处理 #

• 用户注销时清理Token：当用户在某设备上注销账号，记得从该用户的Token列表中移除当前设备的Token，避免推送到已注销的设备。
• 定期清理无效Token：除了发送时处理失败的Token，也可以定期跑脚本清理长期未更新的Token，优化存储和推送效率。
• 安全控制：确保只有你的后端服务能访问和修改用户的Token列表，避免恶意篡改。

内容的提问来源于stack exchange，提问作者Parth Bhoiwala