一、业务背景与痛点

Taocarts反向海淘业务存在大量非实时核心链路：订单创建后的库存统计、批次归集、运费核算、日志归档、用户消息推送、对账数据生成等。早期采用同步执行模式，所有逻辑串行执行，导致两大严重问题。

第一，接口响应极慢，单次下单接口耗时高达800ms~1.5s，高峰期超时严重；第二，大促流量洪峰瞬间压垮数据库，同步大批量写入引发锁等待、慢查询堆积，极易造成服务雪崩。跨境业务潮汐流量明显，同步架构完全无法承载波峰冲击。

二、问题分析

1、核心下单逻辑与非核心统计、归档、推送逻辑耦合，同步阻塞；

2、瞬时高并发写入无缓冲，流量直接打穿至数据库；

3、任务失败无重试机制，导致数据统计遗漏、对账缺失。

三、解决方案

引入阿里云RocketMQ，将所有非实时业务异步解耦，实现流量削峰、异步重试、业务解耦，核心链路只保留下单、库存锁定核心逻辑，极大缩短接口耗时。

四、核心落地代码

/**

订单核心链路：只保留核心逻辑，异步任务投递MQ

*/

@Service

public class OrderCreateService {

@Autowired

private RocketMQTemplate rocketMQTemplate;

public Result createOrder(OrderDTO dto) {

// 1.核心事务：创建订单、锁定库存（仅核心逻辑）

OrderDO order = buildOrder(dto);

orderMapper.insert(order);

stockLockService.lockStock(dto.getGoodsId());

// 2.非核心任务全部异步投递MQ解耦

OrderAsyncMessage message = new OrderAsyncMessage();

message.setOrderNo(order.getOrderNo());

message.setUserId(dto.getUserId());

rocketMQTemplate.syncSend("taocarts-order-async-topic", JSON.toJSONString(message));

return Result.success(order.getOrderNo());

}

}

消费者异步处理+失败重试

/**

MQ消费者：异步处理统计、对账、推送、归档

*/

@RocketMQMessageListener(topic = "taocarts-order-async-topic", consumerGroup = "taocarts-order-consumer")

@Component

public class OrderAsyncConsumer implements RocketMQListener {

@Override

public void onMessage(String message) {

OrderAsyncMessage msg = JSON.parseObject(message, OrderAsyncMessage.class);

try {

// 批次归集

batchService.collectBatch(msg.getOrderNo());

// 费用核算

feeService.calcOrderFee(msg.getOrderNo());

// 消息推送

pushService.sendUserNotice(msg.getUserId());

// 日志归档

logService.archiveOrderLog(msg.getOrderNo());

}catch (Exception e){

// MQ自动重试，保证数据最终一致性

throw new RuntimeException("异步任务处理失败，等待重试");

}

}

}

五、优化效果

1、下单接口平均耗时从1s降至120ms以内；

2、高峰期数据库瞬时QPS压降60%，彻底杜绝流量打穿问题；

3、异步任务失败自动重试，数据最终一致性100%保障；

4、业务完全解耦，迭代维护成本大幅降低。

六、总结

潮汐流量明显的跨境业务，异步解耦是架构稳定的刚需。阿里云RocketMQ完美实现削峰填谷、解耦容错，是中高并发跨境系统的必备中间件架构。