SpringCloud 实战：用 Kafaka 和 Redis 实现异步商品下单减库存

后端

2023-12-17 04:40:35

异步下单减库存概述

在电商系统中，下单减库存是一个关键环节。传统的方式是同步执行，即用户下单后，系统会立即扣减库存。然而，这种方式可能会导致性能瓶颈和系统延迟，尤其是在高并发场景下。为了解决这个问题，我们可以采用异步下单减库存的方式。

异步下单减库存是指，用户下单后，系统不会立即扣减库存，而是将下单信息发送到消息队列中，然后由专门的消费者来处理下单和扣减库存的操作。这种方式可以有效地提高系统性能和并发能力。

2. 系统设计

我们的系统将使用 SpringCloud 作为微服务框架，Kafka 作为消息队列，Redis 作为缓存。系统将包含以下几个组件：

用户服务： 负责处理用户下单请求。
订单服务： 负责处理实际的下单操作和库存扣减。
消息队列： 负责存储预下单信息。
缓存： 负责存储预下单信息。

3. 实现步骤

3.1 预下单

用户下单时，用户服务会生成一个订单号，并将订单号标识保存到 Redis 中，并设置有效期为 1 分钟。

3.2 发送到 Kafka

用户服务将预下单信息发送到 Kafka 中。Kafka 消费者（即订单服务）将从 Kafka 中接收预下单信息。

3.3 实际下单

订单服务收到预下单信息后，会根据订单号从 Redis 中获取订单标识，然后进行实际的下单操作和库存扣减。

3.4 更新缓存

订单服务在下单成功后，会更新 Redis 中的订单标识，以表示该订单已完成。

4. 代码示例

以下是一些代码示例：

4.1 用户服务

@PostMapping("/order")
public ResponseEntity<Order> createOrder(@RequestBody Order order) {
    // 生成订单号
    String orderNo = UUID.randomUUID().toString();

    // 将订单号标识保存到 Redis 中
    redisTemplate.opsForValue().set(orderNo, "1", 1, TimeUnit.MINUTES);

    // 将预下单信息发送到 Kafka 中
    kafkaTemplate.send("orders", order);

    return ResponseEntity.ok(order);
}

4.2 订单服务

@KafkaListener(topics = "orders")
public void listenOrder(@Payload Order order) {
    // 从 Redis 中获取订单标识
    String orderFlag = redisTemplate.opsForValue().get(order.getOrderNo());

    // 判断订单标识是否存在
    if (orderFlag != null) {
        // 执行下单操作和库存扣减
        orderService.placeOrder(order);

        // 更新 Redis 中的订单标识
        redisTemplate.opsForValue().set(order.getOrderNo(), "0");
    }
}