如何用PHP在Firebase运行时动态创建推送通知主题？

嘿，看起来你已经把固定主题的FCM推送跑通了，很棒！关于动态创建主题的需求，其实FCM的主题机制本身就是「按需创建」的——不需要提前在控制台手动创建，只要有设备通过API订阅到某个主题，FCM就会自动帮你生成这个主题。结合你说的「管理员在数据库创建特定记录时自动触发」的场景，我们可以把这个流程和Firebase的数据库触发器结合起来，下面给你具体的实现方案：

FCM的主题不存在「手动创建」的步骤，当你第一次调用API将设备订阅到某个主题时，该主题会自动在FCM系统中生成。所以你的核心需求其实可以转化为：当数据库新增特定记录时，触发设备订阅到对应主题（或者确保有设备订阅，主题自然就创建了）。

如果你想在自己的PHP服务中处理订阅逻辑，可以调用FCM的批量订阅API。下面是一个和你现有推送函数风格一致的PHP函数：

public static function subscribeDevicesToTopic($deviceTokens, $topicName) {
    // 替换为你的API密钥
    define('API_ACCESS_KEY', 'API_KEY');
    
    // 请求体：指定主题和要订阅的设备token数组
    $fields = array(
        'to' => "/topics/{$topicName}",
        'registration_ids' => $deviceTokens
    );
    
    $headers = array(
        'Authorization: key=' . API_ACCESS_KEY,
        'Content-Type: application/json'
    );
    
    $ch = curl_init();
    // 注意订阅API的URL是iid.googleapis.com/iid/v1:batchAdd
    curl_setopt($ch, CURLOPT_URL, 'https://iid.googleapis.com/iid/v1:batchAdd');
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($fields));
    
    $result = curl_exec($ch);
    curl_close($ch);
    
    return json_decode($result, true);
}

调用这个函数时，传入要订阅的设备token数组和主题名称，如果主题不存在，FCM会自动创建它。之后你就可以用你已有的SendFireBaseBroadCast函数向该主题推送通知了。

如果想实现「管理员在数据库创建记录时自动触发主题创建」，最优雅的方式是用Firebase Cloud Functions。比如当Firestore或实时数据库中新增一条主题配置记录时，自动触发订阅逻辑：

示例：Cloud Functions（Node.js）监听Firestore新增记录 #

假设你在Firestore中有一个admin_topics集合，管理员新增的文档包含topicName（主题名称）和deviceTokens（要订阅的设备token数组）两个字段：

const functions = require("firebase-functions");
const admin = require("firebase-admin");
admin.initializeApp();

// 当admin_topics集合新增文档时触发
exports.autoCreateTopicOnRecord = functions.firestore
  .document("admin_topics/{topicDocId}")
  .onCreate(async (snapshot, context) => {
    const topicData = snapshot.data();
    const topicName = topicData.topicName;
    const deviceTokens = topicData.deviceTokens;

    if (!topicName || !deviceTokens || !Array.isArray(deviceTokens)) {
      functions.logger.warn("Invalid topic data: missing name or device tokens");
      return null;
    }

    try {
      // 调用FCM订阅API，自动创建主题（如果不存在）
      const subscriptionResponse = await admin.messaging().subscribeToTopic(
        deviceTokens,
        topicName
      );

      functions.logger.info(
        `Successfully subscribed ${subscriptionResponse.successCount} devices to topic ${topicName}`,
        { response: subscriptionResponse }
      );
      return subscriptionResponse;
    } catch (error) {
      functions.logger.error("Failed to subscribe devices to topic:", error);
      throw error;
    }
  });

工作流程： #

1. 管理员在Firestore的admin_topics集合中添加一条新文档，填写主题名和要订阅的设备token；
2. Cloud Functions自动触发，调用FCM的订阅接口；
3. 如果该主题不存在，FCM自动创建它，同时将设备订阅到该主题；
4. 之后你就可以用你的PHP推送函数向这个主题发送通知了。

• 如果只是想「创建主题」而不立即订阅设备，其实FCM没有专门的接口——主题只有在有订阅者时才会存在。你可以用一个测试设备token订阅一下，之后再取消订阅，主题会暂时保留（FCM会定期清理无订阅者的主题）。
• 如果你需要删除主题，可以调用FCM的批量取消订阅API，当最后一个设备取消订阅后，FCM会自动删除该主题。

内容的提问来源于stack exchange，提问作者Danyal Sandeelo