Django当两个人同时购买时该怎么办

在Django框架中处理并发购买情况，通常涉及到数据库事务和锁机制来确保数据的一致性。以下是一些基础概念和相关解决方案：

基础概念

数据库事务：事务是一组原子性的SQL查询，要么全部执行成功，要么全部失败回滚。
乐观锁与悲观锁：
- 乐观锁：假设冲突很少发生，只在提交更新时检查是否有其他事务修改了数据。
- 悲观锁：假设冲突经常发生，在读取数据时就加锁，防止其他事务修改。

解决方案

使用数据库事务

Django提供了强大的事务管理功能，可以通过atomic装饰器或者上下文管理器来确保一系列操作的原子性。

from django.db import transaction

@transaction.atomic
def purchase_product(user_id, product_id):
    # 检查库存
    product = Product.objects.select_for_update().get(id=product_id)
    if product.stock > 0:
        # 减少库存
        product.stock -= 1
        product.save()
        # 创建购买记录
        Purchase.objects.create(user_id=user_id, product_id=product_id)
    else:
        raise Exception("Out of stock")

使用悲观锁（select_for_update）

select_for_update() 方法可以在查询时锁定选定的行，直到事务结束。这样可以防止其他事务并发修改这些行。

from django.db import transaction

@transaction.atomic
def purchase_product(user_id, product_id):
    with transaction.atomic():
        product = Product.objects.select_for_update().get(id=product_id)
        if product.stock > 0:
            product.stock -= 1
            product.save()
            Purchase.objects.create(user_id=user_id, product_id=product_id)
        else:
            raise Exception("Out of stock")

使用乐观锁

乐观锁通常通过版本号或者在模型中添加一个last_modified字段来实现。在更新数据时检查该字段是否被修改。

class Product(models.Model):
    name = models.CharField(max_length=100)
    stock = models.IntegerField()
    version = models.IntegerField(default=0)  # 乐观锁版本号

@transaction.atomic
def purchase_product(user_id, product_id):
    with transaction.atomic():
        product = Product.objects.get(id=product_id)
        if product.stock > 0:
            # 检查版本号是否一致
            if product.version == Product.objects.get(id=product_id).version:
                product.stock -= 1
                product.version += 1  # 更新版本号
                product.save()
                Purchase.objects.create(user_id=user_id, product_id=product_id)
            else:
                raise Exception("Concurrent update conflict")
        else:
            raise Exception("Out of stock")