Firestore实时数据获取报ERR_HTTP_HEADERS_SENT错误的解决问询

• onSnapshot是Firestore的实时监听API，会在初始获取数据和后续数据发生变更时多次触发回调函数。
• HTTP协议要求一个请求只能返回一次响应，你的接口在第一次触发回调时已经通过res.send()完成了响应。当Firestore文档更新时，onSnapshot再次触发回调，你尝试再次发送响应，此时HTTP响应头已经发送给客户端，Node.js就会抛出ERR_HTTP_HEADERS_SENT错误。

根据你的需求选择对应方案：

方案一：仅单次获取数据（无需实时更新） #

将实时监听的onSnapshot替换为单次获取数据的get()方法，配合async/await处理异步逻辑：

async getData(req, res) {
  try {
    const dataRef = db.collection(`${req.body.banco}`);
    const docSnapshot = await dataRef.get();
    const result = [];
    docSnapshot.forEach(doc => {
      result.push(doc.data());
    });
    console.log(result);
    return res.status(200).send(result);
  } catch (error) {
    console.log(`Erro encontrado: ${error}`);
    return res.status(500).send({ error: 'Falha ao buscar dados' });
  }
}

方案二：实现实时数据推送 #

HTTP接口无法支持实时推送（一次请求一次响应），需要使用WebSocket或**Server-Sent Events (SSE)**来建立长连接，以下是SSE的实现示例：

后端代码（Express） #

getData(req, res) {
  // 配置SSE响应头
  res.setHeader('Content-Type', 'text/event-stream');
  res.setHeader('Cache-Control', 'no-cache');
  res.setHeader('Connection', 'keep-alive');

  const dataRef = db.collection(`${req.body.banco}`);
  
  // 启动Firestore实时监听
  const unsubscribe = dataRef.onSnapshot(docSnapshot => {
    const result = [];
    docSnapshot.forEach(doc => {
      result.push(doc.data());
    });
    // 以SSE格式发送更新数据
    res.write(`data: ${JSON.stringify(result)}\n\n`);
  }, (error) => {
    console.log(`Erro encontrado: ${error}`);
    res.write(`event: error\ndata: ${JSON.stringify({ error: 'Falha ao escutar atualizações' })}\n\n`);
  });

  // 客户端断开连接时，取消Firestore监听并结束响应
  req.on('close', () => {
    unsubscribe();
    res.end();
  });
}

客户端代码（浏览器） #

// 建立SSE连接
const eventSource = new EventSource('/你的-getdata接口路径');

// 接收实时更新数据
eventSource.onmessage = function(event) {
  const updatedData = JSON.parse(event.data);
  console.log('Dados atualizados:', updatedData);
  // 在这里更新页面的展示数据
};

// 处理错误
eventSource.onerror = function(error) {
  console.error('Erro na conexão SSE:', error);
  eventSource.close();
};

注意：如果使用Firebase Cloud Functions作为后端，HTTP函数有超时限制（最长9分钟），不适合长连接场景，此时建议让客户端直接调用Firestore的onSnapshot进行实时监听，后端仅负责权限校验逻辑。

内容的提问来源于stack exchange，提问作者Paulo Victor Oliveira