基于 RabbitMQ 实现延迟消息的订单处理流程

在现代电商系统中，订单处理是一个复杂且关键的环节。从商品查询到库存扣减、订单生成、支付确认等多个步骤，任何一个环节出现问题都可能导致用户体验下降甚至订单失败。今天，我们将通过一个典型的 Java Spring Boot 订单处理流程，结合 RabbitMQ 延迟消息 和全局事务管理，确保每一步都能顺利执行。

订单创建流程

在这个系统中，我们主要关注的功能是 createOrder 方法，它实现了从订单创建到支付确认的全过程。让我们一起来看看代码背后都发生了什么。

@Override
@GlobalTransactional
public Long createOrder(OrderFormDTO orderFormDTO) {// 1.订单数据Order order = new Order();// 1.1.查询商品List<OrderDetailDTO> detailDTOS = orderFormDTO.getDetails();// 1.2.获取商品id和数量的MapMap<Long, Integer> itemNumMap = detailDTOS.stream().collect(Collectors.toMap(OrderDetailDTO::getItemId, OrderDetailDTO::getNum));Set<Long> itemIds = itemNumMap.keySet();// 1.3.查询商品List<ItemDTO> items = itemClient.queryItemByIds(itemIds);if (items == null || items.size() < itemIds.size()) {throw new BadRequestException("商品不存在");}// 1.4.基于商品价格、购买数量计算商品总价：totalFeeint total = 0;for (ItemDTO item : items) {total += item.getPrice() * itemNumMap.get(item.getId());}order.setTotalFee(total);// 1.5.其它属性order.setPaymentType(orderFormDTO.getPaymentType());order.setUserId(UserContext.getUser());order.setStatus(1);// 1.6.将Order写入数据库order表中save(order);// 2.保存订单详情List<OrderDetail> details = buildDetails(order.getId(), items, itemNumMap);detailService.saveBatch(details);// 3.扣减库存try {itemClient.deductStock(detailDTOS);} catch (Exception e) {throw new RuntimeException("库存不足！");}// 4.清理购物车商品cartClient.deleteCartItemByIds(itemIds);// 5.发送延迟消息，检测订单支付状态rabbitTemplate.convertAndSend(MQConstants.DELAY_EXCHANGE_NAME, MQConstants.DELAY_ORDER_KEY, order.getId(),message -> {message.getMessageProperties().setDelay(15 * 60 * 1000); // 15分钟延迟return message;});return order.getId();
}

1. 商品查询与订单数据初始化

首先，我们从用户提交的订单数据中提取商品 ID 和数量，并通过 itemClient.queryItemByIds 方法批量查询商品信息。如果查询结果中商品数量与请求的商品数量不符，则抛出异常提示“商品不存在”。

2. 总价计算与订单保存

接下来，系统根据商品单价与购买数量计算总价，并将相关信息写入数据库。在这一过程中，我们利用 Java 的流处理特性，对商品列表进行遍历与总价计算。

3. 扣减库存与购物车清理

订单数据保存成功后，系统会尝试扣减相应库存，并清理用户购物车中的相关商品。如果库存不足，系统会抛出异常并回滚整个事务。

4. 延迟消息与支付状态检测

最后，系统通过 RabbitMQ 发送一个延迟消息，以便在未来某个时间点检查订单支付状态。这一步保证了即便用户在支付过程中遇到问题，系统也能够及时响应并处理未支付的订单。这里，我们将延迟消息的时间设置为 15 分钟。

订单延迟消息监听器

接下来，我们来看看如何利用消息队列处理订单支付状态的异步检测。

@Component
@RequiredArgsConstructor
public class OrderDelayMessageListener {private final IOrderService orderService;private final PayClient payClient;@RabbitListener(bindings = @QueueBinding(value = @Queue(MQConstants.DELAY_ORDER_QUEUE_NAME),exchange = @Exchange(name = MQConstants.DELAY_EXCHANGE_NAME,delayed = "true"), key = MQConstants.DELAY_ORDER_KEY))public void listenOrderDelayMessage(Long orderId) {// 1.查询订单Order order = orderService.getById(orderId);// 2.判断订单状态，是否已支付if (order == null || order.getStatus() != 1) {// 不做处理return;}// 3.未支付，需要查询支付流水状态PayOrderDTO payOrder = payClient.queryPayOrderByBizOrderNo(orderId);// 4.判断是否支付if (payOrder != null && payOrder.getStatus() == 3) {// 4.1.已经支付，标记订单状态为已支付orderService.markOrderPaySuccess(orderId);} else {// 4.2.未支付，取消订单，回复库存orderService.cancelOrder(orderId);}}
}

在上述代码中，我们利用了 RabbitMQ 的延迟队列特性。当订单延迟消息被监听器捕获后，系统会根据订单当前状态和支付流水状态决定接下来的处理步骤。如果支付成功，订单状态将被更新为已支付；否则，订单将被取消，并恢复相应库存。

支付成功与订单取消

@Override
public void markOrderPaySuccess(Long orderId) {Order order = new Order();order.setId(orderId);order.setStatus(2);order.setPayTime(LocalDateTime.now());updateById(order);
}@Override
@GlobalTransactional
public void cancelOrder(Long orderId) {// 标记订单为已关闭Order order = getById(orderId);if (order != null && order.getStatus() != 5) {order.setStatus(5);updateById(order);}// 恢复库存List<OrderDetail> details = detailService.lambdaQuery().eq(OrderDetail::getOrderId, orderId).list();List<OrderDetailDTO> orderDetailDTOS = BeanUtils.copyList(details, OrderDetailDTO.class);itemClient.restoreStock(orderDetailDTOS);
}

1. 订单支付成功

在 markOrderPaySuccess 方法中，系统将订单状态更新为已支付，并记录支付时间。这一操作确保用户和系统对订单状态有准确的认知。

2. 订单取消与库存恢复

如果订单在延迟消息检测中被认定为未支付，则调用 cancelOrder 方法取消订单，并通过 itemClient.restoreStock 恢复相应库存。由于这些操作可能涉及多个服务，因此通过 @GlobalTransactional 注解确保其在全局事务中执行。

总结

在本篇博客中，我们深入探讨了一个完整的订单处理流程。从商品查询到库存管理，再到支付状态检测，每一步都经过精心设计与实现。通过 Spring Boot 的全局事务管理和 RabbitMQ 延迟消息，我们确保了整个流程的原子性和可靠性。