AngularFire：如何无需订阅从Firebase获取常量值

首先得明确一点：Firebase实时数据库的所有读写操作本质都是异步的，不存在完全无需异步处理的同步获取方式，但我们可以通过优化代码逻辑，让它在你的订单提交流程里按预期执行，同时避免不必要的长期订阅，还能解决并发场景下的重复订单号问题。

问题核心分析 #

你当前的代码里，getOrderNumber()返回的是Observable，这是一个异步数据流，直接用+1会把Observable对象和数字相加，自然得不到正确的订单号。我们需要等待异步操作完成拿到真实的数值后，再执行后续逻辑。

方案1：用Async/Await + Take(1)简化异步流程 #

这种方式最贴近同步代码的写法，可读性很高。

首先修改你的服务方法，把Observable转成Promise，同时用take(1)只取一次数据（避免持续订阅浪费资源）：

// 订单服务中的方法
getOrderNumber(): Promise<number> {
  return this.db.list('lastOrderNumber').valueChanges()
    .pipe(take(1)) // 仅获取一次最新值后自动取消订阅
    .toPromise(); // 转换为Promise，支持await语法
}

然后在组件的提交方法里，用async标记函数，并用await等待订单号获取完成：

// PurchaseComponent中的提交方法
async onOrderSubmit(formValue) {
  try {
    // 等待获取最新的最后订单号
    const lastOrderNumber = await this.orderService.getOrderNumber();
    const newOrderNumber = lastOrderNumber + 1;

    // 重要：先更新Firebase中的lastOrderNumber，再保存新订单
    // 这一步能减少重复订单号的概率，但高并发场景下仍有风险
    await this.db.object('lastOrderNumber').set(newOrderNumber);
    // 保存新订单
    await this.db.object(`purchaseOrder/${newOrderNumber}`).update(formValue);

    console.log('订单提交成功，订单号：', newOrderNumber);
    // 这里可以添加用户提示，比如弹窗或Toast
  } catch (error) {
    console.error('订单提交失败：', error);
    // 处理错误，比如提示用户重试
  }
}

方案2：用Firebase事务解决并发冲突（更安全） #

如果你的系统存在多用户同时提交订单的场景，上面的方案可能会出现竞争条件：两个用户同时拿到同一个lastOrderNumber，生成相同的新订单号。这时候Firebase事务是最优解，它能确保更新操作基于最新的数据库值，自动处理并发重试。

修改服务，新增一个生成订单号的方法，用事务实现：

// 订单服务中的方法
generateNewOrderNumber(): Promise<number> {
  const orderNumberRef = this.db.object('lastOrderNumber');
  
  // 事务会自动处理并发：如果当前值被其他请求修改，会重试直到成功
  return orderNumberRef.transaction(currentValue => {
    // 如果是第一次生成订单号（currentValue为null），默认从1开始
    return (currentValue || 0) + 1;
  }).then(result => {
    if (result.committed) {
      // 事务提交成功，返回新生成的订单号
      return result.snapshot.val();
    } else {
      throw new Error('订单号生成失败，事务未提交');
    }
  });
}

然后组件里调用这个方法：

async onOrderSubmit(formValue) {
  try {
    // 直接获取生成好的新订单号（事务已自动更新lastOrderNumber）
    const newOrderNumber = await this.orderService.generateNewOrderNumber();
    // 保存新订单
    await this.db.object(`purchaseOrder/${newOrderNumber}`).update(formValue);

    console.log('订单提交成功，订单号：', newOrderNumber);
  } catch (error) {
    console.error('订单提交失败：', error);
  }
}

方案3：用RxJS操作符链式处理（适合习惯响应式编程的场景） #

如果你更习惯用RxJS的方式处理异步流，可以用switchMap等操作符链式调用：

服务方法返回带take(1)的Observable：

// 订单服务中的方法
getOrderNumber(): Observable<number> {
  return this.db.list('lastOrderNumber').valueChanges()
    .pipe(take(1));
}

组件里链式处理数据流：

onOrderSubmit(formValue) {
  this.orderService.getOrderNumber().pipe(
    // 拿到lastOrderNumber后，生成新订单号并更新数据库
    switchMap(lastOrderNumber => {
      const newOrderNumber = lastOrderNumber + 1;
      // 更新lastOrderNumber后，把新订单号传递下去
      return this.db.object('lastOrderNumber').set(newOrderNumber).pipe(
        map(() => newOrderNumber)
      );
    })
  ).subscribe({
    next: (newOrderNumber) => {
      // 保存新订单
      this.db.object(`purchaseOrder/${newOrderNumber}`).update(formValue)
        .then(() => console.log('订单保存成功'))
        .catch(err => console.error('保存订单失败：', err));
    },
    error: (err) => console.error('获取订单号失败：', err)
  });
}

关键提醒 #

• 永远不要直接依赖客户端生成的订单号去做唯一性保证，必须通过数据库的原子操作（比如事务）来确保订单号的唯一性。
• 所有Firebase数据库操作都是异步的，你需要通过Promise或Observable的方式等待操作完成，再执行后续逻辑，不能像同步代码那样直接赋值计算。

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