如何在Android应用中结合Firebase配置使用Google Cloud Pub/Sub

核心前提：绝对不能在Android客户端直接集成Pub/Sub SDK、嵌入GCP服务账号密钥——APK反编译即可拿到密钥，会导致Pub/Sub权限完全泄露，产生资损和数据风险。最优方案是通过Firebase Callable云函数做可信代理，客户端只和云函数交互，所有Pub/Sub调用、权限校验都在服务端完成，和现有Firebase生态完全打通，维护成本极低。

• 打开Firebase项目关联的GCP控制台，创建目标Pub/Sub主题，记录主题名称即可，不需要配置对外开放的订阅/发布权限
• 找到Firebase项目默认的云函数服务账号（格式为[你的项目ID]@appspot.gserviceaccount.com），给该账号绑定仅Pub/Sub发布者的最小权限，只授予pubsub.topics.publish单一权限，不要给多余的编辑、管理员权限
• 确认Firebase Android客户端对应的API密钥没有绑定任何Pub/Sub相关权限，从根上禁止客户端直连Pub/Sub的可能

优先选择Firebase Callable类型云函数，该类型函数原生支持自动解析、校验客户端携带的Firebase Auth令牌，不需要手写token传递、验签逻辑，出错概率低。

1. 本地初始化Firebase云函数Node.js环境，安装依赖：
   npm install firebase-functions firebase-admin @google-cloud/pubsub
2. 编写云函数逻辑，核心包含三层校验+发布动作：

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const {PubSub} = require('@google-cloud/pubsub');

admin.initializeApp();
const pubsub = new PubSub();
// 配置目标Pub/Sub主题，后续修改主题无需发版客户端
const TARGET_TOPIC = '你创建的Pub/Sub主题名';

exports.publishToPubSub = functions.https.onCall(async (data, context) => {
  // 1. 强制校验登录状态：未登录请求直接拦截
  if (!context.auth) {
    throw new functions.https.HttpsError('unauthenticated', '请先登录后再操作');
  }
  // 可选：如需细分权限（如仅管理员/付费用户可发），在此处校验自定义Claims即可
  // if (!context.auth.token.pubsubPublishPermission) {
  //   throw new functions.https.HttpsError('permission-denied', '无消息发布权限');
  // }

  // 2. 服务端参数校验：绝对信任客户端传参会产生脏数据和注入风险
  const messageContent = data.message;
  if (!messageContent || typeof messageContent !== 'object') {
    throw new functions.https.HttpsError('invalid-argument', '消息格式非法');
  }
  const messageBuffer = Buffer.from(JSON.stringify(messageContent));
  // 限制单条消息大小在1MB以内，避免超出Pub/Sub配额产生异常
  if (messageBuffer.length > 1024 * 1024) {
    throw new functions.https.HttpsError('invalid-argument', '消息体积超出限制');
  }

  // 3. 调用Pub/Sub发布消息，附带溯源属性
  try {
    const messageId = await pubsub.topic(TARGET_TOPIC).publishMessage({
      data: messageBuffer,
      attributes: {
        publisherUid: context.auth.uid,
        publishTimestamp: Date.now().toString()
      }
    });
    return { code: 0, messageId: messageId };
  } catch (err) {
    functions.logger.error('Pub/Sub发布失败', err);
    throw new functions.https.HttpsError('internal', '服务繁忙，请稍后重试');
  }
});

3. 部署云函数到线上，部署完成后云函数会自动生成可供客户端调用的接入点。

客户端只需要对接Firebase云函数SDK，所有Pub/Sub相关逻辑统一封装，不要散落在业务页面中，降低后续维护成本。

• 在app模块的依赖配置中引入Firebase Functions SDK，版本和现有Firebase BOM版本对齐即可。
• 封装统一的发布管理器，做全局单例：

class PubSubPublisher private constructor() {
    private val functionsClient = Firebase.functions
    private val publishCallable = functionsClient.getHttpsCallable("publishToPubSub")

    // 用协程封装调用逻辑，和Android现有协程生态适配
    suspend fun publish(payload: Map<String, Any?>): Result<String> {
        return try {
            val response = publishCallable.call(mapOf("message" to payload))
            val resultData = response.data as Map<*, *>
            Result.success(resultData["messageId"] as String)
        } catch (e: FirebaseFunctionsException) {
            // 统一处理错误码：未登录、参数错误、服务错误等
            Result.failure(e)
        }
    }

    companion object {
        @Volatile
        private var instance: PubSubPublisher? = null
        fun get(): PubSubPublisher {
            return instance ?: synchronized(this) {
                instance ?: PubSubPublisher().also { instance = it }
            }
        }
    }
}

• 业务层调用示例（以ViewModel中使用为例）：

viewModelScope.launch {
    val testPayload = mapOf(
        "action" to "user_submit",
        "content" to "用户提交的业务内容",
        "clientVersion" to BuildConfig.VERSION_NAME
    )
    PubSubPublisher.get().publish(testPayload)
        .onSuccess { msgId -> Log.i("PubSub", "发布成功，ID：$msgId") }
        .onFailure { err -> Log.e("PubSub", "发布失败", err) }
}

• 双端参数校验：客户端提前做格式校验减少无效请求，服务端必须保留全量校验逻辑，永远不要信任客户端传入的数据
• 给云函数配置限流规则：在Firebase控制台设置云函数的单用户每秒请求上限、总配额阈值，防止恶意刷接口产生高额账单
• 所有Pub/Sub相关配置（主题名、消息格式、权限规则）全部收敛在云函数侧，后续调整逻辑只需要重新部署云函数，不需要强制用户升级APP
• 固定在消息属性中携带发布者UID，后续消息消费、审计、问题排查时可以快速溯源到具体用户
• 如果后续需要支持多主题发布，只需要在云函数中增加主题映射、权限校验逻辑，客户端不需要新增Pub/Sub相关依赖或配置

内容的提问来源于stack exchange，提问作者Sergi Domingo