如何应对像抢小米手机一样的秒杀系统？这里有答案

在数字世界的舞台上，秒杀活动无疑引发了一场紧张激烈的竞争。今天，我们深入研究这场战斗背后的技术武器——筛选策略，助力数据库顺利处理巨量的用户请求。

秒杀的本质：一场流量与库存的较量

秒杀活动，堪称速度与流量控制的绝佳展示，其重要的使命在于为争夺稀缺资源的广大用户创造秩序井然的竞赛环境。

秒杀系统的精髓不仅仅限于用户选购行为，更是一项针对流量控制、库存管理以及用户体验等多种能力的全面考验。因此，技术团队需要打造一个能够敏捷响应需求并确保数据库承受过度负载的体系结构。

// promotion_variant (促销和变体表「sku」的一个中间表)
{
    'id': 1,
    'variant_id': 1,
    'promotion_id': 1,
    'promotion_type': 'snap_up',
    'discount_rate': 0.5,
    'stock': 100, // 秒杀库存
    'sold': 0, // 秒杀销量
    'quantity_limit': 1, // 限购
    'enabled': 1,
    'product_id': 1,
    'rest': {
        variant_name: 'xxx', // 秒杀期间变体名称
        image: 'xxx', // 秒杀期间变体图片
    }
}

流量筛选的艺术：从缓存到API的重构

在快速发展的商业环境下，流量筛选成为至关重要的环节。借助库存缓存的强大功能，我们能提前淘汰那些对产品没有兴趣或无购买意愿的流量，从而显著降低数据库压力，提高系统响应速度。

# PromotionVariantObserver.php
public function saved(PromotionVariant $promotionVariant)
{
  if ($promotionVariant->promotion_type === PromotionType::SNAP_UP) {
    $seconds = $promotionVariant->ended_at->getTimestamp() - time();
    Cache::put(
      "promotion_variants:$promotionVariant->id",
      $promotionVariant,
      $seconds
    );
  }
}

鉴于未来工作需求，对订单接口的优化至关重要。原有的接口在处理限时抢购商品时，由于频繁查询数据库而影响了运行速度。因此，为秒杀活动量身打造专属的API接口便是提升效率的关键所在。通过该全新的API，前端能够在检测到秒杀商品的同时，迅速切换至下单流程，极大地减少了不必要的操作环节。

确认与锁定：确保每一笔订单的安全

在用户完成筛选流程之后，当他们步入订单确认环节时，为了确保交易安全，我们的系统会对这笔订单进行核实与存货锁定。这样的操作可以确保您成功完成后续付款过程，同时也能够有效规避因选错地址或者优惠券误用而造成的数据负载过重问题。

本流程运用队列机制以精准控制数据库并发压力，确保即使在抢购高峰期，用户也能在不知不觉间有序等候，尽享流畅便捷的购物之旅。

后端的力量：从订单创建到事件通知

# CheckoutController.php
/**
 * @param Request $request
 * @return IlluminateContractsRoutingResponseFactory|IlluminateHttpResponse
 * @throws StockException
 */
public function snapUpCheckout(Request $request)
{
    $variantId = $request->input('variant_id');
    $quantity = $request->input('quantity', 1);
    // 加锁防止超卖
    $lock = Cache::lock('snap_up:' . $variantId, 10);
    try {
        // 未获取锁的消费者将阻塞在这里
        $lock->block(10);
        $promotionVariant = Cache::get('promotion_variants:' . $variantId);
        if ($promotionVariant->quantity release();
            throw new StockException('库存不足');
        }
        $promotionVariant->quantity -= $quantity;
        $seconds = $promotionVariant->ended_at->getTimestamp() - time();
        Cache::put(
            "promotion_variants:$promotionVariant->id",
            $promotionVariant,
            $seconds
        );
    } catch (LockTimeoutException $e) {
        throw new StockException('库存不足');
    } finally {
        optional($lock)->release();
    }
    CheckoutOrder::dispatch([
        'user_id' => Auth::id(),
        'variant_id' => $variantId,
        'quantity' => $quantity
    ]);
    return response('结账订单创建中');
}

在秒杀活动后台控制中，其流程具备高度精确性与复杂性。一旦用户成功参与，前后台便立即协同工作，后端在确认订单无误后，立刻通知前端用户进行下一步操作。虽然该流程看似简单，但每一个环节都需要精心设计，确保信息准确无误。

在设计系统时，需考虑用户可能出现的断链或长时间离线情况。为避免库存无端占用，应实现实时释放功能。虽然这会提高系统复杂性，但对保证秒杀活动顺利进行至关重要。

queue的力量：与mysql的和谐共处

# Job/CheckoutOrder.php
// ...
public function handle()
{
  // 创建结账订单
  // ...
  // 通知客户端. websocket 编程本身就是以事件为导向的，和 laravel 的 event 非常契合。
  event(new OrderChecked($this->data->user_id));
}
// ...

在限时抢购环节，队列扮演着至关重要的角色。通过流量控制功能，能显著降低MySQL的负载压力。若MySQL性能优越，众多队列能够同步处理订单，用户几乎无法感知到等待时间，从而享受到流畅的购物体验。

总结与展望：秒杀技术的未来之路

# Event/OrderChecked.php
class OrderChecked implements ShouldBroadcast
{
    use Dispatchable, InteractsWithSockets, SerializesModels;
    private $userId;
    /**
     * Create a new event instance.
     *
     * @param $userId
     */
    public function __construct($userId)
    {
        $this->userId = $userId;
    }
    /**
     * App.User.{id} 是 laravel 初始化时，默认的私有频道，直接使用即可
     * @return IlluminateBroadcastingChannel|array
     */
    public function broadcastOn()
    {
        return new PrivateChannel('App.User.' . $this->userId);
    }
}

深入探讨表明，秒杀活动的成功并不仅仅取决于用户点击购买按钮的行为。实际上，其背后涉及到多项技术挑战，包括流量调控、库存管理以及用户体验等方面。展望科技飞速发展的未来，我们坚信秒杀技术将不断完善，致力于为消费者带来更优质的购物体验。

// views/products/show.vue

import Echo from 'laravel-echo'
import io from 'socket.io-client'
window.io = io
export default {
  name: 'App',
  methods: {
    async snapUpCheckout () {
      try {
        // await post -> snap-up-checkout
        this.toCheckout()
      } catch (error) {
        // 秒杀失败
      }
    },
    toCheckout () {
      // 建立 websocket 连接
      const echo = new Echo({
        broadcaster: 'socket.io',
        host: 'http://api.e-commerce.test:6001',
        auth: {
          headers: {
            Authorization: 'Bearer ' + this.store.auth.token
          }
        }
      })
      // 监听私有频道 App.User.{id} 的 OrderChecked 事件
      echo.private('App.User.' + this.store.user.id).listen('OrderChecked', (e) => {
        // redirect to checkou page
      })
    }
  }
}

的购物体验。

敬请各位深思：未来的瞬间完成交易技术将有何创新之处？望广大业界同仁踊跃于评论区，共谋技术无限潜力的深化探讨。

# BroadcastServiceProvider.php
public function boot()
{
  // 将认证路由改为 /api/broadcasting/auth 从而避免 csrf 验证
  // 添加中间件 auth:api (jwt 使用 api.auth) 进行身份验证，避免访问 session ,并使 Auth::user() 生效。
  Broadcast::routes(["prefix" => "api", "middleware" => ["auth:api"]]);
  require base_path('routes/channels.php');
}

// laravel-echo-server.json
// 认证路由添加 api 前缀，与上面的修改对应
"authEndpoint": "/api/broadcasting/auth"