異步解耦?
- 系統間通過消息隊列通信,降低耦合度(如訂單系統與庫存系統)
- 典型場景:電商下單后異步通知物流系統
?流量削峰?
- 應對突發流量,將請求暫存到消息隊列逐步處理
- 典型場景:秒殺活動時緩沖高并發請求
?數據同步?
- 跨系統/數據庫的數據實時同步(如MySQL到Elasticsearch)
- 通過消息總線實現最終一致性
?事件驅動架構?
- 基于發布-訂閱模式的事件通知(如用戶注冊成功觸發多系統動作)
?日志收集?
- 分布式系統日志聚合分析(結合Flume/Kafka等)
?定時/延遲任務?
- 支持延遲消息(如30分鐘后檢查訂單支付狀態)
- rocketMQTemplate.syncSend(
"order-timeout-topic",?
MessageBuilder.withPayload(orderId)
.setHeader(RocketMQHeaders.DELAY_TIME_LEVEL, "3") // 30分鐘延遲
.build()
);
?金融級事務?
- 提供事務消息機制,保證分布式事務最終一致性
技術特點:
- 低延遲(毫秒級)
- 高吞吐(單機10萬級TPS)
- 分布式高可用架構
- 支持消息回溯和重試
- 完善的監控告警功能
典型用戶案例:支付寶交易通知、菜鳥物流狀態更新、釘釘消息推送等。