RocketMQ 是阿里開源的分佈式消息中間件,基於 Java 開發,遵循 Apache 2.0 協議,主打高吞吐、低延遲、高可用,適配海量消息場景(如電商秒殺、交易對賬、日誌同步),也是阿里雲消息隊列 MQ 的開源版,廣泛應用於電商、金融、物流等企業級系統,兼容 Kafka/RabbitMQ 部分特性,同時適配微服務架構。
核心特性
- 高性能支持百萬級 TPS 消息收發,單節點可處理千萬級消息堆積;採用零拷貝、異步刷盤、批量收發等機制,消息延遲低至毫秒級,適配高併發場景(如雙十一秒殺)。
- 高可用與可靠性基於主從架構 + 副本同步,單節點故障不影響集羣服務;支持消息持久化(磁盤 / SSD)、重試機制、死信隊列,確保消息 “不丟不重”;支持事務消息,解決分佈式事務一致性問題。
- 靈活的消息模型支持發佈訂閲(Pub/Sub)、點對點(P2P)、延時消息(精準到秒級)、順序消息(全局 / 分區有序)、批量消息等,覆蓋電商下單、物流派單、日誌採集等全場景。
- 集羣與生態適配支持多主多從、異地多活集羣部署,可彈性擴縮容;適配 Spring Cloud/Dubbo 等微服務框架,提供豐富的 SDK(Java/Go/Python),兼容 Kubernetes 雲原生部署。
- 可觀測性強內置監控指標(消息堆積、消費延遲、節點狀態),支持接入 Prometheus/Grafana,提供消息軌跡追蹤,便於問題定位。
2025 核心版本(5.x 穩定版)更新
- 雲原生增強:全面適配 ARM 架構,支持容器化部署時的資源彈性調度,降低雲環境部署成本;
- 性能優化:批量消息處理效率提升 20%,順序消息延遲降低 15%,內存佔用優化 10%;
- 生態兼容:新增與 Kafka Connect 無縫對接,支持消息跨中間件遷移;完善 gRPC 協議支持,適配跨語言調用;
- 運維簡化:新增可視化運維控制枱,支持一鍵擴容 / 縮容、消息回溯、死信隊列管理,降低運維門檻;
- 安全強化:默認啓用 ACL 權限控制,支持消息加密傳輸,防範未授權訪問與數據泄露。