NestJS使用@nestjs/axios时ECONNREFUSED错误无法被catchError捕获如何解决

问题根因 #

你遇到的ECONNREFUSED错误无法被catchError捕获的核心原因是你定义的Observable流没有被消费订阅：
@nestjs/axios的请求方法返回的是RxJS冷Observable，只有当存在订阅者时，管道中定义的map、catchError等操作符才会生效，没有订阅的情况下请求逻辑虽然会执行，但错误会直接逃逸到全局，不会进入你定义的catchError回调。

修复方案 #

根据你的代码使用场景选择对应写法即可：

场景1：显式订阅流 #

如果你不需要返回Observable给上层调用方，直接调用subscribe()方法消费流即可：

import { lastValueFrom } from 'rxjs';
import { InternalServerErrorException } from '@nestjs/common';
import { HttpService } from '@nestjs/axios';

// 订阅式写法
this.httpService.get('some url').pipe(
  map(res => {
    console.log('succeeded');
    return res.data;
  }),
  catchError(e => {
    // 此处可以正常捕获所有请求错误，包括ECONNREFUSED
    throw new InternalServerErrorException('error');
  })
).subscribe({
  next: (data) => {
    // 处理正常返回数据
  },
  error: (err) => {
    // catchError抛出的错误会最终流转到此处，可做兜底处理
  }
});

场景2：在async方法中使用 #

如果你习惯用async/await语法，使用RxJS提供的lastValueFrom/firstValueFrom将Observable转为Promise，用try/catch捕获错误即可：

async requestTargetEndpoint() {
  try {
    const res = await lastValueFrom(
      this.httpService.get('some url').pipe(
        map(res => {
          console.log('succeeded');
          return res.data;
        })
      )
    );
    // 处理正常返回数据
    return res;
  } catch (e) {
    // 此处可以捕获所有请求错误
    throw new InternalServerErrorException('error');
  }
}

场景3：Controller接口直接返回 #

如果你的请求逻辑是在Controller接口中直接返回，NestJS会内部自动订阅Observable，此时你原来的catchError写法会自动生效，不需要额外处理：

@Get('proxy')
proxyRequest() {
  // NestJS会自动订阅这个Observable，catchError逻辑正常触发
  return this.httpService.get('some url').pipe(
    catchError(e => {
      throw new InternalServerErrorException('error');
    }),
    map(res => {
      console.log('succeeded');
      return res.data;
    })
  );
}

注意事项 #

• 确保catchError操作符放在请求操作的下游，所有请求阶段产生的错误都会被捕获
• 不要将请求返回的Observable存储在变量中既不订阅也不返回，否则会出现错误逃逸的问题

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