如何给Firebase实时数据库中的多设备Token发送通知？

一、原代码的核心问题与可行性 #

你的代码逻辑框架是可行的，但存在两个关键问题会导致功能失效或效率低下：

• 数据库路径错误：根据你的数据库结构，users节点下是多个用户子节点（每个子节点包含token字段），但代码中直接读取users/token，这会读取不到任何有效Token数据。
• 单条推送效率极低：循环逐个发送通知，当Token数量较多时，会触发大量HTTP请求，不仅耗时，还可能触发Firebase的限流机制。

二、修正与优化方案 #

1. 修复数据库Token读取逻辑 #

调整路径遍历users下的所有用户节点，提取每个节点的token值：

FirebaseDatabase database = FirebaseDatabase.getInstance();
DatabaseReference usersRef = database.getReference("users");

usersRef.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(@NonNull DataSnapshot snapshot) {
        List<String> tokensList = new ArrayList<>();
        for (DataSnapshot userSnapshot : snapshot.getChildren()) {
            // 从每个用户节点中提取token字段
            String token = userSnapshot.child("token").getValue(String.class);
            // 过滤空Token，避免无效推送
            if (token != null && !token.trim().isEmpty()) {
                tokensList.add(token);
            }
        }
        // 调用批量推送逻辑
        sendBulkNotification(tokensList);
    }

    @Override
    public void onCancelled(@NonNull DatabaseError error) {
        Log.e("TAG", "数据库读取失败: " + error.getMessage());
    }
});

2. 使用FCM批量推送API提升效率 #

Firebase提供MulticastMessage支持一次性推送多个Token，大幅减少请求次数：

private void sendBulkNotification(List<String> tokensList) {
    if (tokensList.isEmpty()) {
        Log.d("TAG", "没有有效Token，无需推送");
        return;
    }

    // 构建批量消息
    MulticastMessage message = MulticastMessage.builder()
            .putData("title", "Notification Title")
            .putData("body", "Notification Body")
            .addAllTokens(tokensList)
            .build();

    // 发送批量消息并处理结果
    FirebaseMessaging.getInstance().sendMulticast(message)
            .addOnCompleteListener(task -> {
                if (task.isSuccessful()) {
                    BatchResponse response = task.getResult();
                    Log.d("TAG", String.format("推送完成：成功%d条，失败%d条", 
                            response.getSuccessCount(), response.getFailureCount()));
                    
                    // 处理推送失败的Token，建议从数据库移除无效Token
                    for (SendResponse sendResponse : response.getResponses()) {
                        if (!sendResponse.isSuccessful() && sendResponse.getException() != null) {
                            Log.e("TAG", "Token推送失败: " + sendResponse.getToken() + 
                                    "，原因: " + sendResponse.getException().getMessage());
                            // 此处可添加逻辑：删除数据库中无效的Token
                        }
                    }
                } else {
                    Log.e("TAG", "批量推送失败", task.getException());
                }
            });
}

3. 额外优化建议 #

• 清理无效Token：推送失败后，及时从数据库中移除过期/无效Token，避免后续重复浪费资源。
• 后台执行：如果在Android客户端执行推送，建议用WorkManager或后台服务处理，避免阻塞主线程；生产环境更推荐在Firebase Cloud Functions中执行推送，利用服务端稳定性，同时减轻客户端压力。
• 依赖与权限检查：确保项目已正确添加FCM依赖，且服务账号拥有cloudmessaging.messages.send权限。

三、总结 #

原代码的核心思路正确，但数据库路径错误会导致无法读取Token，单条推送的方式也不适用于批量场景。修正路径后使用FCM批量API，再配合无效Token清理逻辑，就能实现高效、稳定的多设备推送。

内容的提问来源于stack exchange，提问作者Rahitul Islam