Node.js Express使用Twitter包流式响应时ERR_HTTP_HEADERS_SENT报错解决

这个报错的核心原因很好理解——你每次收到Twitter流的新数据时，都在尝试发送一个完整的HTTP响应（res.json()），但HTTP协议里一个请求只能对应一个完整响应，第一次发送后响应头已经被发送了，第二次再调用就会触发ERR_HTTP_HEADERS_SENT错误。

要实现真正的流式响应，你需要用分块传输编码或者更适合实时推送的Server-Sent Events (SSE)，下面是两种可行的实现方案：

方案1：使用Server-Sent Events（推荐前端场景） #

SSE是浏览器原生支持的实时推送协议，格式简单，无需额外前端库就能处理。修改后的代码如下：

var client = new Twitter({ 
  consumer_key: '', 
  consumer_secret: '', 
  access_token_key: '', 
  access_token_secret: '' 
});

app.get('/', function(req, res) {
  // 设置SSE专属响应头
  res.setHeader('Content-Type', 'text/event-stream');
  res.setHeader('Cache-Control', 'no-cache'); // 禁止缓存
  res.setHeader('Connection', 'keep-alive'); // 保持连接
  res.flushHeaders(); // 立即发送响应头，避免客户端等待

  // 启动Twitter流
  const stream = client.stream('statuses/filter', { track: 'crypto' });

  // 收到新推文时发送SSE格式的数据
  stream.on('data', function(event) {
    const tweetText = event?.text || 'nothing';
    // SSE格式要求：data: [内容]\n\n，内容可以是JSON字符串
    res.write(`data: ${JSON.stringify({ tweet: tweetText })}\n\n`);
  });

  // 处理流错误
  stream.on('error', function(error) {
    console.error('Twitter stream error:', error);
    res.write(`data: ${JSON.stringify({ error: 'Stream error occurred' })}\n\n`);
    res.end(); // 错误发生后结束响应
  });

  // 客户端断开连接时，关闭Twitter流并清理资源
  req.on('close', function() {
    console.log('Client disconnected, closing Twitter stream');
    stream.destroy();
    res.end();
  });
});

关键说明： #

• res.write() 用于发送分块数据，不会结束响应，这是和res.json()的核心区别。
• SSE的格式必须严格遵循data: ...\n\n，客户端的EventSource会自动解析每一条消息。
• 一定要处理客户端断开事件（req.on('close')），否则Twitter流会一直占用资源，导致内存泄漏。

方案2：普通分块JSON流（适合自定义客户端） #

如果你的客户端不是浏览器（比如Node.js服务、移动端），可以用普通的分块传输编码，直接发送JSON块：

app.get('/', function(req, res) {
  // 设置分块传输的响应头
  res.setHeader('Content-Type', 'application/json; charset=utf-8');
  res.setHeader('Transfer-Encoding', 'chunked');
  res.setHeader('Cache-Control', 'no-cache');
  res.flushHeaders();

  const stream = client.stream('statuses/filter', { track: 'crypto' });

  stream.on('data', function(event) {
    const tweet = { tweet: event?.text || 'nothing' };
    // 每个块发送一行JSON，方便客户端逐行解析
    res.write(`${JSON.stringify(tweet)}\n`);
  });

  stream.on('error', function(error) {
    console.error('Twitter stream error:', error);
    res.write(JSON.stringify({ error: 'Stream error occurred' }));
    res.end();
  });

  req.on('close', function() {
    stream.destroy();
    res.end();
  });
});

关键说明： #

• Transfer-Encoding: chunked 告诉服务器用分块方式发送响应。
• 每个块发送单独的JSON对象并换行，客户端可以逐行读取并解析，避免一次性加载所有数据。

核心总结 #

• 永远不要在流式场景中使用res.json()/res.send()，这些方法会自动结束响应并发送完整的响应头。
• 必须设置正确的响应头，让服务器和客户端知道这是一个持续的流式响应。
• 做好资源清理：流错误或客户端断开时，及时关闭Twitter流并结束响应。

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