如何使用RxJS手动返回504错误（用于本地模拟测试）

如果你需要在RxJS里手动抛出带指定错误码（比如504网关超时）的错误来测试本地错误处理逻辑，这里有几种实用的方法：

1. 直接创建错误Observable #

用RxJS的throwError函数直接生成一个会立即抛出错误的Observable，错误对象里包含status字段模拟HTTP错误码：

import { throwError } from 'rxjs';

// 构造并返回504错误Observable
const mock504Error$ = throwError(() => ({
  status: 504,
  message: 'Gateway Timeout',
  error: '服务器网关超时，请稍后重试' // 可添加其他实际错误中会有的属性
}));

// 订阅测试错误处理逻辑
mock504Error$.subscribe({
  next: () => console.log('此回调不会执行'),
  error: (err) => {
    console.error(`捕获到错误码: ${err.status}`);
    // 这里编写你的504错误专属处理逻辑
    if (err.status === 504) {
      // 比如显示超时提示、重试请求等
    }
  }
});

2. 在管道操作中抛出错误 #

如果需要模拟“正常请求后触发错误”的场景，可以在管道操作符（比如switchMap、map）中抛出错误：

import { of } from 'rxjs';
import { switchMap } from 'rxjs/operators';

// 模拟请求流程，中途抛出504错误
const mockRequestFlow$ = of('模拟请求参数').pipe(
  switchMap((params) => {
    // 这里可以根据测试条件决定是否抛出错误
    // 比如测试错误分支时强制抛出
    return throwError(() => ({
      status: 504,
      message: 'Gateway Timeout',
      requestParams: params
    }));
  })
);

mockRequestFlow$.subscribe({
  error: (err) => {
    console.log(`请求参数: ${err.requestParams}, 错误码: ${err.status}`);
    // 执行对应的错误处理
  }
});

3. 自定义错误类模拟真实HTTP错误 #

如果希望错误结构更贴近实际项目中的HTTP错误（比如有统一的错误类型），可以自定义错误类：

import { throwError } from 'rxjs';

// 自定义HTTP错误类
class HttpError extends Error {
  constructor(
    public status: number,
    public message: string,
    public responseBody?: any
  ) {
    super(message);
    this.name = 'HttpError';
  }
}

// 使用自定义类创建504错误Observable
const custom504Error$ = throwError(() => 
  new HttpError(504, 'Gateway Timeout', { code: 'GATEWAY_TIMEOUT', retryAfter: 10 })
);

custom504Error$.subscribe({
  error: (err) => {
    console.log(`错误类型: ${err.name}, 状态码: ${err.status}`);
    console.log(`重试建议: ${err.responseBody.retryAfter}秒后重试`);
  }
});

核心思路就是通过throwError生成错误Observable，在错误对象中携带status字段来模拟对应的HTTP错误码，这样就能在订阅时精准捕获并测试你的错误处理逻辑。

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