异步解耦
- 系统间通过消息队列通信,降低耦合度(如订单系统与库存系统)
- 典型场景:电商下单后异步通知物流系统
流量削峰
- 应对突发流量,将请求暂存到消息队列逐步处理
- 典型场景:秒杀活动时缓冲高并发请求
数据同步
- 跨系统/数据库的数据实时同步(如MySQL到Elasticsearch)
- 通过消息总线实现最终一致性
事件驱动架构
- 基于发布-订阅模式的事件通知(如用户注册成功触发多系统动作)
日志收集
- 分布式系统日志聚合分析(结合Flume/Kafka等)
定时/延迟任务
- 支持延迟消息(如30分钟后检查订单支付状态)
- rocketMQTemplate.syncSend(
"order-timeout-topic",
MessageBuilder.withPayload(orderId)
.setHeader(RocketMQHeaders.DELAY_TIME_LEVEL, "3") // 30分钟延迟
.build()
);
金融级事务
- 提供事务消息机制,保证分布式事务最终一致性
技术特点:
- 低延迟(毫秒级)
- 高吞吐(单机10万级TPS)
- 分布式高可用架构
- 支持消息回溯和重试
- 完善的监控告警功能
典型用户案例:支付宝交易通知、菜鸟物流状态更新、钉钉消息推送等。