MongoDB 数据库秒杀

基础概念

秒杀是一种电商促销活动，通常指在极短时间内以极低价格出售商品。由于参与人数众多，系统需要处理高并发请求，这对数据库的性能提出了极高的要求。

类型

库存预减：在活动开始前预先减少库存。
实时扣减：在用户下单时实时检查并扣减库存。
排队机制：将请求排队处理，逐个验证并扣减库存。

应用场景

电商平台的限时抢购活动。
节假日促销活动。
限量版商品发售。

可能遇到的问题及原因

超卖现象：库存被错误地多次扣减。
- 原因：并发请求导致库存检查和扣减操作不是原子性的。
- 解决方法：使用 MongoDB 的事务功能确保操作的原子性。

数据库压力过大：大量请求直接冲击数据库。
- 原因：没有合理的分流机制。
- 解决方法：引入消息队列（如 RabbitMQ 或 Kafka）来缓冲请求，减轻数据库压力。
响应时间过长：用户请求处理缓慢。
- 原因：数据库查询和更新操作效率低下。
- 解决方法：优化索引，使用更高效的查询语句，并考虑分片部署以提高性能。

示例代码

以下是一个简单的示例，展示如何在 MongoDB 中使用事务来防止超卖现象：

const { MongoClient } = require('mongodb');

async function run() {
  const uri = "your_mongodb_connection_string";
  const client = new MongoClient(uri);

  try {
    await client.connect();
    const database = client.db('your_database_name');
    const collection = database.collection('products');

    const session = client.startSession();
    session.startTransaction();

    try {
      const product = await collection.findOne({ _id: 'product_id', stock: { $gt: 0 } }, { session });
      if (!product) {
        throw new Error('Out of stock');
      }

      await collection.updateOne({ _id: 'product_id' }, { $inc: { stock: -1 } }, { session });
      await session.commitTransaction();
      console.log('Purchase successful');
    } catch (error) {
      await session.abortTransaction();
      console.error('Transaction aborted:', error);
    }
  } finally {
    await client.close();
  }
}

run().catch(console.dir);