Axios无法正确捕获流错误，如何捕获错误并重启流进程？

我用Axios写了获取ndjson数据流的代码，这个API会全天持续返回数据，之后通过Socket.io把数据发给所有客户端。但运行数小时后，流会静默停止/失败（从Socket停止向客户端发数据能判断出来）。当前代码没法正确捕获错误，想问问怎么捕获错误并重启这个进程。

原代码：

const getData = () => {
try {
    const response = await axios.get(url, { responseType: 'stream'})
    
    
    const stream = response.data
    
    stream.on('data', (data) => {
        processData(data)
    })
    
    stream.on('end', () => {
        console.log("stream end") //<-- 没打印
        getData() //<-- 没执行
    })
} catch(err) {
console.log(err)
}

核心问题分析 #

你的代码只监听了流的data和end事件，但Node.js的流出现错误（比如网络中断、数据格式异常）时，默认不会触发end，也不会把错误抛到外层的try/catch——这就是流静默停止但end事件没触发的原因。另外，外层try/catch只能捕获Axios发起请求阶段的错误，请求成功建立后流层面的错误管不到。

具体修改方案 #

1. 强制监听流的error事件 #

这是捕获静默错误的关键，流的任何异常都会触发这个事件，必须显式处理：

stream.on('error', (err) => {
  console.error("数据流出错:", err);
  // 出错后延迟重启，避免频繁请求
  setTimeout(getData, 2000);
});

2. 完善Axios请求层面的错误处理 #

保留外层try/catch，但重启时加延迟，应对请求初始化阶段的失败：

catch (err) {
  console.error("Axios请求初始化失败:", err);
  setTimeout(getData, 3000);
}

3. 给Axios请求加超时 #

避免连接长时间挂死但不触发任何事件的情况：

const response = await axios.get(url, { 
  responseType: 'stream',
  timeout: 30000 // 30秒超时
});

4. 优化end事件的重启逻辑 #

即使流正常结束，也加延迟再重启，避免频繁请求：

stream.on('end', () => {
  console.log("数据流正常结束，准备重启");
  setTimeout(getData, 1000);
});

完整修改后的代码 #

const getData = () => {
  try {
    const response = await axios.get(url, { 
      responseType: 'stream',
      timeout: 30000 
    });

    const stream = response.data;

    stream.on('data', (data) => {
      processData(data);
    });

    stream.on('end', () => {
      console.log("数据流正常结束，准备重启");
      setTimeout(getData, 1000);
    });

    // 捕获流的错误
    stream.on('error', (err) => {
      console.error("数据流发生错误:", err);
      setTimeout(getData, 2000);
    });

    // 监听请求中止事件（比如客户端主动断开）
    response.request.on('abort', () => {
      console.log("请求被中止，准备重启");
      setTimeout(getData, 1000);
    });

  } catch (err) {
    console.error("Axios请求初始化失败:", err);
    setTimeout(getData, 3000);
  }
};

补充提示 #

• 如果Socket.io向客户端发数据失败导致数据积压，也可能让流卡住，建议同时监听Socket.io的error和disconnect事件，确保数据流和客户端连接状态联动。
• 重启时的延迟时间可以根据实际网络情况调整，比如不稳定时延长延迟。

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