如何处理产品微服务故障无返回值的调用阻塞问题？

核心问题是未对微服务调用设置超时控制，导致服务故障时请求无限挂起。以下是针对性的落地解决方案：

1. 强制添加超时控制 #

利用RxJS的timeout操作符为服务调用设置最大等待时间，超时后立即终止请求并抛出错误，避免无限等待。

修改原代码中的服务调用片段：

import { timeout } from 'rxjs/operators';

async getStats(productId: string) {
  let existedProduct;
  try {
    // 设置5秒超时，可根据业务场景调整时长
    existedProduct = await firstValueFrom(
      this.productClient.send('get_product', { productId }).pipe(
        timeout(5000)
      )
    );
  } catch (error) {
    // 统一捕获超时、服务不可达等异常
    throw new BadGatewayException('产品服务暂时不可用，请稍后重试');
  }

  if (!existedProduct) {
    throw new NotFoundException('Продукт не найден');
  }

  // 后续统计逻辑保持不变...
}

2. 实现业务降级策略（按需选择） #

如果产品服务的可用性不影响统计数据的核心输出，可以在服务故障时跳过产品存在性检查，返回基础统计数据并标注服务状态：

async getStats(productId: string) {
  let productExists = true;
  try {
    await firstValueFrom(
      this.productClient.send('get_product', { productId }).pipe(
        timeout(5000)
      )
    );
  } catch (error) {
    // 服务故障时标记产品状态未知，继续返回统计数据
    productExists = false;
  }

  const avgRatingData = await this.prismaService.review.aggregate({
    where: { productId },
    _avg: { rate: true }
  });
  const reviewsCount = await this.prismaService.review.count({ where: { productId } });
  const avgRating = avgRatingData._avg.rate ? Number(avgRatingData._avg.rate.toFixed(2)) : 0;

  return {
    stats: {
      productId,
      avgRating,
      reviewsCount,
      productStatus: productExists ? '正常' : '产品服务不可用，状态未知'
    }
  };
}

3. 集成断路器模式保护系统 #

对于频繁调用的微服务，使用断路器避免在服务故障时持续发送请求，防止资源耗尽：

1. 安装依赖：npm install opossum
2. 封装断路器逻辑：

import { CircuitBreaker } from 'opossum';

// 初始化断路器，配置失败阈值和恢复规则
const productCircuit = new CircuitBreaker(async (productId) => {
  return firstValueFrom(
    this.productClient.send('get_product', { productId }).pipe(timeout(5000))
  );
}, {
  timeout: 5000,
  errorThresholdPercentage: 50, // 失败率超过50%触发断路
  resetTimeout: 30000 // 30秒后尝试恢复服务调用
});

async getStats(productId: string) {
  let existedProduct;
  try {
    existedProduct = await productCircuit.fire(productId);
  } catch (error) {
    if (error.type === 'CircuitOpenError') {
      throw new BadGatewayException('产品服务已断路，请稍后重试');
    }
    throw new BadGatewayException('产品服务暂时不可用');
  }

  if (!existedProduct) {
    throw new NotFoundException('Продукт не найден');
  }

  // 后续统计逻辑保持不变...
}

关键注意事项 #

• 超时时间需根据业务场景调整，过短可能误杀正常请求，过长则失去超时控制意义。
• 降级策略必须符合业务规则，若产品存在性是统计数据的前置条件，不可随意跳过检查。
• 断路器的参数（失败阈值、恢复时间）需要结合服务的实际故障率和恢复速度配置。

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