RocketMQ入门01：为什么需要消息队列
引言：从一个电商下单场景说起 想象这样一个场景：用户在你的电商平台下单购买了一件商品。看似简单的一次点击，背后却触发了一系列复杂的业务流程： 扣减库存 生成订单 扣减用户积分 发送短信通知 发送邮件通知 增加商家销量统计 记录用户行为日志 触发推荐系统更新 如果采用传统的同步调用方式，会是什么样子？ 一、同步通信的痛点 1.1 性能瓶颈 // 传统同步调用方式 public OrderResult createOrder(OrderRequest request) { // 核心业务：100ms Order order = orderService.create(request); // 100ms inventoryService.deduct(request.getSkuId()); // 50ms // 非核心业务：累计 500ms+ pointService.deduct(request.getUserId()); // 100ms smsService.send(request.getPhone()); // 200ms emailService.send(request.getEmail()); // 150ms statisticsService.record(order); // 50ms logService.log(order); // 30ms recommendService.update(request.getUserId()); // 100ms return new OrderResult(order); } // 总耗时：730ms+ 问题分析： 用户需要等待 730ms+ 才能看到下单结果 其中只有前 150ms 是核心业务 580ms 都在等待非核心业务完成 1.2 高耦合问题 // 每增加一个下游系统，都要修改订单服务代码 public OrderResult createOrder(OrderRequest request) { // ... 原有代码 // 新需求：增加优惠券系统通知 couponService.notify(order); // 又要改订单服务！ // 新需求：增加大数据分析 bigDataService.collect(order); // 又要改订单服务！ } 问题分析： ...