如何将Firebase Firestore数据通过云函数触发发送到React Native应用

以下是两种生产环境常用的实现方向，你可以根据自身业务需求选择：

方案1：客户端直接监听Firestore实时变更（最推荐，无需额外开发Cloud Function逻辑） #

你完全不需要通过Cloud Function中转推送，Firestore本身支持客户端实时监听集合/文档的变更，直接在Expo端监听users集合的新增事件即可，拿到数据后直接更新Redux：

Expo端实现代码 #

import { collection, onSnapshot, query, where } from "firebase/firestore";
import { db } from "./你的firebase配置文件路径";
import { addUser } from "./你的redux user slice路径";

// 在应用初始化/用户登录后注册监听
const unsubscribe = onSnapshot(collection(db, "users"), (snapshot) => {
  snapshot.docChanges().forEach((change) => {
    // 只处理新增的文档
    if (change.type === "added") {
      const userData = change.doc.data();
      // 分发到redux
      store.dispatch(addUser(userData));
    }
  });
});

// 应用退出/用户登出时记得取消监听，避免内存泄漏
// 调用 unsubscribe() 即可

这个方案是最稳定低开销的，Firebase内部已经处理了断线重连、增量同步等逻辑。

方案2：如果必须经过Cloud Function处理后再推送（比如需要做数据清洗、权限校验等逻辑） #

使用Firebase Cloud Messaging(FCM)的静默推送能力，用户不会感知到通知，应用后台即可接收数据更新Redux，实现步骤：

1. Expo端用户登录后，获取FCM设备令牌，将令牌存储到对应用户的文档中
2. Cloud Function触发时，读取目标用户的FCM令牌，推送结构化数据
3. Expo端监听FCM消息接收事件，拿到数据后更新Redux

Cloud Function端代码示例 #

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

exports.createUser = functions.firestore
  .document('users/{userId}')
  .onCreate(async (snap, context) => {
    const newUser = snap.data();
    // 获取需要推送的目标设备的FCM令牌，这里示例推给所有管理员，你可以根据业务逻辑取对应令牌
    const adminSnapshot = await admin.firestore().collection('admins').get();
    const fcmTokens = adminSnapshot.docs.map(doc => doc.data().fcmToken);
    
    const message = {
      data: {
        type: 'NEW_USER',
        userData: JSON.stringify(newUser)
      },
      tokens: fcmTokens
    };
    
    // 发送静默推送
    await admin.messaging().sendEachForMulticast(message);
  });

Expo端接收代码示例 #

import messaging from '@react-native-firebase/messaging';
import { addUser } from './你的redux user slice路径';

// 应用在前台时接收消息
messaging().onMessage(async remoteMessage => {
  if (remoteMessage.data.type === 'NEW_USER') {
    const userData = JSON.parse(remoteMessage.data.userData);
    store.dispatch(addUser(userData));
  }
});

// 应用在后台时接收消息
messaging().setBackgroundMessageHandler(async remoteMessage => {
  if (remoteMessage.data.type === 'NEW_USER') {
    const userData = JSON.parse(remoteMessage.data.userData);
    store.dispatch(addUser(userData));
  }
});

注意事项 #

• 方案1需要配置正确的Firestore安全规则，避免越权访问数据
• 方案2需要提前在Expo项目中配置好FCM相关权限和依赖
• 不要尝试在Cloud Function中直接发HTTP请求到客户端，客户端没有公网固定IP，也没有持续监听HTTP请求的服务，无法稳定接收这类请求

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